180 lines
6.9 KiB
C
180 lines
6.9 KiB
C
/*
|
|
测试odbc支持smalldatetime类型
|
|
test: SQLProcedureColumns()函数,测试通过odbc取出存储过程入参FIRSTID为smalldatetime的列
|
|
*/
|
|
#include <stdio.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#include <sql.h>
|
|
#include <sqlext.h>
|
|
#include <sqltypes.h>
|
|
|
|
int main( )
|
|
{
|
|
SQLHENV hEnv = SQL_NULL_HENV;
|
|
SQLHDBC hDbc = SQL_NULL_HDBC;
|
|
SQLHSTMT hStmt = SQL_NULL_HSTMT;
|
|
SQLRETURN rc = SQL_SUCCESS;
|
|
SQLINTEGER RETCODE = 0;
|
|
SQLCHAR typename[200];
|
|
SQLCHAR schema[200] = "PUBLIC";
|
|
SQLCHAR table[200] = "ODBC_SMALLDATETIME_07";
|
|
SQLCHAR col[200] = "FIRSTTM";
|
|
SQLSMALLINT dateType = 0;
|
|
SQLSMALLINT sqlDateType = 0;
|
|
char procedure_name [200];
|
|
SQLINTEGER buffLen = 0;
|
|
SQLINTEGER columnSize = 0;
|
|
SQLINTEGER octLen = 0;
|
|
SQLLEN cbValue3;
|
|
SQLLEN cbDateType = 0;
|
|
SQLLEN cbSqlDateType = 0;
|
|
SQLLEN cbBuffLen = 0;
|
|
SQLLEN cbTypeName = 0;
|
|
SQLLEN cbColSize = 0;
|
|
SQLLEN cbOctLen = 0;
|
|
|
|
(void) printf ("**** Entering CLIP06.\n\n");
|
|
/*****************************************************************/
|
|
/* Allocate environment handle */
|
|
/*****************************************************************/
|
|
RETCODE = SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &hEnv);
|
|
if (!SQL_SUCCEEDED(RETCODE))
|
|
{
|
|
printf("SQLAllocHandle ENV error!\n");
|
|
goto dberror;
|
|
}
|
|
SQLSetEnvAttr(hEnv, SQL_ATTR_ODBC_VERSION, (void*)SQL_OV_ODBC3, 0);
|
|
|
|
/*****************************************************************/
|
|
/* Allocate connection handle to DSN */
|
|
/*****************************************************************/
|
|
RETCODE = SQLAllocHandle(SQL_HANDLE_DBC, hEnv, &hDbc);
|
|
if( !SQL_SUCCEEDED(RETCODE) ) // Could not get a Connect Handle
|
|
{
|
|
printf("SQLAllocHandle dbc error!\n");
|
|
goto dberror;
|
|
}
|
|
/*****************************************************************/
|
|
/* CONNECT TO data source (STLEC1) */
|
|
/*****************************************************************/
|
|
RETCODE = SQLConnect(hDbc, // Connect handle
|
|
(SQLCHAR *)"gaussdb", // DSN
|
|
SQL_NTS, // DSN is nul-terminated
|
|
NULL, // Null UID
|
|
0 ,
|
|
NULL, // Null Auth string
|
|
0);
|
|
|
|
if( !SQL_SUCCEEDED(RETCODE)) // Connect failed
|
|
{
|
|
printf("connetct failed!");
|
|
goto dberror;
|
|
}
|
|
/*****************************************************************/
|
|
/* Allocate statement handle */
|
|
/*****************************************************************/
|
|
rc = SQLAllocHandle(SQL_HANDLE_STMT, hDbc, &hStmt);
|
|
if (!SQL_SUCCEEDED(rc))
|
|
{
|
|
printf("SQLAllocHandle error!\n");
|
|
goto exit;
|
|
}
|
|
|
|
/*****************************************************************/
|
|
/* */
|
|
/* Retrieve native SQL types from DSN ------------> */
|
|
/* */
|
|
/* The result set consists of 15 columns. We only bind */
|
|
/* serveral we modified for smalldatetime. Note: Need */
|
|
/* not bind all columns of result set -- only those required. */
|
|
/* */
|
|
/*****************************************************************/
|
|
rc = SQLExecDirect(hStmt," create or replace function odbc_smalldatetime_07(in firsttm smalldatetime) returns smalldatetime as $$ BEGIN return firsttm;END;$$ LANGUAGE plpgsql;",SQL_NTS);
|
|
if (!SQL_SUCCEEDED(rc))
|
|
{
|
|
printf("create function error!\n");
|
|
goto exit;
|
|
}
|
|
|
|
rc = SQLProcedureColumns(hStmt, NULL, 0, schema, sizeof(schema),table, sizeof(table),NULL, sizeof(col));
|
|
|
|
|
|
if (!SQL_SUCCEEDED(rc))
|
|
{
|
|
printf("SQLProcedureColumns error!\n");
|
|
goto exit;
|
|
}
|
|
rc = SQLBindCol (hStmt, // bind procedure_name
|
|
3,
|
|
SQL_C_CHAR,
|
|
procedure_name,
|
|
sizeof(procedure_name),
|
|
&cbValue3);
|
|
rc = SQLBindCol(hStmt,6,SQL_C_SSHORT, (SQLPOINTER)&dateType,0,&cbDateType);
|
|
rc = SQLBindCol(hStmt,7,SQL_C_CHAR, (SQLPOINTER)typename,sizeof(typename),&cbTypeName);
|
|
rc = SQLBindCol(hStmt,8,SQL_C_ULONG, (SQLPOINTER)&columnSize,0,&cbColSize);
|
|
rc = SQLBindCol(hStmt,9,SQL_C_ULONG, (SQLPOINTER)&buffLen,0,&cbBuffLen);
|
|
rc = SQLBindCol(hStmt,15,SQL_C_SSHORT, (SQLPOINTER)&sqlDateType,0,&cbSqlDateType);
|
|
rc = SQLBindCol(hStmt,17,SQL_C_ULONG, (SQLPOINTER)&octLen,0,&cbOctLen);
|
|
/*****************************************************************/
|
|
/* Answer set is available - Fetch rows and print parameters for */
|
|
/* all procedures. */
|
|
/*****************************************************************/
|
|
printf ("**** begin fetch variable.\n");
|
|
rc = SQLFetch(hStmt);
|
|
while(rc != SQL_NO_DATA)
|
|
{
|
|
printf("PROCEDURE NAME ----: %s\n",procedure_name);
|
|
printf("DATA_TYPE ----: %d SQL_TYPE_TIMESTAMP = %d \n",dateType,SQL_TYPE_TIMESTAMP);
|
|
|
|
printf("TYPE_NAME ----: %s\n",typename);
|
|
|
|
printf("COLUMN_SIZE ----: %d\n",columnSize);
|
|
|
|
printf("SQL_DATA_TYPE ----: %d\n",sqlDateType);
|
|
|
|
printf("BUFFER_LENGTH ----: %d\n",buffLen);
|
|
|
|
printf("CHAR_OCTET_LENGTH----: %d\n",buffLen);
|
|
|
|
rc = SQLFetch(hStmt);
|
|
};
|
|
|
|
|
|
/*****************************************************************/
|
|
/* Free statement handle */
|
|
/*****************************************************************/
|
|
RETCODE = SQLFreeHandle(SQL_HANDLE_STMT, hStmt);
|
|
if (!SQL_SUCCEEDED(RETCODE)) // An advertised API failed
|
|
goto dberror;
|
|
|
|
/*****************************************************************/
|
|
/* DISCONNECT from data source */
|
|
/*****************************************************************/
|
|
RETCODE = SQLDisconnect(hDbc);
|
|
if (!SQL_SUCCEEDED(RETCODE))
|
|
goto dberror;
|
|
|
|
/*****************************************************************/
|
|
/* Deallocate connection handle */
|
|
/*****************************************************************/
|
|
RETCODE = SQLFreeHandle(SQL_HANDLE_DBC, hDbc);
|
|
if (!SQL_SUCCEEDED(RETCODE))
|
|
goto dberror;
|
|
|
|
/*****************************************************************/
|
|
/* Free environment handle */
|
|
/*****************************************************************/
|
|
RETCODE = SQLFreeHandle(SQL_HANDLE_ENV, hEnv);
|
|
if (!SQL_SUCCEEDED(RETCODE))
|
|
goto exit;
|
|
return 0;
|
|
|
|
dberror:
|
|
RETCODE=12;
|
|
exit:
|
|
(void) printf ("**** Exiting CLIP06.\n\n");
|
|
return(RETCODE);
|
|
}
|