/******************************************************************************* ** ** Source File Name = getcurs.c 1.3 ** ** Licensed Materials - Property of IBM ** ** (C) COPYRIGHT International Business Machines Corp. 1995, 1999 ** All Rights Reserved. ** ** US Government Users Restricted Rights - Use, duplication or ** disclosure restricted by GSA ADP Schedule Contract with IBM Corp. ** ** ** PURPOSE : ** Example of directly executing a SELECT and positioned UPDATE SQL statement. ** Two statement handles are used, and SQLGetCursor is used to retrieve the ** generated cursor name. ** ** For more information about these samples see the README file. ** ** For more information on programming in CLI see the: ** - "Building CLI Applications" section of the Application Building Guide, and the ** - CLI Guide and Reference. ** ** For more information on the SQL language see the SQL Reference. ** *********************************************************************************/ #include <stdio.h> #include <string.h> #include <stdlib.h> #include <sqlcli1.h> #include "samputil.h" /* Header file for CLI sample code */ /* For the Macintosh environment when generating 68K applications */ #ifdef DB268K /* Need to include ASLM for 68K applications */ #include <LibraryManager.h> #endif #define MAX_STMT_LEN 255 /* Global Variables for user id and password. To keep samples simple, not a recommended practice. */ extern SQLCHAR server[SQL_MAX_DSN_LENGTH + 1] ; extern SQLCHAR uid[MAX_UID_LENGTH + 1] ; extern SQLCHAR pwd[MAX_PWD_LENGTH + 1] ; /** main **/ int main( int argc, char * argv[] ) { SQLHANDLE henv, hdbc, hstmt1, hstmt2 ; SQLRETURN rc, rc2 ; /*--> SQLL1X04.SCRIPT */ SQLCHAR * sqlstmt = ( SQLCHAR * ) "SELECT name, job FROM staff " "WHERE job = 'Clerk' " "FOR UPDATE OF job" ; /*<-- */ SQLCHAR updstmt[MAX_STMT_LEN + 1] ; struct { SQLINTEGER ind ; SQLCHAR s[10] ; } name ; struct { SQLINTEGER ind ; SQLCHAR s[6] ; } job ; SQLCHAR cursor[19], newjob[6] ; SQLSMALLINT clength ; /* For the Macintosh environment when generating 68K applications */ #ifdef DB268K /* Before making any API calls for 68K environment, need to initialize the Library Manager */ InitLibraryManager(0,kCurrentZone,kNormalMemory); atexit(CleanupLibraryManager); #endif /* macro to initalize server, uid and pwd */ INIT_UID_PWD ; /* allocate an environment handle */ rc = SQLAllocHandle( SQL_HANDLE_ENV, SQL_NULL_HANDLE, &henv ) ; if ( rc != SQL_SUCCESS ) return( terminate( henv, rc ) ) ; /* allocate a connect handle, and connect */ rc = DBconnect( henv, &hdbc ) ; if ( rc != SQL_SUCCESS ) return( terminate( henv, rc ) ) ; rc = SQLAllocHandle( SQL_HANDLE_STMT, hdbc, &hstmt1 ) ; CHECK_HANDLE( SQL_HANDLE_DBC, hdbc, rc ) ; /* allocate second statement handle for update statement */ rc = SQLAllocHandle( SQL_HANDLE_STMT, hdbc, &hstmt2 ) ; CHECK_HANDLE( SQL_HANDLE_DBC, hdbc, rc ) ; /*--> */ rc = SQLExecDirect( hstmt1, sqlstmt, SQL_NTS ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; /* Get Cursor of the SELECT statement's handle */ rc = SQLGetCursorName( hstmt1, cursor, 19, &clength ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; /* bind name to first column in the result set */ rc = SQLBindCol( hstmt1, 1, SQL_C_CHAR, name.s, 10, &name.ind ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; /* bind job to second column in the result set */ rc = SQLBindCol( hstmt1, 2, SQL_C_CHAR, job.s, 6, &job.ind ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; printf( "Job Change for all clerks\n" ) ; while ((rc = SQLFetch(hstmt1)) == SQL_SUCCESS) { printf("Name: %-9.9s Job: %-5.5s \n", name.s, job.s); printf("Enter new job or return to continue\n"); gets((char *)newjob); if (newjob[0] != '\0') { sprintf((char *)updstmt, "UPDATE staff set job = '%s' where current of %s", newjob, cursor); rc2 = SQLExecDirect(hstmt2, updstmt, SQL_NTS); CHECK_HANDLE( SQL_HANDLE_STMT, hstmt2, rc2 ) ; } } if ( rc != SQL_NO_DATA_FOUND ) CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; /*<-- */ /* Disconnect and free up CLI resources. */ /* Commit the changes. */ printf( "Commiting Transaction\n" ) ; rc = SQLEndTran( SQL_HANDLE_DBC, hdbc, SQL_COMMIT ) ; CHECK_HANDLE( SQL_HANDLE_DBC, hdbc, rc ) ; rc = SQLFreeHandle( SQL_HANDLE_STMT, hstmt1 ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt1, rc ) ; rc = SQLFreeHandle( SQL_HANDLE_STMT, hstmt2 ) ; CHECK_HANDLE( SQL_HANDLE_STMT, hstmt2, rc ) ; printf( "\n>Disconnecting .....\n" ) ; rc = SQLDisconnect( hdbc ) ; CHECK_HANDLE( SQL_HANDLE_DBC, hdbc, rc ) ; rc = SQLFreeHandle( SQL_HANDLE_DBC, hdbc ) ; CHECK_HANDLE( SQL_HANDLE_DBC, hdbc, rc ) ; rc = SQLFreeHandle( SQL_HANDLE_ENV, henv ) ; if ( rc != SQL_SUCCESS ) return( terminate( henv, rc ) ) ; return( SQL_SUCCESS ) ; } /* end main */