|
|
@@ -1,191 +0,0 @@
|
|
|
-#include <stdio.h>
|
|
|
-#include <stdlib.h>
|
|
|
-#include <string.h>
|
|
|
-#ifdef WIN32
|
|
|
-#include <io.h>
|
|
|
-#include <windows.h>
|
|
|
-#endif
|
|
|
-#ifdef UNIX
|
|
|
-#include <sqltypes.h>
|
|
|
-#endif
|
|
|
-#include <sql.h>
|
|
|
-#include <sqlext.h>
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-#define BUF_LENGTH 65000
|
|
|
-
|
|
|
-/* environment variable */
|
|
|
-SQLHENV env=NULL;
|
|
|
-SQLHDBC dbc=NULL;
|
|
|
-SQLHSTMT stmt=NULL;
|
|
|
-SQLHSTMT cstmt=NULL;
|
|
|
-unsigned char *dsn;
|
|
|
-unsigned char *user;
|
|
|
-unsigned char *pass;
|
|
|
-
|
|
|
-RETCODE retcod;
|
|
|
-
|
|
|
-/*description a columns of result of request */
|
|
|
-SQLSMALLINT ColumnCount;
|
|
|
-unsigned int ColNumber;
|
|
|
-unsigned char ColName[SQL_MAX_COLUMN_NAME_LEN];
|
|
|
-unsigned int Length;
|
|
|
-unsigned int Type;
|
|
|
-unsigned int Size;
|
|
|
-unsigned int Digits;
|
|
|
-unsigned int Nullable;
|
|
|
-
|
|
|
-
|
|
|
-unsigned char data_buf[BUF_LENGTH];
|
|
|
-unsigned long OutData;
|
|
|
-
|
|
|
-/* function print error message*/
|
|
|
-void PrintError(HENV env,HDBC dbc,HSTMT stmt,RETCODE retcod)
|
|
|
-{
|
|
|
- SQLINTEGER nError;
|
|
|
- SQLSMALLINT TextLength;
|
|
|
- unsigned char BufErrMsg[SQL_MAX_MESSAGE_LENGTH+1];
|
|
|
- unsigned char SqlState[128];
|
|
|
-
|
|
|
- SQLError(env,dbc,stmt,SqlState,&nError,BufErrMsg,512, &TextLength);
|
|
|
- printf("%s\n" ,BufErrMsg);
|
|
|
-}
|
|
|
-
|
|
|
-void sqlquery(SQLHDBC dbc,SQLHSTMT stmt, unsigned char *strquery)
|
|
|
-{
|
|
|
- retcod=SQLAllocStmt(dbc, &stmt);
|
|
|
-
|
|
|
- retcod=SQLExecDirect(stmt,strquery,SQL_NTS);
|
|
|
- if(retcod!=SQL_SUCCESS)
|
|
|
- { PrintError(env,dbc,stmt,retcod);}
|
|
|
-
|
|
|
- SQLNumResultCols(stmt,&ColumnCount);
|
|
|
-
|
|
|
- while(SQLFetch(stmt)==SQL_SUCCESS)
|
|
|
- {
|
|
|
- for(ColNumber=1; ColNumber<=ColumnCount ; ColNumber++)
|
|
|
- {
|
|
|
- SQLGetData(stmt,ColNumber,SQL_CHAR,data_buf,BUF_LENGTH,&OutData);
|
|
|
- printf("%s|",data_buf);
|
|
|
- }
|
|
|
- printf("\n",data_buf);
|
|
|
- strcpy(data_buf,"");
|
|
|
- }
|
|
|
- SQLFreeStmt( stmt, SQL_DROP );
|
|
|
-}
|
|
|
-
|
|
|
-/* isqlodbc dsn[[,user][,pass]] ["SQLCMD"] */
|
|
|
-int main(int argc, char *argv[])
|
|
|
-{
|
|
|
- unsigned char qbuf[64000];
|
|
|
- unsigned char *ptr=NULL;
|
|
|
-
|
|
|
- /* Allocate environment and database connection handles */
|
|
|
- retcod=SQLAllocEnv( &env );
|
|
|
- if(retcod!=SQL_SUCCESS)
|
|
|
- {
|
|
|
- PrintError(env,dbc,stmt,retcod);
|
|
|
- SQLFreeEnv(env);
|
|
|
- return (-1);
|
|
|
- }
|
|
|
- retcod = SQLAllocConnect( env, &dbc );
|
|
|
- if(retcod!=SQL_SUCCESS)
|
|
|
- {
|
|
|
- PrintError(env,dbc,stmt,retcod);
|
|
|
- SQLFreeConnect( dbc );
|
|
|
- return (-1);
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- if(argc > 1 )
|
|
|
- {
|
|
|
- /* parsing command line and get parametrs */
|
|
|
- dsn = strtok(argv[1],",");
|
|
|
- user = strtok(NULL, ",");
|
|
|
- pass = strtok(NULL, ",");
|
|
|
-
|
|
|
- /* Connect from DSN */
|
|
|
- retcod=SQLConnect(dbc,dsn,SQL_NTS,user,SQL_NTS,pass,SQL_NTS);
|
|
|
-
|
|
|
- if(retcod!=SQL_SUCCESS)
|
|
|
- { PrintError(env,dbc,stmt,retcod); }
|
|
|
- else
|
|
|
- {
|
|
|
- if (argc > 2)
|
|
|
- {
|
|
|
- /*sql cmd from command line*/
|
|
|
- sqlquery(dbc,stmt,argv[2]);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- /*sql cmd from stdin */
|
|
|
- if( isatty(0) ){ printf(".tables - list table\n.q - exit\nsql>"); }
|
|
|
- while(fgets(qbuf,63000,stdin) != NULL )
|
|
|
- {
|
|
|
- ptr=strrchr(qbuf,';');
|
|
|
- if (ptr!=NULL)
|
|
|
- {
|
|
|
- sqlquery(dbc,stmt,qbuf);
|
|
|
- }
|
|
|
- else
|
|
|
- {
|
|
|
- /*cmd exit*/
|
|
|
- if (strstr(qbuf,".q")){ break; };
|
|
|
-
|
|
|
- /*cmd table list*/
|
|
|
- if (strstr(qbuf,".tables"))
|
|
|
- {
|
|
|
- retcod=SQLAllocStmt(dbc, &stmt);
|
|
|
- if(retcod!=SQL_SUCCESS){ PrintError(env,dbc,stmt,retcod); }
|
|
|
- else
|
|
|
- {
|
|
|
- retcod=SQLTables(stmt,NULL,0,NULL,0,NULL,0,NULL,0);
|
|
|
- if(retcod !=SQL_SUCCESS) { PrintError(env,dbc,stmt,retcod);}
|
|
|
- while(SQLFetch(stmt)==SQL_SUCCESS)
|
|
|
- {
|
|
|
- SQLGetData(stmt,3,SQL_CHAR,data_buf,BUF_LENGTH,&OutData);
|
|
|
- printf("%s|",data_buf);
|
|
|
-
|
|
|
- /*list columns */
|
|
|
- retcod=SQLAllocStmt(dbc, &cstmt);
|
|
|
- retcod=SQLColumns(cstmt,NULL,0,NULL,0,data_buf,strlen(data_buf),NULL,0);
|
|
|
-
|
|
|
- if(retcod !=SQL_SUCCESS) { PrintError(env,dbc,stmt,retcod);}
|
|
|
- else
|
|
|
- {
|
|
|
- printf("create table %s (",data_buf);
|
|
|
- while(SQLFetch(cstmt)==SQL_SUCCESS)
|
|
|
- {
|
|
|
- SQLGetData(cstmt,4,SQL_CHAR,data_buf,BUF_LENGTH,&OutData);
|
|
|
- printf("%s ",data_buf);
|
|
|
- SQLGetData(cstmt,6,SQL_CHAR,data_buf,BUF_LENGTH,&OutData);
|
|
|
- printf("%s, ",data_buf);
|
|
|
- }
|
|
|
- printf(");\n");
|
|
|
- SQLFreeStmt( cstmt, SQL_DROP );
|
|
|
- }/*end list columns*/
|
|
|
-
|
|
|
- }/*end while SQLFetch */
|
|
|
- SQLFreeStmt( stmt, SQL_DROP );
|
|
|
- }
|
|
|
-
|
|
|
- }/*end if (strstr(qbuf,".tables")) */
|
|
|
-
|
|
|
-
|
|
|
- } /*end else cmd*/
|
|
|
- if( isatty(0) ){ printf("sql>"); }
|
|
|
- } /*end while*/
|
|
|
- }
|
|
|
- }
|
|
|
- SQLDisconnect(dbc);
|
|
|
- } /* if (argc > 2) */
|
|
|
- else
|
|
|
- {
|
|
|
- printf("isqlodbc dsn[[,user][,pass]] [\"SQLCMD\"]\n");
|
|
|
- }
|
|
|
-
|
|
|
- SQLFreeConnect( dbc );
|
|
|
- SQLFreeEnv( env );
|
|
|
- return 0;
|
|
|
-}
|
z3APA3A