부록 A. Sample Code#
이 부록은 본 매뉴얼에서 전반적으로 사용된 예제에 대하여 전체 코드 리스트를 제공한다.
프로그래밍 시 각 단계에서 주의할 점#
Altibase CLI 애플리케이션 작성시 주의할 점과 범하기 쉬운 오류에 대해서 설명한다.
파라미터 바인딩#
이 절은 SQLBindCol()과 SQLBindParameter() 함수의 마지막 인자인 valueLength (지시자, indicator) 사용 시의 주의 사항에 대해 설명한다.
SQLBindCol() 함수의 valueLength는 출력 인자이다. 조회된 데이터가 NULL 이면, 이 인자 변수에 SQL_NULL_DATA 가 반환된다.
SQLBindParameter() 함수의 바인딩 입출력 타입을 SQL_PARAM_INPUT 로 지정하면, valueLength는 입력 인자로 사용된다. 바인딩되는 인자 변수의 데이터 타입이 가변 길이 타입일 경우 실제 바인딩되는 데이터의 길이를 표시하는 데 사용된다.
예를 들어, valueLength에 아래의 값을 지정할 수 있다.
-
SQL_NTS
버퍼가 null ( '\0' ) 로 끝나는 스트링 -
SQL_NULL_DATA
널 값을 바인딩 -
SQL_DATA_AT_EXEC 혹은 SQL_LEN_DATA_AT_EXEC() 매크로의 결과값
사용자가 SQLPutData(), SQLParamData() 의 조합으로 데이터를 삽입하겠다는 의미로써, SQLExecute() 실행시 SQL_NEED_DATA 를 리턴한다.
SQLBindParameter()에서 입출력 타입을 SQL_PARAM_OUTPUT 로 지정할 경우의 valueLength는 SELECT 문 실행시 사용되는 SQLBindCol() 함수의 valueLength와 동일한 역할을 한다.
트랜잭션 Commit#
autocommit off의 세션에서 commit을 하지 않고 응용프로그램을 종료할 경우 commit 하지 않은 트랜잭션은 모두 Altibase 서버에 의해 롤백(rollback) 된다. 그러나, SQLDisconnect() 를 호출하고 응용프로그램을 종료할 경우에는 Altibase 서버가 커밋되지 않은 트랜잭션들을 commit 한다.
SQL 함수 사용#
SQLFreeStmt()에서 두 번째 인자를 SQL_DROP으로 했을 경우에는 핸들의 상태가 핸들을 할당하기 이전의 상태가 된다. 즉, SQLFreeHandle()과 완전히 동일한 동작을 수행한다. 그러나, SQL_CLOSE 인자를 사용하면 SQLCloseCursor()와 완전히 동일한 동작을 수행한다. SQLPrepare()를 수행한 명령문의 경우에는, SQLCloseCursor() 호출 후에 준비(prepare)를 한 상태로 돌아가게 된다.
SQLPrepare()를 사용하여 SELECT 문을 수행할 경우, SQLExecute() -> SQLFetch() 시 SELECT 문의 수행 결과, 결과 집합의 마지막 레코드까지 페치를 하지 않고, 다른 호스트 변수를 바인딩해서 SQLExecute()를 다시 호출할 경우에 "invalid cursor state"가 발생한다. 이를 방지하기 위해서는 SQLCloseCursor()를 호출하고 나서 SQLExecute()를 호출하면 된다.
Altibase CLI 프로그램 기본 예제#
/***********************************************
** 파일명 = demo_ex1.cpp
***********************************************/
#include <sqlcli.h>
#include <stdio.h>
#include <stdlib.h>
#define SQL_LEN 1000
#define MSG_LEN 1024
SQLHENV env; // Environment Handle
SQLHDBC dbc; // Connection Handle
int conn_flag;
SQLRETURN alloc_handle();
SQLRETURN db_connect();
void free_handle();
SQLRETURN execute_select();
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q);
int main()
{
SQLRETURN rc;
env = SQL_NULL_HENV;
dbc = SQL_NULL_HDBC;
conn_flag = 0;
/* allocate handle */
rc = alloc_handle();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* Connect to Altibase Server */
rc = db_connect();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
rc = execute_select();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
free_handle();
}
static void print_diagnostic(SQLSMALLINT aHandleType, SQLHANDLE aHandle)
{
SQLRETURN rc;
SQLSMALLINT sRecordNo;
SQLCHAR sSQLSTATE[6];
SQLCHAR sMessage[2048];
SQLSMALLINT sMessageLength;
SQLINTEGER sNativeError;
sRecordNo = 1;
while ((rc = SQLGetDiagRec(aHandleType,
aHandle,
sRecordNo,
sSQLSTATE,
&sNativeError,
sMessage,
sizeof(sMessage),
&sMessageLength)) != SQL_NO_DATA)
{
printf("Diagnostic Record %d\n", sRecordNo);
printf(" SQLSTATE : %s\n", sSQLSTATE);
printf(" Message text : %s\n", sMessage);
printf(" Message len : %d\n", sMessageLength);
printf(" Native error : 0x%X\n", sNativeError);
if (rc != SQL_SUCCESS && rc != SQL_SUCCESS_WITH_INFO)
{
break;
}
sRecordNo++;
}
}
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q)
{
printf("Error : %s\n",q);
if (aStmt == SQL_NULL_HSTMT)
{
if (aCon != SQL_NULL_HDBC)
{
print_diagnostic(SQL_HANDLE_DBC, aCon);
}
}
else
{
print_diagnostic(SQL_HANDLE_STMT, aStmt);
}
}
SQLRETURN alloc_handle()
{
/* allocate Environment handle */
if (SQLAllocEnv(&env) != SQL_SUCCESS)
{
printf("SQLAllocEnv error!!\n");
return SQL_ERROR;
}
/* allocate Connection handle */
if (SQLAllocConnect(env, &dbc) != SQL_SUCCESS)
{
printf("SQLAllocConnect error!!\n");
return SQL_ERROR;
}
return SQL_SUCCESS;
}
void free_handle()
{
if ( conn_flag == 1 )
{
/* close connection */
SQLDisconnect( dbc );
}
/* free connection handle */
if ( dbc != NULL )
{
SQLFreeConnect( dbc );
}
if ( env != NULL )
{
SQLFreeEnv( env );
}
}
SQLRETURN db_connect()
{
char *USERNAME = "SYS"; // user name
char *PASSWD = "MANAGER"; // user password
char *NLS = "US7ASCII"; // NLS_USE ( KO16KSC5601, US7ASCII )
char connStr[1024];
sprintf(connStr,
"DSN=127.0.0.1;UID=%s;PWD=%s;CONNTYPE=%d;NLS_USE=%s", /* ;PORT_NO=20300", */
USERNAME, PASSWD, 1, NLS);
/* establish connection */
if (SQLDriverConnect( dbc, NULL, (SQLCHAR *)connStr, SQL_NTS,
NULL, 0, NULL,
SQL_DRIVER_NOPROMPT ) != SQL_SUCCESS)
{
execute_err(dbc, SQL_NULL_HSTMT, "SQLDriverConnect");
return SQL_ERROR;
}
conn_flag = 1;
return SQL_SUCCESS;
}
SQLRETURN execute_select()
{
SQLHSTMT stmt = SQL_NULL_HSTMT;
SQLRETURN rc;
int i;
char query[SQL_LEN];
SQLSMALLINT columnCount;
char columnName[50];
SQLSMALLINT columnNameLength;
SQLSMALLINT dataType;
SQLSMALLINT scale;
SQLSMALLINT nullable;
SQLULEN columnSize;
void **columnPtr;
SQLLEN *columnInd;
/* allocate Statement handle */
if (SQL_ERROR == SQLAllocStmt(dbc, &stmt))
{
printf("SQLAllocStmt error!!\n");
return SQL_ERROR;
}
sprintf(query,"SELECT * FROM DEMO_EX1");
if (SQLExecDirect(stmt, (SQLCHAR *)query, SQL_NTS) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
SQLNumResultCols(stmt, &columnCount);
columnPtr = (void**) malloc( sizeof(void*) * columnCount );
columnInd = (SQLLEN*) malloc( sizeof(SQLLEN) * columnCount );
if ( columnPtr == NULL )
{
return SQL_ERROR;
}
for ( i=0; i<columnCount; i++ )
{
SQLDescribeCol(stmt, i+1,
(SQLCHAR *)columnName, sizeof(columnName), &columnNameLength,
&dataType, &columnSize, &scale, &nullable);
printf("columnName = %s, nullable = %d\n", columnName, nullable);
switch (dataType)
{
case SQL_CHAR:
printf("%s : CHAR(%d)\n", columnName, columnSize);
columnPtr[i] = (char*) malloc( columnSize + 1 );
SQLBindCol(stmt, i+1, SQL_C_CHAR, columnPtr[i], columnSize+1, &columnInd[i]);
break;
case SQL_VARCHAR:
printf("%s : VARCHAR(%d)\n", columnName, columnSize);
columnPtr[i] = (char*) malloc( columnSize + 1 );
SQLBindCol(stmt, i+1, SQL_C_CHAR, columnPtr[i], columnSize+1, &columnInd[i]);
break;
case SQL_INTEGER:
printf("%s : INTEGER\n", columnName);
columnPtr[i] = (int*) malloc( sizeof(int) );
SQLBindCol(stmt, i+1, SQL_C_SLONG, columnPtr[i], 0, &columnInd[i]);
break;
case SQL_SMALLINT:
printf("%s : SMALLINT\n", columnName);
columnPtr[i] = (short*) malloc( sizeof(short) );
SQLBindCol(stmt, i+1, SQL_C_SSHORT, columnPtr[i], 0, &columnInd[i]);
break;
case SQL_NUMERIC:
printf("%s : NUMERIC(%d,%d)\n", columnName, columnSize, scale);
columnPtr[i] = (double*) malloc( sizeof(double) );
SQLBindCol(stmt, i+1, SQL_C_DOUBLE, columnPtr[i], 0, &columnInd[i]);
break;
case SQL_TYPE_TIMESTAMP:
printf("%s : DATE\n", columnName);
columnPtr[i] = (SQL_TIMESTAMP_STRUCT*) malloc( sizeof(SQL_TIMESTAMP_STRUCT) );
SQLBindCol(stmt, i+1, SQL_C_TYPE_TIMESTAMP, columnPtr[i], 0, &columnInd[i]);
break;
}
}
/* fetches next rowset of data from the result set and print to stdout */
printf("==========================================================================\n");
while ( (rc = SQLFetch(stmt)) != SQL_NO_DATA)
{
if ( rc != SQL_SUCCESS )
{
execute_err(dbc, stmt, query);
break;
}
for ( i=0; i<columnCount; i++ )
{
SQLDescribeCol(stmt, i+1,
NULL, 0, NULL,
&dataType, NULL, NULL, NULL);
if ( columnInd[i] == SQL_NULL_DATA )
{
printf("NULL\t");
continue;
}
switch (dataType)
{
case SQL_CHAR:
case SQL_VARCHAR:
printf("%s\t", columnPtr[i]);
break;
case SQL_INTEGER:
printf("%d\t", *(int*)columnPtr[i]);
break;
case SQL_SMALLINT:
printf("%d\t", *(short*)columnPtr[i]);
break;
case SQL_NUMERIC:
printf("%10.3f\t", *(double*)columnPtr[i]);
break;
case SQL_TYPE_TIMESTAMP:
printf("%4d/%02d/%02d %02d:%02d:%02d\t",
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->year,
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->month,
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->day,
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->hour,
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->minute,
((SQL_TIMESTAMP_STRUCT*)columnPtr[i])->second);
break;
}
}
printf("\n");
}
SQLFreeStmt(stmt, SQL_DROP);
for ( i=0; i<columnCount; i++ )
{
free( columnPtr[i] );
}
free( columnPtr );
free( columnInd );
return SQL_SUCCESS;
}
메타 정보 검색 프로그램 예제#
/***********************************************
** 파일명 = demo_meta1.cpp
** 메타 정보 검색 프로그램 예제
************************************************/
#include <sqlcli.h>
#include <stdio.h>
#include <stdlib.h>
#define SQL_LEN 1000
#define MSG_LEN 1024
SQLHENV env; // Environment Handle
SQLHDBC dbc; // Connection Handle
int conn_flag;
SQLRETURN alloc_handle();
SQLRETURN db_connect();
void free_handle();
SQLRETURN get_tables();
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q);
int main()
{
SQLRETURN rc;
env = SQL_NULL_HENV;
dbc = SQL_NULL_HDBC;
conn_flag = 0;
/* allocate handle */
rc = alloc_handle();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* Connect to Altibase Server */
rc = db_connect();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
rc = get_tables();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
free_handle();
}
static void print_diagnostic(SQLSMALLINT aHandleType, SQLHANDLE aHandle)
{
SQLRETURN rc;
SQLSMALLINT sRecordNo;
SQLCHAR sSQLSTATE[6];
SQLCHAR sMessage[2048];
SQLSMALLINT sMessageLength;
SQLINTEGER sNativeError;
sRecordNo = 1;
while ((rc = SQLGetDiagRec(aHandleType,
aHandle,
sRecordNo,
sSQLSTATE,
&sNativeError,
sMessage,
sizeof(sMessage),
&sMessageLength)) != SQL_NO_DATA)
{
printf("Diagnostic Record %d\n", sRecordNo);
printf(" SQLSTATE : %s\n", sSQLSTATE);
printf(" Message text : %s\n", sMessage);
printf(" Message len : %d\n", sMessageLength);
printf(" Native error : 0x%X\n", sNativeError);
if (rc != SQL_SUCCESS && rc != SQL_SUCCESS_WITH_INFO)
{
break;
}
sRecordNo++;
}
}
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q)
{
printf("Error : %s\n",q);
if (aStmt == SQL_NULL_HSTMT)
{
if (aCon != SQL_NULL_HDBC)
{
print_diagnostic(SQL_HANDLE_DBC, aCon);
}
}
else
{
print_diagnostic(SQL_HANDLE_STMT, aStmt);
}
}
SQLRETURN alloc_handle()
{
/* allocate Environment handle */
if (SQLAllocEnv(&env) != SQL_SUCCESS)
{
printf("SQLAllocEnv error!!\n");
return SQL_ERROR;
}
/* allocate Connection handle */
if (SQLAllocConnect(env, &dbc) != SQL_SUCCESS)
{
printf("SQLAllocConnect error!!\n");
return SQL_ERROR;
}
return SQL_SUCCESS;
}
void free_handle()
{
if ( conn_flag == 1 )
{
/* close connection */
SQLDisconnect( dbc );
}
/* free connection handle */
if ( dbc != NULL )
{
SQLFreeConnect( dbc );
}
if ( env != NULL )
{
SQLFreeEnv( env );
}
}
SQLRETURN db_connect()
{
char *USERNAME = "SYS"; // user name
char *PASSWD = "MANAGER"; // user password
char *NLS = "US7ASCII"; // NLS_USE ( KO16KSC5601, US7ASCII )
char connStr[1024];
sprintf(connStr,
"DSN=127.0.0.1;UID=%s;PWD=%s;CONNTYPE=%d;NLS_USE=%s", /* ;PORT_NO=20300", */
USERNAME, PASSWD, 1, NLS);
/* establish connection */
if (SQLDriverConnect( dbc, NULL, (SQLCHAR *) connStr, SQL_NTS,
NULL, 0, NULL,
SQL_DRIVER_NOPROMPT ) != SQL_SUCCESS)
{
execute_err(dbc, SQL_NULL_HSTMT, "SQLDriverConnect");
return SQL_ERROR;
}
conn_flag = 1;
return SQL_SUCCESS;
}
SQLRETURN get_tables()
{
SQLHSTMT stmt = SQL_NULL_HSTMT;
SQLRETURN rc;
char schem[50+1] = {0};
char name[50+1] = {0};
char type[50+1] = {0};
SQLLEN schem_ind;
SQLLEN name_ind;
SQLLEN type_ind;
/* allocate Statement handle */
if (SQL_ERROR == SQLAllocHandle(SQL_HANDLE_STMT, dbc, &stmt))
{
printf("SQLAllocHandle error!!\n");
return SQL_ERROR;
}
if (SQLTables(stmt,
NULL, 0,
NULL, 0,
NULL, 0,
NULL, 0) != SQL_SUCCESS)
{
execute_err(dbc, stmt, "SQLTables");
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindCol(stmt, 2, SQL_C_CHAR,
schem, sizeof(schem), &schem_ind) != SQL_SUCCESS)
{
execute_err(dbc, stmt, "SQLBindCol");
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindCol(stmt, 3, SQL_C_CHAR,
name, sizeof(name), &name_ind) != SQL_SUCCESS)
{
execute_err(dbc, stmt, "SQLBindCol");
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindCol(stmt, 4, SQL_C_CHAR,
type, sizeof(type), &type_ind) != SQL_SUCCESS)
{
execute_err(dbc, stmt, "SQLBindCol");
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
/* fetches the next rowset of data from the result set and print to stdout */
printf("TABLE_SCHEM\t\tTABLE_NAME\t\tTABLE_TYPE\n");
printf("=============================================================\n");
while ( (rc = SQLFetch(stmt)) != SQL_NO_DATA)
{
if ( rc == SQL_ERROR )
{
execute_err(dbc, stmt, "SQLFetch");
break;
}
printf("%-40s%-40s%s\n", schem, name, type);
}
SQLFreeHandle(SQL_HANDLE_STMT, stmt);/* == SQLFreeStmt(stmt, SQL_DROP); */
return SQL_SUCCESS;
}
프로시저 테스트 프로그램 예제#
/***********************************************
** 파일명 = proctest.cpp
** procedure 테스트 프로그램 예제
************************************************/
#include <sqlcli.h>
#include <stdio.h>
#include <stdlib.h>
#define SQL_LEN 1000
#define MSG_LEN 1024
SQLHENV env; // Environment Handle
SQLHDBC dbc; // Connection Handle
int conn_flag;
SQLRETURN alloc_handle();
SQLRETURN db_connect();
void free_handle();
SQLRETURN execute_proc();
SQLRETURN execute_select();
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q);
int main()
{
SQLRETURN rc;
env = SQL_NULL_HENV;
dbc = SQL_NULL_HDBC;
conn_flag = 0;
/* allocate handle */
rc = alloc_handle();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* Connect to Altibase Server */
rc = db_connect();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* select data */
rc = execute_select();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* procedure 실행 */
rc = execute_proc();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* select data */
rc = execute_select();
if ( rc != SQL_SUCCESS )
{
free_handle();
exit(1);
}
/* disconnect, free handles */
free_handle();
}
void execute_err(SQLHDBC aCon, SQLHSTMT aStmt, char* q)
{
SQLINTEGER errNo;
SQLSMALLINT msgLength;
SQLCHAR errMsg[MSG_LEN];
printf("Error : %s\n",q);
if (SQLError ( SQL_NULL_HENV, aCon, aStmt,
NULL, &errNo,
errMsg, MSG_LEN, &msgLength ) == SQL_SUCCESS)
{
printf(" Error : # %ld, %s\n", errNo, errMsg);
}
}
SQLRETURN alloc_handle()
{
/* allocate Environment handle */
if (SQLAllocEnv(&env) != SQL_SUCCESS)
{
printf("SQLAllocEnv error!!\n");
return SQL_ERROR;
}
/* allocate Connection handle */
if (SQLAllocConnect(env, &dbc) != SQL_SUCCESS)
{
printf("SQLAllocConnect error!!\n");
return SQL_ERROR;
}
return SQL_SUCCESS;
}
void free_handle()
{
if ( conn_flag == 1 )
{
/* close connection */
SQLDisconnect( dbc );
}
/* free connection handle */
if ( dbc != NULL )
{
SQLFreeConnect( dbc );
}
if ( env != NULL )
{
SQLFreeEnv( env );
}
}
SQLRETURN db_connect()
{
char *USERNAME = "SYS"; // user name
char *PASSWD = "MANAGER"; // user password
char *NLS = "US7ASCII"; // NLS_USE ( KO16KSC5601, US7ASCII )
char connStr[1024];
sprintf(connStr,
"DSN=127.0.0.1;UID=%s;PWD=%s;CONNTYPE=%d;NLS_USE=%s", /* ;PORT_NO=20300", */
USERNAME, PASSWD, 1, NLS);
/* establish connection */
if (SQLDriverConnect( dbc, NULL, (SQLCHAR *) connStr, SQL_NTS,
NULL, 0, NULL,
SQL_DRIVER_NOPROMPT ) != SQL_SUCCESS)
{
execute_err(dbc, SQL_NULL_HSTMT, "SQLDriverConnect");
return SQL_ERROR;
}
conn_flag = 1;
return SQL_SUCCESS;
}
SQLRETURN execute_select()
{
SQLHSTMT stmt = SQL_NULL_HSTMT;
SQLRETURN rc;
char query[SQL_LEN];
SQLINTEGER id;
char name[20+1];
SQL_TIMESTAMP_STRUCT birth;
/* allocate Statement handle */
if (SQL_ERROR == SQLAllocStmt(dbc, &stmt))
{
printf("SQLAllocStmt error!!\n");
return SQL_ERROR;
}
sprintf(query,"SELECT * FROM DEMO_EX6");
if (SQLPrepare(stmt, (SQLCHAR *)query, SQL_NTS) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
/* binds application data buffers to columns in the result set */
if (SQLBindCol(stmt, 1, SQL_C_SLONG,
&id, 0, NULL) != SQL_SUCCESS)
{
printf("SQLBindCol error!!!\n");
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindCol(stmt, 2, SQL_C_CHAR,
name, sizeof(name), NULL) != SQL_SUCCESS)
{
printf("SQLBindCol error!!!\n");
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindCol(stmt, 3, SQL_C_TYPE_TIMESTAMP,
&birth, 0, NULL) != SQL_SUCCESS)
{
printf("SQLBindCol error!!!\n");
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
/* fetches the next rowset of data from the result set and print to stdout */
printf("id\t Name\tbirth\n");
printf("=====================================================================\n");
if ( SQLExecute(stmt) != SQL_SUCCESS )
{
execute_err(dbc, stmt, "SQLExecute : ");
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
while ( (rc = SQLFetch(stmt)) != SQL_NO_DATA )
{
if ( rc != SQL_SUCCESS )
{
execute_err(dbc, stmt, query);
break;
}
printf("%d%20s\t%4d/%02d/%02d %02d:%02d:%02d\n",
id, name, birth.year, birth.month, birth.day,
birth.hour, birth.minute, birth.second);
}
SQLFreeStmt(stmt, SQL_DROP);
return SQL_SUCCESS;
}
SQLRETURN execute_proc()
{
SQLHSTMT stmt = SQL_NULL_HSTMT;
char query[SQL_LEN];
SQLINTEGER id;
char name[20+1];
SQL_TIMESTAMP_STRUCT birth;
SQLINTEGER ret = 0;
SQLLEN name_ind = SQL_NTS;
/* allocate Statement handle */
if (SQL_ERROR == SQLAllocStmt(dbc, &stmt))
{
printf("SQLAllocStmt error!!\n");
return SQL_ERROR;
}
sprintf(query,"EXEC DEMO_PROC6( ?, ?, ?, ? )");
/* prepares an SQL string for execution */
if (SQLPrepare(stmt, (SQLCHAR *) query, SQL_NTS) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindParameter(stmt,
1, /* Parameter number, starting at 1 */
SQL_PARAM_INPUT, /* in, out, inout */
SQL_C_SLONG, /* C data type of the parameter */
SQL_INTEGER, /* SQL data type of the parameter : char(8)*/
0, /* size of the column or expression, precision */
0, /* The decimal digits, scale */
&id, /* A pointer to a buffer for the parameter's data */
0, /* Length of the ParameterValuePtr buffer in bytes */
NULL /* indicator */
) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindParameter(stmt, 2, SQL_PARAM_INPUT,
SQL_C_CHAR, SQL_VARCHAR,
20, /* varchar(20) */
0,
name, sizeof(name), &name_ind) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindParameter(stmt, 3, SQL_PARAM_INPUT,
SQL_C_TYPE_TIMESTAMP, SQL_DATE,
0, 0, &birth, 0, NULL) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
if (SQLBindParameter(stmt, 4, SQL_PARAM_OUTPUT,
SQL_C_SLONG, SQL_INTEGER,
0, 0, &ret,
0,/* For all fixed size C data type, this argument is ignored */
NULL) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
/* executes a prepared statement */
id = 5;
sprintf(name, "name5");
birth.year=2004;birth.month=5;birth.day=14;
birth.hour=15;birth.minute=17;birth.second=20;
birth.fraction=0;
name_ind = 5; /* name => length=5 */
if (SQLExecute(stmt) != SQL_SUCCESS)
{
execute_err(dbc, stmt, query);
SQLFreeStmt(stmt, SQL_DROP);
return SQL_ERROR;
}
else
{
printf("\n======= Result of exec procedure ======\n");
printf("ret => %d\n\n", ret);
}
SQLFreeStmt(stmt, SQL_DROP);
return SQL_SUCCESS;
}