openGauss-connector-odbc/odbc-test-gauss/odbc_smalldatetime_07_SQLProcedureColumns.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);
}