SQLxxxx() to PGAPI_xxxx().
2) Handle an escaped date/time format as a parameter.
3) Improve the tuple allocation a little.
4) The preparation of ODBC 3.0 a little.
5) Updatable cursors(may be deprecated before long).
#include "sql.h"
#include "sqlext.h"
#endif
+#include "pgapifunc.h"
/* Bind parameters on a statement handle */
RETCODE SQL_API
-SQLBindParameter(
+PGAPI_BindParameter(
HSTMT hstmt,
UWORD ipar,
SWORD fParamType,
SDWORD FAR *pcbValue)
{
StatementClass *stmt = (StatementClass *) hstmt;
- static char *func = "SQLBindParameter";
+ static char *func = "PGAPI_BindParameter";
mylog("%s: entering...\n", func);
if (stmt->status == STMT_PREMATURE)
SC_recycle_statement(stmt);
- mylog("SQLBindParamater: ipar=%d, paramType=%d, fCType=%d, fSqlType=%d, cbColDef=%d, ibScale=%d, rgbValue=%d, *pcbValue = %d, data_at_exec = %d\n", ipar, fParamType, fCType, fSqlType, cbColDef, ibScale, rgbValue, pcbValue ? *pcbValue : -777, stmt->parameters[ipar].data_at_exec);
+ mylog("PGAPI_BindParamater: ipar=%d, paramType=%d, fCType=%d, fSqlType=%d, cbColDef=%d, ibScale=%d, rgbValue=%d, *pcbValue = %d, data_at_exec = %d\n", ipar, fParamType, fCType, fSqlType, cbColDef, ibScale, rgbValue, pcbValue ? *pcbValue : -777, stmt->parameters[ipar].data_at_exec);
return SQL_SUCCESS;
}
/* Associate a user-supplied buffer with a database column. */
RETCODE SQL_API
-SQLBindCol(
+PGAPI_BindCol(
HSTMT hstmt,
UWORD icol,
SWORD fCType,
SDWORD FAR *pcbValue)
{
StatementClass *stmt = (StatementClass *) hstmt;
- static char *func = "SQLBindCol";
+ static char *func = "PGAPI_BindCol";
mylog("%s: entering...\n", func);
- mylog("**** SQLBindCol: stmt = %u, icol = %d\n", stmt, icol);
+ mylog("**** PGAPI_BindCol: stmt = %u, icol = %d\n", stmt, icol);
+mylog("**** : fCType=%d rgb=%x valusMax=%d pcb=%x\n", fCType, rgbValue, cbValueMax, pcbValue);
if (!stmt)
{
* data type (most likely varchar).
*/
RETCODE SQL_API
-SQLDescribeParam(
+PGAPI_DescribeParam(
HSTMT hstmt,
UWORD ipar,
SWORD FAR *pfSqlType,
SWORD FAR *pfNullable)
{
StatementClass *stmt = (StatementClass *) hstmt;
- static char *func = "SQLDescribeParam";
+ static char *func = "PGAPI_DescribeParam";
mylog("%s: entering...\n", func);
if ((ipar < 1) || (ipar > stmt->parameters_allocated))
{
- stmt->errormsg = "Invalid parameter number for SQLDescribeParam.";
+ stmt->errormsg = "Invalid parameter number for PGAPI_DescribeParam.";
stmt->errornumber = STMT_BAD_PARAMETER_NUMBER_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
/* Sets multiple values (arrays) for the set of parameter markers. */
RETCODE SQL_API
-SQLParamOptions(
+PGAPI_ParamOptions(
HSTMT hstmt,
UDWORD crow,
UDWORD FAR *pirow)
{
- static char *func = "SQLParamOptions";
+ static char *func = "PGAPI_ParamOptions";
+ StatementClass *stmt = (StatementClass *) hstmt;
mylog("%s: entering...\n", func);
+ stmt->errornumber = CONN_UNSUPPORTED_OPTION;
+ stmt->errormsg = "Function not implemented";
SC_log_error(func, "Function not implemented", (StatementClass *) hstmt);
return SQL_ERROR;
}
* If the statement does not have parameters, it should just return 0.
*/
RETCODE SQL_API
-SQLNumParams(
+PGAPI_NumParams(
HSTMT hstmt,
SWORD FAR *pcpar)
{
StatementClass *stmt = (StatementClass *) hstmt;
char in_quote = FALSE;
unsigned int i;
- static char *func = "SQLNumParams";
+ static char *func = "PGAPI_NumParams";
mylog("%s: entering...\n", func);
if (!stmt->statement)
{
/* no statement has been allocated */
- stmt->errormsg = "SQLNumParams called with no statement ready.";
+ stmt->errormsg = "PGAPI_NumParams called with no statement ready.";
stmt->errornumber = STMT_SEQUENCE_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
#include "socket.h"
#include <stdlib.h>
#include <string.h>
+#include "pgapifunc.h"
ColumnInfoClass *
CI_Constructor()
#ifdef WIN32
#include <odbcinst.h>
#endif
+#include "pgapifunc.h"
#define STMT_INCREMENT 16 /* how many statement holders to allocate
* at a time */
RETCODE SQL_API
-SQLAllocConnect(
+PGAPI_AllocConnect(
HENV henv,
HDBC FAR *phdbc)
{
EnvironmentClass *env = (EnvironmentClass *) henv;
ConnectionClass *conn;
- static char *func = "SQLAllocConnect";
+ static char *func = "PGAPI_AllocConnect";
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLConnect(
+PGAPI_Connect(
HDBC hdbc,
UCHAR FAR *szDSN,
SWORD cbDSN,
{
ConnectionClass *conn = (ConnectionClass *) hdbc;
ConnInfo *ci;
- static char *func = "SQLConnect";
+ static char *func = "PGAPI_Connect";
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLBrowseConnect(
+PGAPI_BrowseConnect(
HDBC hdbc,
UCHAR FAR *szConnStrIn,
SWORD cbConnStrIn,
SWORD cbConnStrOutMax,
SWORD FAR *pcbConnStrOut)
{
- static char *func = "SQLBrowseConnect";
+ static char *func = "PGAPI_BrowseConnect";
mylog("%s: entering...\n", func);
/* Drop any hstmts open on hdbc and disconnect from database */
RETCODE SQL_API
-SQLDisconnect(
+PGAPI_Disconnect(
HDBC hdbc)
{
ConnectionClass *conn = (ConnectionClass *) hdbc;
- static char *func = "SQLDisconnect";
+ static char *func = "PGAPI_Disconnect";
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLFreeConnect(
+PGAPI_FreeConnect(
HDBC hdbc)
{
ConnectionClass *conn = (ConnectionClass *) hdbc;
- static char *func = "SQLFreeConnect";
+ static char *func = "PGAPI_FreeConnect";
mylog("%s: entering...\n", func);
mylog("**** in %s: hdbc=%u\n", func, hdbc);
rv->translation_handle = NULL;
rv->DataSourceToDriver = NULL;
rv->DriverToDataSource = NULL;
+ rv->driver_version = ODBCVER;
memset(rv->pg_version, 0, sizeof(rv->pg_version));
rv->pg_version_number = .0;
rv->pg_version_major = 0;
* has not transitioned to "connected" yet.
*/
- result = SQLAllocStmt(self, &hstmt);
+ result = PGAPI_AllocStmt(self, &hstmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
return FALSE;
stmt = (StatementClass *) hstmt;
stmt->internal = TRUE; /* ensure no BEGIN/COMMIT/ABORT stuff */
/* Set the Datestyle to the format the driver expects it to be in */
- result = SQLExecDirect(hstmt, "set DateStyle to 'ISO'", SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, "set DateStyle to 'ISO'", SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
status = FALSE;
/* Disable genetic optimizer based on global flag */
if (globals.disable_optimizer)
{
- result = SQLExecDirect(hstmt, "set geqo to 'OFF'", SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, "set geqo to 'OFF'", SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
status = FALSE;
/* KSQO */
if (globals.ksqo)
{
- result = SQLExecDirect(hstmt, "set ksqo to 'ON'", SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, "set ksqo to 'ON'", SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
status = FALSE;
ptr = strtok(cs, ";");
while (ptr)
{
- result = SQLExecDirect(hstmt, ptr, SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, ptr, SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
status = FALSE;
ptr = strtok(cs, ";");
while (ptr)
{
- result = SQLExecDirect(hstmt, ptr, SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, ptr, SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
status = FALSE;
}
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return status;
}
* This function must use the local odbc API functions since the odbc state
* has not transitioned to "connected" yet.
*/
- result = SQLAllocStmt(self, &hstmt);
+ result = PGAPI_AllocStmt(self, &hstmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
return;
stmt = (StatementClass *) hstmt;
- result = SQLExecDirect(hstmt, "select oid from pg_type where typname='" PG_TYPE_LO_NAME "'", SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, "select oid from pg_type where typname='" PG_TYPE_LO_NAME "'", SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
- result = SQLFetch(hstmt);
+ result = PGAPI_Fetch(hstmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
- result = SQLGetData(hstmt, 1, SQL_C_SLONG, &self->lobj_type, sizeof(self->lobj_type), NULL);
+ result = PGAPI_GetData(hstmt, 1, SQL_C_SLONG, &self->lobj_type, sizeof(self->lobj_type), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
mylog("Got the large object oid: %d\n", self->lobj_type);
qlog(" [ Large Object oid = %d ]\n", self->lobj_type);
- result = SQLFreeStmt(hstmt, SQL_DROP);
+ result = PGAPI_FreeStmt(hstmt, SQL_DROP);
}
* This function must use the local odbc API functions since the odbc state
* has not transitioned to "connected" yet.
*/
- result = SQLAllocStmt(self, &hstmt);
+ result = PGAPI_AllocStmt(self, &hstmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
return;
stmt = (StatementClass *) hstmt;
/* get the server's version if possible */
- result = SQLExecDirect(hstmt, "select version()", SQL_NTS);
+ result = PGAPI_ExecDirect(hstmt, "select version()", SQL_NTS);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
- result = SQLFetch(hstmt);
+ result = PGAPI_Fetch(hstmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
- result = SQLGetData(hstmt, 1, SQL_C_CHAR, self->pg_version, MAX_INFO_STRING, NULL);
+ result = PGAPI_GetData(hstmt, 1, SQL_C_CHAR, self->pg_version, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- SQLFreeStmt(hstmt, SQL_DROP);
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
return;
}
qlog(" [ PostgreSQL version string = '%s' ]\n", self->pg_version);
qlog(" [ PostgreSQL version number = '%1.1f' ]\n", self->pg_version_number);
- result = SQLFreeStmt(hstmt, SQL_DROP);
+ result = PGAPI_FreeStmt(hstmt, SQL_DROP);
}
HINSTANCE translation_handle;
DataSourceToDriverProc DataSourceToDriver;
DriverToDataSourceProc DriverToDataSource;
+ Int2 driver_version; /* prepared for ODBC3.0 */
char transact_status;/* Is a transaction is currently in
* progress */
char errormsg_created; /* has an informative error msg
#include "pgtypes.h"
#include "lobj.h"
#include "connection.h"
+#include "pgapifunc.h"
#ifndef WIN32
#ifndef HAVE_STRICMP
retval;
BOOL check_select_into = FALSE; /* select into check */
unsigned int declare_pos;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ BOOL ins_ctrl = FALSE;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
if (!old_statement)
check_select_into = TRUE;
declare_pos = npos;
}
-
param_number = -1;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (stmt->statement_type != STMT_TYPE_SELECT)
+ {
+ stmt->options.cursor_type = SQL_CURSOR_FORWARD_ONLY;
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ }
+ else if (stmt->options.cursor_type == SQL_CURSOR_FORWARD_ONLY)
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ else if (stmt->options.scroll_concurrency != SQL_CONCUR_READ_ONLY)
+ {
+ if (stmt->parse_status == STMT_PARSE_NONE)
+ parse_statement(stmt);
+ if (stmt->parse_status != STMT_PARSE_COMPLETE)
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ else if (!stmt->ti || stmt->ntab != 1)
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ else ins_ctrl = TRUE;
+ }
+#endif /* DRIVER_CURSOR_IMPLEMENT */
#ifdef MULTIBYTE
multibyte_init();
#endif
into_table_from(&old_statement[opos]))
{
stmt->statement_type = STMT_TYPE_CREATE;
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
memmove(new_statement, new_statement + declare_pos, npos - declare_pos);
npos -= declare_pos;
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ else if (ins_ctrl && /* select into check */
+ opos > 0 &&
+ isspace((unsigned char) old_statement[opos - 1]) &&
+ strnicmp(&old_statement[opos], "from", 4) == 0)
+ {
+ ins_ctrl = FALSE;
+ CVT_APPEND_STR(", CTID, OID ");
+ }
+#endif /* DRIVER_CURSOR_IMPLEMENT */
CVT_APPEND_CHAR(oldchar);
continue;
}
NULL, 0, NULL);
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (ins_ctrl)
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
return SQL_SUCCESS;
}
y = m = d = hh = mm = ss = 0;
+ /* escape sequence ? */
+ if (buf[0] == '{')
+ {
+ while (*(++buf) && *buf != '\'');
+ if (!(*buf))
+ return FALSE;
+ buf++;
+ }
if (buf[4] == '-') /* year first */
nf = sscanf(buf, "%4d-%2d-%2d %2d:%2d:%2d", &y, &m, &d, &hh, &mm, &ss);
else
for (i = 0; i < max; i++)
{
+#ifdef MULTIBYTE
+ if (multibyte_char_check(si[i]) != 0)
+ {
+ if (p)
+ p[out] = si[i];
+ out++;
+ continue;
+ }
+#endif
if (si[i] == '\r' && si[i + 1] == '\n')
continue;
-#ifdef MULTIBYTE
- else if (multibyte_char_check(si[i]) == 0 && (si[i] == '\'' || si[i] == '\\'))
-#else
else if (si[i] == '\'' || si[i] == '\\')
-#endif
{
if (p)
p[out++] = '\\';
#ifdef MULTIBYTE
#include "multibyte.h"
#endif
+#include "pgapifunc.h"
#ifndef BOOL
#define BOOL int
#include <odbcinst.h>
#include "resource.h"
#endif
+#include "pgapifunc.h"
#ifndef TRUE
#define TRUE (BOOL)1
RETCODE SQL_API
-SQLDriverConnect(
+PGAPI_DriverConnect(
HDBC hdbc,
HWND hwnd,
UCHAR FAR *szConnStrIn,
SWORD FAR *pcbConnStrOut,
UWORD fDriverCompletion)
{
- static char *func = "SQLDriverConnect";
+ static char *func = "PGAPI_DriverConnect";
ConnectionClass *conn = (ConnectionClass *) hdbc;
ConnInfo *ci;
make_string(szConnStrIn, cbConnStrIn, connStrIn);
- mylog("**** SQLDriverConnect: fDriverCompletion=%d, connStrIn='%s'\n", fDriverCompletion, connStrIn);
- qlog("conn=%u, SQLDriverConnect( in)='%s', fDriverCompletion=%d\n", conn, connStrIn, fDriverCompletion);
+ mylog("**** PGAPI_DriverConnect: fDriverCompletion=%d, connStrIn='%s'\n", fDriverCompletion, connStrIn);
+ qlog("conn=%u, PGAPI_DriverConnect( in)='%s', fDriverCompletion=%d\n", conn, connStrIn, fDriverCompletion);
ci = &(conn->connInfo);
*pcbConnStrOut = len;
mylog("szConnStrOut = '%s'\n", szConnStrOut);
- qlog("conn=%u, SQLDriverConnect(out)='%s'\n", conn, szConnStrOut);
+ qlog("conn=%u, PGAPI_DriverConnect(out)='%s'\n", conn, szConnStrOut);
- mylog("SQLDRiverConnect: returning %d\n", result);
+ mylog("PGAPI_DRiverConnect: returning %d\n", result);
return result;
}
#include "statement.h"
#include <stdlib.h>
#include <string.h>
+#include "pgapifunc.h"
extern GLOBAL_VALUES globals;
RETCODE SQL_API
-SQLAllocEnv(HENV FAR *phenv)
+PGAPI_AllocEnv(HENV FAR *phenv)
{
- static char *func = "SQLAllocEnv";
+ static char *func = "PGAPI_AllocEnv";
- mylog("**** in SQLAllocEnv ** \n");
+ mylog("**** in PGAPI_AllocEnv ** \n");
/*
* Hack for systems on which none of the constructor-making techniques
return SQL_ERROR;
}
- mylog("** exit SQLAllocEnv: phenv = %u **\n", *phenv);
+ mylog("** exit PGAPI_AllocEnv: phenv = %u **\n", *phenv);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLFreeEnv(HENV henv)
+PGAPI_FreeEnv(HENV henv)
{
- static char *func = "SQLFreeEnv";
+ static char *func = "PGAPI_FreeEnv";
EnvironmentClass *env = (EnvironmentClass *) henv;
- mylog("**** in SQLFreeEnv: env = %u ** \n", env);
+ mylog("**** in PGAPI_FreeEnv: env = %u ** \n", env);
if (env && EN_Destructor(env))
{
/* Returns the next SQL error information. */
RETCODE SQL_API
-SQLError(
+PGAPI_Error(
HENV henv,
HDBC hdbc,
HSTMT hstmt,
char *msg;
int status;
- mylog("**** SQLError: henv=%u, hdbc=%u, hstmt=%u <%d>\n", henv, hdbc, hstmt, cbErrorMsgMax);
+ mylog("**** PGAPI_Error: henv=%u, hdbc=%u, hstmt=%u <%d>\n", henv, hdbc, hstmt, cbErrorMsgMax);
if (cbErrorMsgMax < 0)
return SQL_ERROR;
switch (status)
{
/* now determine the SQLSTATE to be returned */
+ case STMT_ROW_VERSION_CHANGED:
+ strcpy(szSqlState, "01001");
+ /* data truncated */
+ break;
case STMT_TRUNCATED:
strcpy(szSqlState, "01004");
/* data truncated */
strcpy(szSqlState, "07006");
break;
case STMT_INVALID_CURSOR_STATE_ERROR:
- strcpy(szSqlState, "24000");
+ strcpy(szSqlState, "24000");
break;
case STMT_OPTION_VALUE_CHANGED:
strcpy(szSqlState, "01S02");
break;
+ case STMT_POS_BEFORE_RECORDSET:
+ strcpy(szSqlState, "01S06");
+ break;
case STMT_INVALID_CURSOR_NAME:
strcpy(szSqlState, "34000");
break;
case STMT_OPERATION_INVALID:
strcpy(szSqlState, "S1011");
break;
+ case STMT_INVALID_OPTION_IDENTIFIER:
+ strcpy(szSqlState, "HY092");
+ break;
case STMT_EXEC_ERROR:
default:
strcpy(szSqlState, "S1000");
#include "bind.h"
#include "pgtypes.h"
#include "lobj.h"
+#include "pgapifunc.h"
extern GLOBAL_VALUES globals;
/* Perform a Prepare on the SQL statement */
RETCODE SQL_API
-SQLPrepare(HSTMT hstmt,
+PGAPI_Prepare(HSTMT hstmt,
UCHAR FAR *szSqlStr,
SDWORD cbSqlStr)
{
- static char *func = "SQLPrepare";
+ static char *func = "PGAPI_Prepare";
StatementClass *self = (StatementClass *) hstmt;
mylog("%s: entering...\n", func);
switch (self->status)
{
case STMT_PREMATURE:
- mylog("**** SQLPrepare: STMT_PREMATURE, recycle\n");
+ mylog("**** PGAPI_Prepare: STMT_PREMATURE, recycle\n");
SC_recycle_statement(self); /* recycle the statement, but do
* not remove parameter bindings */
break;
case STMT_FINISHED:
- mylog("**** SQLPrepare: STMT_FINISHED, recycle\n");
+ mylog("**** PGAPI_Prepare: STMT_FINISHED, recycle\n");
SC_recycle_statement(self); /* recycle the statement, but do
* not remove parameter bindings */
break;
case STMT_ALLOCATED:
- mylog("**** SQLPrepare: STMT_ALLOCATED, copy\n");
+ mylog("**** PGAPI_Prepare: STMT_ALLOCATED, copy\n");
self->status = STMT_READY;
break;
case STMT_READY:
- mylog("**** SQLPrepare: STMT_READY, change SQL\n");
+ mylog("**** PGAPI_Prepare: STMT_READY, change SQL\n");
break;
case STMT_EXECUTING:
- mylog("**** SQLPrepare: STMT_EXECUTING, error!\n");
+ mylog("**** PGAPI_Prepare: STMT_EXECUTING, error!\n");
self->errornumber = STMT_SEQUENCE_ERROR;
- self->errormsg = "SQLPrepare(): The handle does not point to a statement that is ready to be executed";
+ self->errormsg = "PGAPI_Prepare(): The handle does not point to a statement that is ready to be executed";
SC_log_error(func, "", self);
return SQL_ERROR;
/* Performs the equivalent of SQLPrepare, followed by SQLExecute. */
RETCODE SQL_API
-SQLExecDirect(
+PGAPI_ExecDirect(
HSTMT hstmt,
UCHAR FAR *szSqlStr,
SDWORD cbSqlStr)
{
StatementClass *stmt = (StatementClass *) hstmt;
RETCODE result;
- static char *func = "SQLExecDirect";
+ static char *func = "PGAPI_ExecDirect";
mylog("%s: entering...\n", func);
return SQL_ERROR;
}
- mylog("%s: calling SQLExecute...\n", func);
+ mylog("%s: calling PGAPI_Execute...\n", func);
- result = SQLExecute(hstmt);
+ result = PGAPI_Execute(hstmt);
- mylog("%s: returned %hd from SQLExecute\n", func, result);
+ mylog("%s: returned %hd from PGAPI_Execute\n", func, result);
return result;
}
/* Execute a prepared SQL statement */
RETCODE SQL_API
-SQLExecute(
+PGAPI_Execute(
HSTMT hstmt)
{
- static char *func = "SQLExecute";
+ static char *func = "PGAPI_Execute";
StatementClass *stmt = (StatementClass *) hstmt;
ConnectionClass *conn;
int i,
RETCODE SQL_API
-SQLTransact(
+PGAPI_Transact(
HENV henv,
HDBC hdbc,
UWORD fType)
{
- static char *func = "SQLTransact";
+ static char *func = "PGAPI_Transact";
extern ConnectionClass *conns[];
ConnectionClass *conn;
QResultClass *res;
conn = conns[lf];
if (conn && conn->henv == henv)
- if (SQLTransact(henv, (HDBC) conn, fType) != SQL_SUCCESS)
+ if (PGAPI_Transact(henv, (HDBC) conn, fType) != SQL_SUCCESS)
return SQL_ERROR;
}
return SQL_SUCCESS;
else
{
conn->errornumber = CONN_INVALID_ARGUMENT_NO;
- conn->errormsg = "SQLTransact can only be called with SQL_COMMIT or SQL_ROLLBACK as parameter";
+ conn->errormsg = "PGAPI_Transact can only be called with SQL_COMMIT or SQL_ROLLBACK as parameter";
CC_log_error(func, "", conn);
return SQL_ERROR;
}
/* If manual commit and in transaction, then proceed. */
if (!CC_is_in_autocommit(conn) && CC_is_in_trans(conn))
{
- mylog("SQLTransact: sending on conn %d '%s'\n", conn, stmt_string);
+ mylog("PGAPI_Transact: sending on conn %d '%s'\n", conn, stmt_string);
res = CC_send_query(conn, stmt_string, NULL);
CC_set_no_trans(conn);
RETCODE SQL_API
-SQLCancel(
+PGAPI_Cancel(
HSTMT hstmt) /* Statement to cancel. */
{
- static char *func = "SQLCancel";
+ static char *func = "PGAPI_Cancel";
StatementClass *stmt = (StatementClass *) hstmt;
RETCODE result;
result = addr((char *) (stmt->phstmt) - 96, SQL_CLOSE);
}
else
- result = SQLFreeStmt(hstmt, SQL_CLOSE);
+ result = PGAPI_FreeStmt(hstmt, SQL_CLOSE);
#else
- result = SQLFreeStmt(hstmt, SQL_CLOSE);
+ result = PGAPI_FreeStmt(hstmt, SQL_CLOSE);
#endif
- mylog("SQLCancel: SQLFreeStmt returned %d\n", result);
+ mylog("PGAPI_Cancel: PGAPI_FreeStmt returned %d\n", result);
SC_clear_error(hstmt);
return SQL_SUCCESS;
* observing buffer limits and truncation.
*/
RETCODE SQL_API
-SQLNativeSql(
+PGAPI_NativeSql(
HDBC hdbc,
UCHAR FAR *szSqlStrIn,
SDWORD cbSqlStrIn,
SDWORD cbSqlStrMax,
SDWORD FAR *pcbSqlStr)
{
- static char *func = "SQLNativeSql";
+ static char *func = "PGAPI_NativeSql";
int len = 0;
char *ptr;
ConnectionClass *conn = (ConnectionClass *) hdbc;
if (pcbSqlStr)
*pcbSqlStr = len;
- free(ptr);
+ if (cbSqlStrIn)
+ free(ptr);
return result;
}
* Used in conjuction with SQLPutData.
*/
RETCODE SQL_API
-SQLParamData(
+PGAPI_ParamData(
HSTMT hstmt,
PTR FAR *prgbValue)
{
- static char *func = "SQLParamData";
+ static char *func = "PGAPI_ParamData";
StatementClass *stmt = (StatementClass *) hstmt;
int i,
retval;
* Used in conjunction with SQLParamData.
*/
RETCODE SQL_API
-SQLPutData(
+PGAPI_PutData(
HSTMT hstmt,
PTR rgbValue,
SDWORD cbValue)
{
- static char *func = "SQLPutData";
+ static char *func = "PGAPI_PutData";
StatementClass *stmt = (StatementClass *) hstmt;
int old_pos,
retval;
if (!stmt->put_data)
{ /* first call */
- mylog("SQLPutData: (1) cbValue = %d\n", cbValue);
+ mylog("PGAPI_PutData: (1) cbValue = %d\n", cbValue);
stmt->put_data = TRUE;
if (!current_param->EXEC_used)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (1)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (1)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
if (!current_param->EXEC_buffer)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (2)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (2)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
if (!current_param->EXEC_buffer)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (2)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (2)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
if (!current_param->EXEC_buffer)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (2)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (2)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
else
{
/* calling SQLPutData more than once */
- mylog("SQLPutData: (>1) cbValue = %d\n", cbValue);
+ mylog("PGAPI_PutData: (>1) cbValue = %d\n", cbValue);
if (current_param->SQLType == SQL_LONGVARBINARY)
{
if (!buffer)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (3)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (3)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
if (!buffer)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Out of memory in SQLPutData (3)";
+ stmt->errormsg = "Out of memory in PGAPI_PutData (3)";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
#include <windows.h>
#include <sql.h>
#include <sqlext.h>
+
+#include <odbcinst.h>
#endif
#include "tuple.h"
#include "bind.h"
#include "misc.h"
#include "pgtypes.h"
+#include "pgapifunc.h"
/* Trigger related stuff for SQLForeign Keys */
extern GLOBAL_VALUES globals;
+
RETCODE SQL_API
-SQLGetInfo(
+PGAPI_GetInfo(
HDBC hdbc,
UWORD fInfoType,
PTR rgbInfoValue,
SWORD cbInfoValueMax,
SWORD FAR *pcbInfoValue)
{
- static char *func = "SQLGetInfo";
+ static char *func = "PGAPI_GetInfo";
ConnectionClass *conn = (ConnectionClass *) hdbc;
ConnInfo *ci;
char *p = NULL,
case SQL_CURSOR_COMMIT_BEHAVIOR: /* ODBC 1.0 */
len = 2;
value = SQL_CB_CLOSE;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (!globals.use_declarefetch)
+ value = SQL_CB_PRESERVE;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
break;
case SQL_CURSOR_ROLLBACK_BEHAVIOR: /* ODBC 1.0 */
len = 2;
value = SQL_CB_CLOSE;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (!globals.use_declarefetch)
+ value = SQL_CB_PRESERVE;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
break;
case SQL_DATA_SOURCE_NAME: /* ODBC 1.0 */
case SQL_DRIVER_ODBC_VER:
p = DRIVER_ODBC_VER;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ {
+ static char dver[32];
+ SQLGetPrivateProfileString(DBMS_NAME,
+ "DriverODBCVer", "", dver, sizeof(dver), "odbcinst.ini");
+ if (dver[0])
+ {
+ int major, minor;
+ mylog("REIGISTRY_ODBC_VER = %s\n", dver)
+;
+ if (sscanf(dver, "%x.%x", &major, &minor) >= 2)
+ {
+ Int2 drv_ver = (major << 8) + minor;
+ if (drv_ver > ODBCVER)
+ {
+ conn->driver_version = drv_ver;
+ p = dver;
+ }
+ }
+ }
+ }
+#endif /* DRIVER_CURSOR_IMPLEMENT */
break;
case SQL_DRIVER_VER: /* ODBC 1.0 */
break;
default:
+return PGAPI_GetInfo30(hdbc, fInfoType, rgbInfoValue, cbInfoValueMax,pcbInfoValue);
/* unrecognized key */
- conn->errormsg = "Unrecognized key passed to SQLGetInfo.";
+ conn->errormsg = "Unrecognized key passed to PGAPI_GetInfo.";
conn->errornumber = CONN_NOT_IMPLEMENTED_ERROR;
CC_log_error(func, "", conn);
return SQL_ERROR;
result = SQL_SUCCESS;
- mylog("SQLGetInfo: p='%s', len=%d, value=%d, cbMax=%d\n", p ? p : "<NULL>", len, value, cbInfoValueMax);
+ mylog("%s: p='%s', len=%d, value=%d, cbMax=%d\n", func, p ? p : "<NULL>", len, value, cbInfoValueMax);
/*
* NOTE, that if rgbInfoValue is NULL, then no warnings or errors
RETCODE SQL_API
-SQLGetTypeInfo(
+PGAPI_GetTypeInfo(
HSTMT hstmt,
SWORD fSqlType)
{
- static char *func = "SQLGetTypeInfo";
+ static char *func = "PGAPI_GetTypeInfo";
StatementClass *stmt = (StatementClass *) hstmt;
TupleNode *row;
int i;
RETCODE SQL_API
-SQLGetFunctions(
+/*SQLGetFunctions(*/
+PGAPI_GetFunctions(
HDBC hdbc,
UWORD fFunction,
UWORD FAR *pfExists)
{
- static char *func = "SQLGetFunctions";
+ static char *func = "PGAPI_GetFunctions";
- mylog("%s: entering...%u\n", func);
+ mylog("%s: entering...%u\n", func, fFunction);
if (fFunction == SQL_API_ALL_FUNCTIONS)
{
RETCODE SQL_API
-SQLTables(
+PGAPI_Tables(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UCHAR FAR *szTableType,
SWORD cbTableType)
{
- static char *func = "SQLTables";
+ static char *func = "PGAPI_Tables";
StatementClass *stmt = (StatementClass *) hstmt;
StatementClass *tbl_stmt;
TupleNode *row;
conn = (ConnectionClass *) (stmt->hdbc);
ci = &stmt->hdbc->connInfo;
- result = SQLAllocStmt(stmt->hdbc, &htbl_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &htbl_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't allocate statement for SQLTables result.";
+ stmt->errormsg = "Couldn't allocate statement for PGAPI_Tables result.";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
strcat(tables_query, " and usesysid = relowner");
strcat(tables_query, " order by relname");
- result = SQLExecDirect(htbl_stmt, tables_query, strlen(tables_query));
+ result = PGAPI_ExecDirect(htbl_stmt, tables_query, strlen(tables_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 1, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 1, SQL_C_CHAR,
table_name, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 2, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 2, SQL_C_CHAR,
table_owner, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 3, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 3, SQL_C_CHAR,
relkind_or_hasrules, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
stmt->result = QR_Constructor();
if (!stmt->result)
{
- stmt->errormsg = "Couldn't allocate memory for SQLTables result.";
+ stmt->errormsg = "Couldn't allocate memory for PGAPI_Tables result.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
QR_set_field_info(stmt->result, 4, "REMARKS", PG_TYPE_TEXT, 254);
/* add the tuples */
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
while ((result == SQL_SUCCESS) || (result == SQL_SUCCESS_WITH_INFO))
{
* set_tuplefield_string(&row->tuple[1], table_owner);
*/
- mylog("SQLTables: table_name = '%s'\n", table_name);
+ mylog("%s: table_name = '%s'\n", func, table_name);
set_tuplefield_string(&row->tuple[1], "");
set_tuplefield_string(&row->tuple[2], table_name);
QR_add_tuple(stmt->result, row);
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
}
if (result != SQL_NO_DATA_FOUND)
{
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
stmt->rowset_start = -1;
stmt->current_col = -1;
- SQLFreeStmt(htbl_stmt, SQL_DROP);
- mylog("SQLTables(): EXIT, stmt=%u\n", stmt);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
+ mylog("%s: EXIT, stmt=%u\n", func, stmt);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLColumns(
+PGAPI_Columns(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UCHAR FAR *szColumnName,
SWORD cbColumnName)
{
- static char *func = "SQLColumns";
+ static char *func = "PGAPI_Columns";
StatementClass *stmt = (StatementClass *) hstmt;
TupleNode *row;
HSTMT hcol_stmt;
*/
strcat(columns_query, " order by attnum");
- result = SQLAllocStmt(stmt->hdbc, &hcol_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &hcol_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't allocate statement for SQLColumns result.";
+ stmt->errormsg = "Couldn't allocate statement for PGAPI_Columns result.";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
col_stmt = (StatementClass *) hcol_stmt;
- mylog("SQLColumns: hcol_stmt = %u, col_stmt = %u\n", hcol_stmt, col_stmt);
+ mylog("%s: hcol_stmt = %u, col_stmt = %u\n", func, hcol_stmt, col_stmt);
- result = SQLExecDirect(hcol_stmt, columns_query,
+ result = PGAPI_ExecDirect(hcol_stmt, columns_query,
strlen(columns_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(hcol_stmt);
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 1, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 1, SQL_C_CHAR,
table_owner, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 2, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 2, SQL_C_CHAR,
table_name, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 3, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 3, SQL_C_CHAR,
field_name, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 4, SQL_C_LONG,
+ result = PGAPI_BindCol(hcol_stmt, 4, SQL_C_LONG,
&field_type, 4, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 5, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 5, SQL_C_CHAR,
field_type_name, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 6, SQL_C_SHORT,
+ result = PGAPI_BindCol(hcol_stmt, 6, SQL_C_SHORT,
&field_number, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 7, SQL_C_LONG,
+ result = PGAPI_BindCol(hcol_stmt, 7, SQL_C_LONG,
&field_length, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 8, SQL_C_LONG,
+ result = PGAPI_BindCol(hcol_stmt, 8, SQL_C_LONG,
&mod_length, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 9, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 9, SQL_C_CHAR,
not_null, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 10, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 10, SQL_C_CHAR,
relhasrules, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
stmt->result = QR_Constructor();
if (!stmt->result)
{
- stmt->errormsg = "Couldn't allocate memory for SQLColumns result.";
+ stmt->errormsg = "Couldn't allocate memory for PGAPI_Columns result.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
QR_set_field_info(stmt->result, 12, "DISPLAY_SIZE", PG_TYPE_INT4, 4);
QR_set_field_info(stmt->result, 13, "FIELD_TYPE", PG_TYPE_INT4, 4);
- result = SQLFetch(hcol_stmt);
+ result = PGAPI_Fetch(hcol_stmt);
/*
* Only show oid if option AND there are other columns AND it's not
*
*----------
*/
- qlog("SQLColumns: table='%s',field_name='%s',type=%d,sqltype=%d,name='%s'\n",
+ qlog("PGAPI_Columns: table='%s',field_name='%s',type=%d,sqltype=%d,name='%s'\n",
table_name, field_name, field_type, pgtype_to_sqltype, field_type_name);
useStaticPrecision = TRUE;
precision = (mod_length >> 16) & 0xffff;
scale = mod_length & 0xffff;
- mylog("SQLColumns: field type is NUMERIC: field_type = %d, mod_length=%d, precision=%d, scale=%d\n", field_type, mod_length, precision, scale);
+ mylog("%s: field type is NUMERIC: field_type = %d, mod_length=%d, precision=%d, scale=%d\n", func, field_type, mod_length, precision, scale);
set_tuplefield_int4(&row->tuple[7], precision + 2); /* sign+dec.point */
set_tuplefield_int4(&row->tuple[6], precision);
if (mod_length > globals.max_varchar_size || mod_length <= 0)
mod_length = globals.max_varchar_size;
- mylog("SQLColumns: field type is VARCHAR,BPCHAR: field_type = %d, mod_length = %d\n", field_type, mod_length);
+ mylog("%s: field type is VARCHAR,BPCHAR: field_type = %d, mod_length = %d\n", func, field_type, mod_length);
set_tuplefield_int4(&row->tuple[7], mod_length);
set_tuplefield_int4(&row->tuple[6], mod_length);
if (useStaticPrecision)
{
- mylog("SQLColumns: field type is OTHER: field_type = %d, pgtype_length = %d\n", field_type, pgtype_length(stmt, field_type, PG_STATIC, PG_STATIC));
+ mylog("%s: field type is OTHER: field_type = %d, pgtype_length = %d\n", func, field_type, pgtype_length(stmt, field_type, PG_STATIC, PG_STATIC));
set_tuplefield_int4(&row->tuple[7], pgtype_length(stmt, field_type, PG_STATIC, PG_STATIC));
set_tuplefield_int4(&row->tuple[6], pgtype_precision(stmt, field_type, PG_STATIC, PG_STATIC));
QR_add_tuple(stmt->result, row);
- result = SQLFetch(hcol_stmt);
+ result = PGAPI_Fetch(hcol_stmt);
}
if (result != SQL_NO_DATA_FOUND)
stmt->errormsg = SC_create_errormsg(hcol_stmt);
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
stmt->rowset_start = -1;
stmt->current_col = -1;
- SQLFreeStmt(hcol_stmt, SQL_DROP);
- mylog("SQLColumns(): EXIT, stmt=%u\n", stmt);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
+ mylog("%s: EXIT, stmt=%u\n", func, stmt);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLSpecialColumns(
+PGAPI_SpecialColumns(
HSTMT hstmt,
UWORD fColType,
UCHAR FAR *szTableQualifier,
UWORD fScope,
UWORD fNullable)
{
- static char *func = "SQLSpecialColumns";
+ static char *func = "PGAPI_SpecialColumns";
TupleNode *row;
StatementClass *stmt = (StatementClass *) hstmt;
ConnInfo *ci;
my_strcat(columns_query, " and u.usename like '%.*s'", szTableOwner, cbTableOwner);
- result = SQLAllocStmt(stmt->hdbc, &hcol_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &hcol_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
}
col_stmt = (StatementClass *) hcol_stmt;
- mylog("SQLSpecialColumns: hcol_stmt = %u, col_stmt = %u\n", hcol_stmt, col_stmt);
+ mylog("%s: hcol_stmt = %u, col_stmt = %u\n", func, hcol_stmt, col_stmt);
- result = SQLExecDirect(hcol_stmt, columns_query,
+ result = PGAPI_ExecDirect(hcol_stmt, columns_query,
strlen(columns_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(hcol_stmt);
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(hcol_stmt, 1, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 1, SQL_C_CHAR,
relhasrules, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLFetch(hcol_stmt);
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ result = PGAPI_Fetch(hcol_stmt);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
stmt->result = QR_Constructor();
extend_bindings(stmt, 8);
stmt->rowset_start = -1;
stmt->current_col = -1;
- mylog("SQLSpecialColumns(): EXIT, stmt=%u\n", stmt);
+ mylog("%s: EXIT, stmt=%u\n", func, stmt);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLStatistics(
+PGAPI_Statistics(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UWORD fUnique,
UWORD fAccuracy)
{
- static char *func = "SQLStatistics";
+ static char *func = "PGAPI_Statistics";
StatementClass *stmt = (StatementClass *) hstmt;
char index_query[INFO_INQUIRY_LEN];
HSTMT hindx_stmt;
stmt->result = QR_Constructor();
if (!stmt->result)
{
- stmt->errormsg = "Couldn't allocate memory for SQLStatistics result.";
+ stmt->errormsg = "Couldn't allocate memory for PGAPI_Statistics result.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
table_name = make_string(szTableName, cbTableName, NULL);
if (!table_name)
{
- stmt->errormsg = "No table name passed to SQLStatistics.";
+ stmt->errormsg = "No table name passed to PGAPI_Statistics.";
stmt->errornumber = STMT_INTERNAL_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
* we need to get a list of the field names first, so we can return
* them later.
*/
- result = SQLAllocStmt(stmt->hdbc, &hcol_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &hcol_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- stmt->errormsg = "SQLAllocStmt failed in SQLStatistics for columns.";
+ stmt->errormsg = "PGAPI_AllocStmt failed in PGAPI_Statistics for columns.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
goto SEEYA;
}
* being shown. This would throw everything off.
*/
col_stmt->internal = TRUE;
- result = SQLColumns(hcol_stmt, "", 0, "", 0,
+ result = PGAPI_Columns(hcol_stmt, "", 0, "", 0,
table_name, (SWORD) strlen(table_name), "", 0);
col_stmt->internal = FALSE;
stmt->errormsg = col_stmt->errormsg; /* "SQLColumns failed in
* SQLStatistics."; */
stmt->errornumber = col_stmt->errornumber; /* STMT_EXEC_ERROR; */
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
goto SEEYA;
}
- result = SQLBindCol(hcol_stmt, 4, SQL_C_CHAR,
+ result = PGAPI_BindCol(hcol_stmt, 4, SQL_C_CHAR,
column_name, MAX_INFO_STRING, &column_name_len);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = col_stmt->errormsg;
stmt->errornumber = col_stmt->errornumber;
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
goto SEEYA;
}
- result = SQLFetch(hcol_stmt);
+ result = PGAPI_Fetch(hcol_stmt);
while ((result == SQL_SUCCESS) || (result == SQL_SUCCESS_WITH_INFO))
{
total_columns++;
(char *) malloc(strlen(column_name) + 1);
strcpy(column_names[total_columns - 1], column_name);
- mylog("SQLStatistics: column_name = '%s'\n", column_name);
+ mylog("%s: column_name = '%s'\n", func, column_name);
- result = SQLFetch(hcol_stmt);
+ result = PGAPI_Fetch(hcol_stmt);
}
if (result != SQL_NO_DATA_FOUND || total_columns == 0)
* names in
* SQLStatistics."; */
stmt->errornumber = col_stmt->errornumber;
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
goto SEEYA;
}
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
/* get a list of indexes on this table */
- result = SQLAllocStmt(stmt->hdbc, &hindx_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &hindx_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- stmt->errormsg = "SQLAllocStmt failed in SQLStatistics for indices.";
+ stmt->errormsg = "PGAPI_AllocStmt failed in SQLStatistics for indices.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
goto SEEYA;
" and c.relam = a.oid"
, table_name);
- result = SQLExecDirect(hindx_stmt, index_query, strlen(index_query));
+ result = PGAPI_ExecDirect(hindx_stmt, index_query, strlen(index_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
/*
stmt->errormsg = SC_create_errormsg(hindx_stmt);
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
/* bind the index name column */
- result = SQLBindCol(hindx_stmt, 1, SQL_C_CHAR,
+ result = PGAPI_BindCol(hindx_stmt, 1, SQL_C_CHAR,
index_name, MAX_INFO_STRING, &index_name_len);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg; /* "Couldn't bind column
* in SQLStatistics."; */
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
/* bind the vector column */
- result = SQLBindCol(hindx_stmt, 2, SQL_C_DEFAULT,
+ result = PGAPI_BindCol(hindx_stmt, 2, SQL_C_DEFAULT,
fields_vector, 32, &fields_vector_len);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg; /* "Couldn't bind column
* in SQLStatistics."; */
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
/* bind the "is unique" column */
- result = SQLBindCol(hindx_stmt, 3, SQL_C_CHAR,
+ result = PGAPI_BindCol(hindx_stmt, 3, SQL_C_CHAR,
isunique, sizeof(isunique), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg; /* "Couldn't bind column
* in SQLStatistics."; */
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
/* bind the "is clustered" column */
- result = SQLBindCol(hindx_stmt, 4, SQL_C_CHAR,
+ result = PGAPI_BindCol(hindx_stmt, 4, SQL_C_CHAR,
isclustered, sizeof(isclustered), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg; /* "Couldn't bind column
* in SQLStatistics."; */
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
/* bind the "is hash" column */
- result = SQLBindCol(hindx_stmt, 5, SQL_C_CHAR,
+ result = PGAPI_BindCol(hindx_stmt, 5, SQL_C_CHAR,
ishash, sizeof(ishash), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg; /* "Couldn't bind column
* in SQLStatistics."; */
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
- result = SQLBindCol(hindx_stmt, 6, SQL_C_CHAR,
+ result = PGAPI_BindCol(hindx_stmt, 6, SQL_C_CHAR,
relhasrules, MAX_INFO_STRING, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = indx_stmt->errormsg;
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
QR_add_tuple(stmt->result, row);
}
- result = SQLFetch(hindx_stmt);
+ result = PGAPI_Fetch(hindx_stmt);
while ((result == SQL_SUCCESS) || (result == SQL_SUCCESS_WITH_INFO))
{
/* If only requesting unique indexs, then just return those. */
if (fields_vector[i] == OID_ATTNUM)
{
set_tuplefield_string(&row->tuple[8], "oid");
- mylog("SQLStatistics: column name = oid\n");
+ mylog("%s: column name = oid\n", func);
}
else if (fields_vector[i] < 0 || fields_vector[i] > total_columns)
{
set_tuplefield_string(&row->tuple[8], "UNKNOWN");
- mylog("SQLStatistics: column name = UNKNOWN\n");
+ mylog("%s: column name = UNKNOWN\n", func);
}
else
{
set_tuplefield_string(&row->tuple[8], column_names[fields_vector[i] - 1]);
- mylog("SQLStatistics: column name = '%s'\n", column_names[fields_vector[i] - 1]);
+ mylog("%s: column name = '%s'\n", func, column_names[fields_vector[i] - 1]);
}
set_tuplefield_string(&row->tuple[9], "A");
}
}
- result = SQLFetch(hindx_stmt);
+ result = PGAPI_Fetch(hindx_stmt);
}
if (result != SQL_NO_DATA_FOUND)
{
/* "SQLFetch failed in SQLStatistics."; */
stmt->errormsg = SC_create_errormsg(hindx_stmt);
stmt->errornumber = indx_stmt->errornumber;
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
goto SEEYA;
}
- SQLFreeStmt(hindx_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hindx_stmt, SQL_DROP);
/*
* also, things need to think that this statement is finished so the
free(column_names[i]);
free(column_names);
- mylog("SQLStatistics(): EXIT, %s, stmt=%u\n", error ? "error" : "success", stmt);
+ mylog("%s: EXIT, %s, stmt=%u\n", func, error ? "error" : "success", stmt);
if (error)
{
RETCODE SQL_API
-SQLColumnPrivileges(
+PGAPI_ColumnPrivileges(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UCHAR FAR *szColumnName,
SWORD cbColumnName)
{
- static char *func = "SQLColumnPrivileges";
+ static char *func = "PGAPI_ColumnPrivileges";
mylog("%s: entering...\n", func);
* Retrieve the primary key columns for the specified table.
*/
RETCODE SQL_API
-SQLPrimaryKeys(
+PGAPI_PrimaryKeys(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UCHAR FAR *szTableName,
SWORD cbTableName)
{
- static char *func = "SQLPrimaryKeys";
+ static char *func = "PGAPI_PrimaryKeys";
StatementClass *stmt = (StatementClass *) hstmt;
ConnectionClass *conn;
TupleNode *row;
stmt->result = QR_Constructor();
if (!stmt->result)
{
- stmt->errormsg = "Couldn't allocate memory for SQLPrimaryKeys result.";
+ stmt->errormsg = "Couldn't allocate memory for PGAPI_PrimaryKeys result.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
QR_set_field_info(stmt->result, 5, "PK_NAME", PG_TYPE_TEXT, MAX_INFO_STRING);
- result = SQLAllocStmt(stmt->hdbc, &htbl_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &htbl_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
make_string(szTableName, cbTableName, pktab);
if (pktab[0] == '\0')
{
- stmt->errormsg = "No Table specified to SQLPrimaryKeys.";
+ stmt->errormsg = "No Table specified to PGAPI_PrimaryKeys.";
stmt->errornumber = STMT_INTERNAL_ERROR;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 1, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 1, SQL_C_CHAR,
attname, MAX_INFO_STRING, &attname_len);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
" order by ia.attnum", pktab);
break;
}
- mylog("SQLPrimaryKeys: tables_query='%s'\n", tables_query);
+ mylog("%s: tables_query='%s'\n", func, tables_query);
- result = SQLExecDirect(htbl_stmt, tables_query, strlen(tables_query));
+ result = PGAPI_ExecDirect(htbl_stmt, tables_query, strlen(tables_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
if (result != SQL_NO_DATA_FOUND)
break;
}
mylog(">> primaryKeys: pktab = '%s', attname = '%s', seq = %d\n", pktab, attname, seq);
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
}
if (result != SQL_NO_DATA_FOUND)
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
/*
stmt->rowset_start = -1;
stmt->current_col = -1;
- mylog("SQLPrimaryKeys(): EXIT, stmt=%u\n", stmt);
+ mylog("%s: EXIT, stmt=%u\n", func, stmt);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLForeignKeys(
+PGAPI_ForeignKeys(
HSTMT hstmt,
UCHAR FAR *szPkTableQualifier,
SWORD cbPkTableQualifier,
UCHAR FAR *szFkTableName,
SWORD cbFkTableName)
{
- static char *func = "SQLForeignKeys";
+ static char *func = "PGAPI_ForeignKeys";
StatementClass *stmt = (StatementClass *) hstmt;
TupleNode *row;
HSTMT htbl_stmt,
stmt->result = QR_Constructor();
if (!stmt->result)
{
- stmt->errormsg = "Couldn't allocate memory for SQLForeignKeys result.";
+ stmt->errormsg = "Couldn't allocate memory for PGAPI_ForeignKeys result.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
stmt->current_col = -1;
- result = SQLAllocStmt(stmt->hdbc, &htbl_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &htbl_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't allocate statement for SQLForeignKeys result.";
+ stmt->errormsg = "Couldn't allocate statement for PGAPI_ForeignKeys result.";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
"AND (pg_trigger_1.tgconstrname=pt.tgconstrname))",
fk_table_needed);
- result = SQLExecDirect(htbl_stmt, tables_query, strlen(tables_query));
+ result = PGAPI_ExecDirect(htbl_stmt, tables_query, strlen(tables_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 1, SQL_C_BINARY,
+ result = PGAPI_BindCol(htbl_stmt, 1, SQL_C_BINARY,
trig_args, sizeof(trig_args), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 2, SQL_C_SHORT,
+ result = PGAPI_BindCol(htbl_stmt, 2, SQL_C_SHORT,
&trig_nargs, 0, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 3, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 3, SQL_C_CHAR,
trig_deferrable, sizeof(trig_deferrable), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 4, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 4, SQL_C_CHAR,
trig_initdeferred, sizeof(trig_initdeferred), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 5, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 5, SQL_C_CHAR,
upd_rule, sizeof(upd_rule), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 6, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 6, SQL_C_CHAR,
del_rule, sizeof(del_rule), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
if (result == SQL_NO_DATA_FOUND)
return SQL_SUCCESS;
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- keyresult = SQLAllocStmt(stmt->hdbc, &hpkey_stmt);
+ keyresult = PGAPI_AllocStmt(stmt->hdbc, &hpkey_stmt);
if ((keyresult != SQL_SUCCESS) && (keyresult != SQL_SUCCESS_WITH_INFO))
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't allocate statement for SQLForeignKeys (pkeys) result.";
+ stmt->errormsg = "Couldn't allocate statement for PGAPI_ForeignKeys (pkeys) result.";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
- keyresult = SQLBindCol(hpkey_stmt, 4, SQL_C_CHAR,
+ keyresult = PGAPI_BindCol(hpkey_stmt, 4, SQL_C_CHAR,
pkey, sizeof(pkey), NULL);
if (keyresult != SQL_SUCCESS)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't bindcol for primary keys for SQLForeignKeys result.";
+ stmt->errormsg = "Couldn't bindcol for primary keys for PGAPI_ForeignKeys result.";
SC_log_error(func, "", stmt);
- SQLFreeStmt(hpkey_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hpkey_stmt, SQL_DROP);
return SQL_ERROR;
}
/* If it doesn't match, then continue */
if (strcmp(pk_table, pk_table_needed))
{
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
continue;
}
}
- keyresult = SQLPrimaryKeys(hpkey_stmt, NULL, 0, NULL, 0, pk_table, SQL_NTS);
+ keyresult = PGAPI_PrimaryKeys(hpkey_stmt, NULL, 0, NULL, 0, pk_table, SQL_NTS);
if (keyresult != SQL_SUCCESS)
{
stmt->errornumber = STMT_NO_MEMORY_ERROR;
- stmt->errormsg = "Couldn't get primary keys for SQLForeignKeys result.";
+ stmt->errormsg = "Couldn't get primary keys for PGAPI_ForeignKeys result.";
SC_log_error(func, "", stmt);
- SQLFreeStmt(hpkey_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hpkey_stmt, SQL_DROP);
return SQL_ERROR;
}
/* Check that the key listed is the primary key */
- keyresult = SQLFetch(hpkey_stmt);
+ keyresult = PGAPI_Fetch(hpkey_stmt);
/* Get to first primary key */
pkey_ptr = trig_args;
for (k = 0; k < 2; k++)
pkey_ptr += strlen(pkey_ptr) + 1;
- keyresult = SQLFetch(hpkey_stmt);
+ keyresult = PGAPI_Fetch(hpkey_stmt);
}
/* Set to first fk column */
}
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
}
- SQLFreeStmt(hpkey_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hpkey_stmt, SQL_DROP);
}
/*
" )",
pk_table_needed);
- result = SQLExecDirect(htbl_stmt, tables_query, strlen(tables_query));
+ result = PGAPI_ExecDirect(htbl_stmt, tables_query, strlen(tables_query));
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 1, SQL_C_BINARY,
+ result = PGAPI_BindCol(htbl_stmt, 1, SQL_C_BINARY,
trig_args, sizeof(trig_args), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 2, SQL_C_SHORT,
+ result = PGAPI_BindCol(htbl_stmt, 2, SQL_C_SHORT,
&trig_nargs, 0, NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 3, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 3, SQL_C_CHAR,
trig_deferrable, sizeof(trig_deferrable), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 4, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 4, SQL_C_CHAR,
trig_initdeferred, sizeof(trig_initdeferred), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 5, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 5, SQL_C_CHAR,
upd_rule, sizeof(upd_rule), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLBindCol(htbl_stmt, 6, SQL_C_CHAR,
+ result = PGAPI_BindCol(htbl_stmt, 6, SQL_C_CHAR,
del_rule, sizeof(del_rule), NULL);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
stmt->errormsg = tbl_stmt->errormsg;
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
if (result == SQL_NO_DATA_FOUND)
return SQL_SUCCESS;
stmt->errormsg = SC_create_errormsg(htbl_stmt);
stmt->errornumber = tbl_stmt->errornumber;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
fkey_ptr += strlen(fkey_ptr) + 1;
}
}
- result = SQLFetch(htbl_stmt);
+ result = PGAPI_Fetch(htbl_stmt);
}
}
else
{
- stmt->errormsg = "No tables specified to SQLForeignKeys.";
+ stmt->errormsg = "No tables specified to PGAPI_ForeignKeys.";
stmt->errornumber = STMT_INTERNAL_ERROR;
SC_log_error(func, "", stmt);
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
return SQL_ERROR;
}
- SQLFreeStmt(htbl_stmt, SQL_DROP);
+ PGAPI_FreeStmt(htbl_stmt, SQL_DROP);
- mylog("SQLForeignKeys(): EXIT, stmt=%u\n", stmt);
+ mylog("PGAPI_ForeignKeys(): EXIT, stmt=%u\n", stmt);
return SQL_SUCCESS;
}
RETCODE SQL_API
-SQLProcedureColumns(
+PGAPI_ProcedureColumns(
HSTMT hstmt,
UCHAR FAR *szProcQualifier,
SWORD cbProcQualifier,
UCHAR FAR *szColumnName,
SWORD cbColumnName)
{
- static char *func = "SQLProcedureColumns";
+ static char *func = "PGAPI_ProcedureColumns";
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLProcedures(
+PGAPI_Procedures(
HSTMT hstmt,
UCHAR FAR *szProcQualifier,
SWORD cbProcQualifier,
UCHAR FAR *szProcName,
SWORD cbProcName)
{
- static char *func = "SQLProcedures";
+ static char *func = "PGAPI_Procedures";
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLTablePrivileges(
+PGAPI_TablePrivileges(
HSTMT hstmt,
UCHAR FAR *szTableQualifier,
SWORD cbTableQualifier,
UCHAR FAR *szTableName,
SWORD cbTableName)
{
- static char *func = "SQLTablePrivileges";
+ StatementClass *stmt = (StatementClass *) hstmt;
+ static char *func = "PGAPI_TablePrivileges";
+ Int2 result_cols;
mylog("%s: entering...\n", func);
+ /*
+ * a statement is actually executed, so we'll have to do this
+ * ourselves.
+ */
+ result_cols = 7;
+ extend_bindings(stmt, result_cols);
+
+ /* set the field names */
+ QR_set_num_fields(stmt->result, result_cols);
+ QR_set_field_info(stmt->result, 0, "TABLE_CAT", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 1, "TABLE_SCHEM", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 2, "TABLE_NAME", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 3, "GRANTOR", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 4, "GRANTEE", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 5, "PRIVILEGE", PG_TYPE_TEXT, MAX_INFO_STRING);
+ QR_set_field_info(stmt->result, 6, "IS_GRANTABLE", PG_TYPE_TEXT, MAX_INFO_STRING);
+
SC_log_error(func, "Function not implemented", (StatementClass *) hstmt);
return SQL_ERROR;
}
#include "connection.h"
#include "statement.h"
#include "qresult.h"
+#include "pgapifunc.h"
extern GLOBAL_VALUES globals;
* positioned update isn't supported so cursor concurrency is
* read-only
*/
- if (conn)
- conn->stmtOptions.scroll_concurrency = vParam;
- if (stmt)
- stmt->options.scroll_concurrency = vParam;
- break;
-
- /*----------
- * if (globals.lie)
- * {
- * if (conn)
- * conn->stmtOptions.scroll_concurrency = vParam;
- * if (stmt)
- * stmt->options.scroll_concurrency = vParam;
- * } else {
- * if (conn)
- * conn->stmtOptions.scroll_concurrency =
- * SQL_CONCUR_READ_ONLY;
- * if (stmt)
- * stmt->options.scroll_concurrency =
- * SQL_CONCUR_READ_ONLY;
- *
- * if (vParam != SQL_CONCUR_READ_ONLY)
- * changed = TRUE;
- * }
- * break;
- * }
- *----------
- */
+ mylog("SetStmtOption(): SQL_CONCURRENCY = %d\n", vParam);
+ if (globals.lie || vParam == SQL_CONCUR_READ_ONLY || vParam == SQL_CONCUR_ROWVER)
+ {
+ if (conn)
+ conn->stmtOptions.scroll_concurrency = vParam;
+ if (stmt)
+ stmt->options.scroll_concurrency = vParam;
+ }
+ else
+ {
+ if (conn)
+ conn->stmtOptions.scroll_concurrency = SQL_CONCUR_ROWVER;
+ if (stmt)
+ stmt->options.scroll_concurrency = SQL_CONCUR_ROWVER;
+ changed = TRUE;
+ }
+ break;
case SQL_CURSOR_TYPE:
/* Implements only SQL_AUTOCOMMIT */
RETCODE SQL_API
-SQLSetConnectOption(
+PGAPI_SetConnectOption(
HDBC hdbc,
UWORD fOption,
UDWORD vParam)
{
- static char *func = "SQLSetConnectOption";
+ static char *func = "PGAPI_SetConnectOption";
ConnectionClass *conn = (ConnectionClass *) hdbc;
char changed = FALSE;
RETCODE retval;
int i;
- mylog("%s: entering...\n", func);
-
+ mylog("%s: entering fOption = %d vParam = %d\n", func, fOption, vParam);
if (!conn)
{
CC_log_error(func, "", NULL);
return SQL_ERROR;
}
- mylog("SQLSetConnectOption: AUTOCOMMIT: transact_status=%d, vparam=%d\n", conn->transact_status, vParam);
+ mylog("PGAPI_SetConnectOption: AUTOCOMMIT: transact_status=%d, vparam=%d\n", conn->transact_status, vParam);
switch (vParam)
{
/* This function just can tell you whether you are in Autcommit mode or not */
RETCODE SQL_API
-SQLGetConnectOption(
+PGAPI_GetConnectOption(
HDBC hdbc,
UWORD fOption,
PTR pvParam)
{
- static char *func = "SQLGetConnectOption";
+ static char *func = "PGAPI_GetConnectOption";
ConnectionClass *conn = (ConnectionClass *) hdbc;
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLSetStmtOption(
+PGAPI_SetStmtOption(
HSTMT hstmt,
UWORD fOption,
UDWORD vParam)
{
- static char *func = "SQLSetStmtOption";
+ static char *func = "PGAPI_SetStmtOption";
StatementClass *stmt = (StatementClass *) hstmt;
mylog("%s: entering...\n", func);
RETCODE SQL_API
-SQLGetStmtOption(
+PGAPI_GetStmtOption(
HSTMT hstmt,
UWORD fOption,
PTR pvParam)
{
- static char *func = "SQLGetStmtOption";
+ static char *func = "PGAPI_GetStmtOption";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *res;
#include "connection.h"
#include "qresult.h"
#include "pgtypes.h"
+#include "pgapifunc.h"
#ifdef MULTIBYTE
#include "multibyte.h"
i++;
}
- if (s[0] == '\0')
+ if (s[i] == '\0')
{
token[0] = '\0';
return NULL;
while (!isspace((unsigned char) s[i]) && s[i] != ',' &&
s[i] != '\0' && out != smax)
{
+#ifdef MULTIBYTE
+ if (multibyte_char_check(s[i]) != 0)
+ {
+ token[out++] = s[i++];
+ continue;
+ }
+#endif
/* Handle quoted stuff */
if (out == 0 && (s[i] == '\"' || s[i] == '\''))
{
i++; /* dont return the quote */
while (s[i] != '\0' && out != smax)
{
- if (s[i] == qc && !in_escape)
- break;
#ifdef MULTIBYTE
- if (multibyte_char_check(s[i]) == 0 && s[i] == '\\' && !in_escape)
+ if (multibyte_char_check(s[i]) != 0)
{
-#else
+ token[out++] = s[i++];
+ continue;
+ }
+#endif
+ if (s[i] == qc && !in_escape)
+ break;
if (s[i] == '\\' && !in_escape)
{
-#endif
in_escape = TRUE;
}
else
dquote,
numeric,
unquoted;
- char *ptr;
+ char *ptr, *pptr = NULL;
char in_select = FALSE,
in_distinct = FALSE,
in_on = FALSE,
in_from = FALSE,
+ from_found = FALSE,
in_where = FALSE,
in_table = FALSE;
char in_field = FALSE,
i,
k = 0,
n,
+ first_where = 0,
blevel = 0;
FIELD_INFO **fi;
TABLE_INFO **ti;
stmt->nfld = 0;
stmt->ntab = 0;
- while ((ptr = getNextToken(ptr, token, sizeof(token), &delim, "e, &dquote, &numeric)) != NULL)
+#ifdef MULTIBYTE
+ multibyte_init();
+#endif
+ while (pptr = ptr, (ptr = getNextToken(pptr, token, sizeof(token), &delim, "e, &dquote, &numeric)) != NULL)
{
unquoted = !(quote || dquote);
mylog("unquoted=%d, quote=%d, dquote=%d, numeric=%d, delim='%c', token='%s', ptr='%s'\n", unquoted, quote, dquote, numeric, delim, token, ptr);
- if (unquoted && !stricmp(token, "select"))
+ if (in_select && unquoted && blevel == 0)
{
- in_select = TRUE;
-
- mylog("SELECT\n");
- continue;
- }
+ if (!stricmp(token, "distinct"))
+ {
+ in_distinct = TRUE;
- if (unquoted && in_select && !stricmp(token, "distinct"))
- {
- in_distinct = TRUE;
+ mylog("DISTINCT\n");
+ continue;
+ }
+ if (!stricmp(token, "into"))
+ {
+ in_select = FALSE;
+ mylog("INTO\n");
+ stmt->statement_type = STMT_TYPE_CREATE;
+ stmt->parse_status = STMT_PARSE_FATAL;
+ return FALSE;
+ }
+ if (!stricmp(token, "from"))
+ {
+ in_select = FALSE;
+ in_from = TRUE;
+ if (!from_found &&
+ (!strnicmp(pptr, "from", 4)))
+ {
+ mylog("First ");
+ from_found = TRUE;
+ }
- mylog("DISTINCT\n");
- continue;
+ mylog("FROM\n");
+ continue;
+ }
}
-
- if (unquoted && !stricmp(token, "into"))
+ if (unquoted && blevel == 0)
{
- in_select = FALSE;
-
- mylog("INTO\n");
- continue;
+ if ((!stricmp(token, "where") ||
+ !stricmp(token, "union") ||
+ !stricmp(token, "intersect") ||
+ !stricmp(token, "except") ||
+ !stricmp(token, "order") ||
+ !stricmp(token, "group") ||
+ !stricmp(token, "having")))
+ {
+ in_select = FALSE;
+ in_from = FALSE;
+ in_where = TRUE;
+
+ if (!first_where &&
+ (!stricmp(token, "where")))
+ first_where = ptr - stmt->statement;
+
+ mylog("WHERE...\n");
+ break;
+ }
}
-
- if (unquoted && !stricmp(token, "from"))
+ if (in_select && (in_expr || in_func))
{
- in_select = FALSE;
- in_from = TRUE;
+ /* just eat the expression */
+ mylog("in_expr=%d or func=%d\n", in_expr, in_func);
+ if (!unquoted)
+ continue;
- mylog("FROM\n");
+ if (token[0] == '(')
+ {
+ blevel++;
+ mylog("blevel++ = %d\n", blevel);
+ }
+ else if (token[0] == ')')
+ {
+ blevel--;
+ mylog("blevel-- = %d\n", blevel);
+ }
+ if (blevel == 0)
+ {
+ if (delim == ',')
+ {
+ mylog("**** Got comma in_expr/func\n");
+ in_func = FALSE;
+ in_expr = FALSE;
+ in_field = FALSE;
+ }
+ else if (!stricmp(token, "as"))
+ {
+ mylog("got AS in_expr\n");
+ in_func = FALSE;
+ in_expr = FALSE;
+ in_as = TRUE;
+ in_field = TRUE;
+ }
+ }
continue;
}
- if (unquoted && (!stricmp(token, "where") ||
- !stricmp(token, "union") ||
- !stricmp(token, "order") ||
- !stricmp(token, "group") ||
- !stricmp(token, "having")))
+ if (unquoted && !stricmp(token, "select"))
{
- in_select = FALSE;
- in_from = FALSE;
- in_where = TRUE;
+ in_select = TRUE;
- mylog("WHERE...\n");
- break;
+ mylog("SELECT\n");
+ continue;
}
-
if (in_select)
{
if (in_distinct)
in_distinct = FALSE;
}
- if (in_expr || in_func)
- {
- /* just eat the expression */
- mylog("in_expr=%d or func=%d\n", in_expr, in_func);
- if (quote || dquote)
- continue;
-
- if (in_expr && blevel == 0 && delim == ',')
- {
- mylog("**** in_expr and Got comma\n");
- in_expr = FALSE;
- in_field = FALSE;
- }
- else if (token[0] == '(')
- {
- blevel++;
- mylog("blevel++ = %d\n", blevel);
- }
- else if (token[0] == ')')
- {
- blevel--;
- mylog("blevel-- = %d\n", blevel);
- }
- if (blevel == 0)
- {
- if (delim == ',')
- {
- in_func = FALSE;
- in_expr = FALSE;
- in_field = FALSE;
- }
- }
- continue;
- }
-
if (!in_field)
{
if (!token[0])
if (quote)
{
fi[stmt->nfld++]->quote = TRUE;
+in_expr = TRUE;
continue;
}
else if (numeric)
else if (fi[i]->quote)
{ /* handle as text */
fi[i]->ti = NULL;
+ /*
fi[i]->type = PG_TYPE_TEXT;
fi[i]->precision = 0;
+ the following may be better */
+ fi[i]->type = PG_TYPE_UNKNOWN;
+ fi[i]->precision = 254;
continue;
}
/* it's a dot, resolve to table or alias */
if (!found)
{
- mylog("PARSE: Getting SQLColumns for table[%d]='%s'\n", i, ti[i]->name);
+ mylog("PARSE: Getting PG_Columns for table[%d]='%s'\n", i, ti[i]->name);
- result = SQLAllocStmt(stmt->hdbc, &hcol_stmt);
+ result = PGAPI_AllocStmt(stmt->hdbc, &hcol_stmt);
if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
{
- stmt->errormsg = "SQLAllocStmt failed in parse_statement for columns.";
+ stmt->errormsg = "PGAPI_AllocStmt failed in parse_statement for columns.";
stmt->errornumber = STMT_NO_MEMORY_ERROR;
stmt->parse_status = STMT_PARSE_FATAL;
return FALSE;
col_stmt = (StatementClass *) hcol_stmt;
col_stmt->internal = TRUE;
- result = SQLColumns(hcol_stmt, "", 0, "", 0,
+ result = PGAPI_Columns(hcol_stmt, "", 0, "", 0,
ti[i]->name, (SWORD) strlen(ti[i]->name), "", 0);
- mylog(" Past SQLColumns\n");
+ mylog(" Past PG_Columns\n");
if (result == SQL_SUCCESS)
{
mylog(" Success\n");
conn->ntables++;
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
mylog("Created col_info table='%s', ntables=%d\n", ti[i]->name, conn->ntables);
}
else
{
- SQLFreeStmt(hcol_stmt, SQL_DROP);
+ PGAPI_FreeStmt(hcol_stmt, SQL_DROP);
break;
}
}
mylog("associate col_info: i=%d, k=%d\n", i, k);
}
- mylog("Done SQLColumns\n");
+ mylog("Done PG_Columns\n");
/*
* Now resolve the fields to point to column info
{
switch (type)
{
- case PG_TYPE_CHAR:return "char";
+ case PG_TYPE_CHAR:
+ return "char";
case PG_TYPE_CHAR2:
return "char2";
case PG_TYPE_CHAR4:
QResultClass *result;
ColumnInfoClass *flds;
- mylog("getNumericScale: type=%d, col=%d, unknown = %d\n", type, col);
+ mylog("getNumericScale: type=%d, col=%d\n", type, col);
if (col < 0)
return PG_NUMERIC_MAX_SCALE;
QResultClass *result;
ColumnInfoClass *flds;
- mylog("getNumericPrecision: type=%d, col=%d, unknown = %d\n", type, col);
+ mylog("getNumericPrecision: type=%d, col=%d\n", type, col);
if (col < 0)
return PG_NUMERIC_MAX_PRECISION;
case PG_TYPE_ABSTIME:
case PG_TYPE_DATETIME:
case PG_TYPE_TIMESTAMP:
- return 19;
+ /*return 19;*/
+return 21;
case PG_TYPE_BOOL:
return 1;
SQLSetScrollOptions @69
SQLTablePrivileges @70
SQLBindParameter @72
+
+SQLAllocHandle @80
+SQLBindParam @81
+SQLCloseCursor @82
+SQLColAttribute @83
+SQLCopyDesc @84
+SQLEndTran @85
+SQLFetchScroll @86
+SQLFreeHandle @87
+SQLGetDescField @88
+SQLGetDescRec @89
+SQLGetDiagField @90
+SQLGetDiagRec @91
+SQLGetEnvAttr @92
+SQLGetConnectAttr @93
+SQLGetStmtAttr @94
+SQLSetConnectAttr @95
+SQLSetDescField @96
+SQLSetDescRec @97
+SQLSetEnvAttr @98
+SQLSetStmtAttr @99
+
SQLDummyOrdinal @199
dconn_FDriverConnectProc @200
DllMain @201
*
* Comments: See "notice.txt" for copyright and license information.
*
- * $Id: psqlodbc.h,v 1.44 2001/06/27 07:38:07 inoue Exp $
+ * $Id: psqlodbc.h,v 1.45 2001/08/18 04:30:47 inoue Exp $
*
*/
int bind_size; /* size of each structure if using Row
* Binding */
int use_bookmarks;
+ UInt4 *rowsFetched;
+ UInt2 *rowStatusArray;
+ void *bookmark_ptr;
} StatementOptions;
/* Used to pass extra query info to send_query */
QR_set_message(self, "Could not get memory for tuple cache.");
return FALSE;
}
+ self->count_allocated = tuple_size;
self->inTuples = TRUE;
self->fetch_count++;
}
- self->backend_tuples = (TupleField *) realloc(self->backend_tuples, self->num_fields * sizeof(TupleField) * self->cache_size);
+ if (self->cache_size > self->count_allocated)
+ self->backend_tuples = (TupleField *) realloc(self->backend_tuples, self->num_fields * sizeof(TupleField) * self->cache_size);
if (!self->backend_tuples)
{
self->status = PGRES_FATAL_ERROR;
case 'B': /* Tuples in binary format */
case 'D': /* Tuples in ASCII format */
- if (!globals.use_declarefetch && self->fcount > 0 && !(self->fcount % TUPLE_MALLOC_INC))
+ if (!globals.use_declarefetch && self->fcount >= self->count_allocated)
{
- size_t old_size = self->fcount * self->num_fields * sizeof(TupleField);
+ int tuple_size = self->count_allocated;
- mylog("REALLOC: old_size = %d\n", old_size);
-
- self->backend_tuples = (TupleField *) realloc(self->backend_tuples, old_size + (self->num_fields * sizeof(TupleField) * TUPLE_MALLOC_INC));
+ mylog("REALLOC: old_count = %d, size = %d\n", tuple_size, self->num_fields * sizeof(TupleField) * tuple_size);
+ tuple_size *= 2;
+ self->backend_tuples = (TupleField *) realloc(self->backend_tuples,
+ tuple_size * self->num_fields * sizeof(TupleField));
if (!self->backend_tuples)
{
self->status = PGRES_FATAL_ERROR;
QR_set_message(self, "Out of memory while reading tuples.");
return FALSE;
}
+ self->count_allocated = tuple_size;
}
if (!QR_read_tuple(self, (char) (id == 0)))
* (backend) */
/* Stuff for declare/fetch tuples */
+ int count_allocated; /* m(re)alloced count */
int fetch_count; /* logical rows read so far */
int fcount; /* actual rows read in the fetch */
int currTuple;
#include <windows.h>
#include <sqlext.h>
#endif
+#include "pgapifunc.h"
extern GLOBAL_VALUES globals;
RETCODE SQL_API
-SQLRowCount(
+PGAPI_RowCount(
HSTMT hstmt,
SDWORD FAR *pcrow)
{
- static char *func = "SQLRowCount";
+ static char *func = "PGAPI_RowCount";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *res;
char *msg,
if (ptr)
{
*pcrow = atoi(ptr + 1);
- mylog("**** SQLRowCount(): THE ROWS: *pcrow = %d\n", *pcrow);
+ mylog("**** PGAPI_RowCount(): THE ROWS: *pcrow = %d\n", *pcrow);
}
else
{
*pcrow = -1;
- mylog("**** SQLRowCount(): NO ROWS: *pcrow = %d\n", *pcrow);
+ mylog("**** PGAPI_RowCount(): NO ROWS: *pcrow = %d\n", *pcrow);
}
return SQL_SUCCESS;
* attached to "hstmt".
*/
RETCODE SQL_API
-SQLNumResultCols(
+PGAPI_NumResultCols(
HSTMT hstmt,
SWORD FAR *pccol)
{
- static char *func = "SQLNumResultCols";
+ static char *func = "PGAPI_NumResultCols";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *result;
char parse_ok;
{
if (stmt->parse_status == STMT_PARSE_NONE)
{
- mylog("SQLNumResultCols: calling parse_statement on stmt=%u\n", stmt);
+ mylog("PGAPI_NumResultCols: calling parse_statement on stmt=%u\n", stmt);
parse_statement(stmt);
}
{
parse_ok = TRUE;
*pccol = stmt->nfld;
- mylog("PARSE: SQLNumResultCols: *pccol = %d\n", *pccol);
+ mylog("PARSE: PGAPI_NumResultCols: *pccol = %d\n", *pccol);
}
}
SC_pre_execute(stmt);
result = SC_get_Result(stmt);
- mylog("SQLNumResultCols: result = %u, status = %d, numcols = %d\n", result, stmt->status, result != NULL ? QR_NumResultCols(result) : -1);
+ mylog("PGAPI_NumResultCols: result = %u, status = %d, numcols = %d\n", result, stmt->status, result != NULL ? QR_NumResultCols(result) : -1);
if ((!result) || ((stmt->status != STMT_FINISHED) && (stmt->status != STMT_PREMATURE)))
{
/* no query has been executed on this statement */
}
*pccol = QR_NumResultCols(result);
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (stmt->options.scroll_concurrency != SQL_CONCUR_READ_ONLY)
+ {
+ *pccol -= 2;
+ }
+#endif /* DRIVER_CURSOR_IMPLEMENT */
}
return SQL_SUCCESS;
* information about.
*/
RETCODE SQL_API
-SQLDescribeCol(
+PGAPI_DescribeCol(
HSTMT hstmt,
UWORD icol,
UCHAR FAR *szColName,
SWORD FAR *pibScale,
SWORD FAR *pfNullable)
{
- static char *func = "SQLDescribeCol";
+ static char *func = "PGAPI_DescribeCol";
/* gets all the information about a specific column */
StatementClass *stmt = (StatementClass *) hstmt;
{
if (stmt->parse_status == STMT_PARSE_NONE)
{
- mylog("SQLDescribeCol: calling parse_statement on stmt=%u\n", stmt);
+ mylog("PGAPI_DescribeCol: calling parse_statement on stmt=%u\n", stmt);
parse_statement(stmt);
}
res = SC_get_Result(stmt);
- mylog("**** SQLDescribeCol: res = %u, stmt->status = %d, !finished=%d, !premature=%d\n", res, stmt->status, stmt->status != STMT_FINISHED, stmt->status != STMT_PREMATURE);
+ mylog("**** PGAPI_DescribeCol: res = %u, stmt->status = %d, !finished=%d, !premature=%d\n", res, stmt->status, stmt->status != STMT_FINISHED, stmt->status != STMT_PREMATURE);
if ((NULL == res) || ((stmt->status != STMT_FINISHED) && (stmt->status != STMT_PREMATURE)))
{
/* no query has been executed on this statement */
/* Returns result column descriptor information for a result set. */
RETCODE SQL_API
-SQLColAttributes(
+PGAPI_ColAttributes(
HSTMT hstmt,
UWORD icol,
UWORD fDescType,
SWORD FAR *pcbDesc,
SDWORD FAR *pfDesc)
{
- static char *func = "SQLColAttributes";
+ static char *func = "PGAPI_ColAttributes";
StatementClass *stmt = (StatementClass *) hstmt;
Int4 field_type = 0;
ConnInfo *ci;
{
if (stmt->parse_status == STMT_PARSE_NONE)
{
- mylog("SQLColAttributes: calling parse_statement\n");
+ mylog("PGAPI_ColAttributes: calling parse_statement\n");
parse_statement(stmt);
}
{
SC_pre_execute(stmt);
- mylog("**** SQLColAtt: result = %u, status = %d, numcols = %d\n", stmt->result, stmt->status, stmt->result != NULL ? QR_NumResultCols(stmt->result) : -1);
+ mylog("**** PGAPI_ColAtt: result = %u, status = %d, numcols = %d\n", stmt->result, stmt->status, stmt->result != NULL ? QR_NumResultCols(stmt->result) : -1);
if ((NULL == stmt->result) || ((stmt->status != STMT_FINISHED) && (stmt->status != STMT_PREMATURE)))
{
case SQL_COLUMN_DISPLAY_SIZE:
value = (parse_ok) ? stmt->fi[icol]->display_size : pgtype_display_size(stmt, field_type, icol, unknown_sizes);
- mylog("SQLColAttributes: col %d, display_size= %d\n", icol, value);
+ mylog("PGAPI_ColAttributes: col %d, display_size= %d\n", icol, value);
break;
{
p = stmt->fi[icol]->alias;
- mylog("SQLColAttr: COLUMN_LABEL = '%s'\n", p);
+ mylog("PGAPI_ColAttr: COLUMN_LABEL = '%s'\n", p);
break;
}
case SQL_COLUMN_NAME:
p = (parse_ok) ? stmt->fi[icol]->name : QR_get_fieldname(stmt->result, icol);
- mylog("SQLColAttr: COLUMN_NAME = '%s'\n", p);
+ mylog("PGAPI_ColAttr: COLUMN_NAME = '%s'\n", p);
break;
case SQL_COLUMN_LENGTH:
value = (parse_ok) ? stmt->fi[icol]->length : pgtype_length(stmt, field_type, icol, unknown_sizes);
- mylog("SQLColAttributes: col %d, length = %d\n", icol, value);
+ mylog("PGAPI_ColAttributes: col %d, length = %d\n", icol, value);
break;
case SQL_COLUMN_MONEY:
case SQL_COLUMN_PRECISION:
value = (parse_ok) ? stmt->fi[icol]->precision : pgtype_precision(stmt, field_type, icol, unknown_sizes);
- mylog("SQLColAttributes: col %d, precision = %d\n", icol, value);
+ mylog("PGAPI_ColAttributes: col %d, precision = %d\n", icol, value);
break;
case SQL_COLUMN_QUALIFIER_NAME:
case SQL_COLUMN_TABLE_NAME:
p = (parse_ok && stmt->fi[icol]->ti) ? stmt->fi[icol]->ti->name : "";
- mylog("SQLColAttr: TABLE_NAME = '%s'\n", p);
+ mylog("PGAPI_ColAttr: TABLE_NAME = '%s'\n", p);
break;
case SQL_COLUMN_TYPE:
*/
value = SQL_ATTR_WRITE;
- mylog("SQLColAttr: UPDATEABLE = %d\n", value);
+ mylog("PGAPI_ColAttr: UPDATEABLE = %d\n", value);
break;
}
/* Returns result data for a single column in the current row. */
RETCODE SQL_API
-SQLGetData(
+PGAPI_GetData(
HSTMT hstmt,
UWORD icol,
SWORD fCType,
SDWORD cbValueMax,
SDWORD FAR *pcbValue)
{
- static char *func = "SQLGetData";
+ static char *func = "PGAPI_GetData";
QResultClass *res;
StatementClass *stmt = (StatementClass *) hstmt;
int num_cols,
int result;
char get_bookmark = FALSE;
- mylog("SQLGetData: enter, stmt=%u\n", stmt);
+ mylog("PGAPI_GetData: enter, stmt=%u\n", stmt);
if (!stmt)
{
field_type = QR_get_field_type(res, icol);
- mylog("**** SQLGetData: icol = %d, fCType = %d, field_type = %d, value = '%s'\n", icol, fCType, field_type, value);
+ mylog("**** PGAPI_GetData: icol = %d, fCType = %d, field_type = %d, value = '%s'\n", icol, fCType, field_type, value);
stmt->current_col = icol;
* advances the cursor.
*/
RETCODE SQL_API
-SQLFetch(
+PGAPI_Fetch(
HSTMT hstmt)
{
- static char *func = "SQLFetch";
+ static char *func = "PGAPI_Fetch";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *res;
- mylog("SQLFetch: stmt = %u, stmt->result= %u\n", stmt, stmt->result);
+ mylog("PGAPI_Fetch: stmt = %u, stmt->result= %u\n", stmt, stmt->result);
if (!stmt)
{
if (!(res = stmt->result))
{
- stmt->errormsg = "Null statement result in SQLFetch.";
+ stmt->errormsg = "Null statement result in PGAPI_Fetch.";
stmt->errornumber = STMT_SEQUENCE_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
if (stmt->bookmark.buffer)
{
stmt->errornumber = STMT_COLNUM_ERROR;
- stmt->errormsg = "Not allowed to bind a bookmark column when using SQLFetch";
+ stmt->errormsg = "Not allowed to bind a bookmark column when using PGAPI_Fetch";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
/* This fetchs a block of data (rowset). */
RETCODE SQL_API
-SQLExtendedFetch(
+PGAPI_ExtendedFetch(
HSTMT hstmt,
UWORD fFetchType,
SDWORD irow,
UDWORD FAR *pcrow,
UWORD FAR *rgfRowStatus)
{
- static char *func = "SQLExtendedFetch";
+ static char *func = "PGAPI_ExtendedFetch";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *res;
int num_tuples,
char truncated,
error;
- mylog("SQLExtendedFetch: stmt=%u\n", stmt);
+ mylog("PGAPI_ExtendedFetch: stmt=%u\n", stmt);
if (!stmt)
{
if (fFetchType != SQL_FETCH_NEXT)
{
stmt->errornumber = STMT_NOT_IMPLEMENTED_ERROR;
- stmt->errormsg = "Unsupported fetch type for SQLExtendedFetch with UseDeclareFetch option.";
+ stmt->errormsg = "Unsupported fetch type for PGAPI_ExtendedFetch with UseDeclareFetch option.";
return SQL_ERROR;
}
}
if (!(res = stmt->result))
{
- stmt->errormsg = "Null statement result in SQLExtendedFetch.";
+ stmt->errormsg = "Null statement result in PGAPI_ExtendedFetch.";
stmt->errornumber = STMT_SEQUENCE_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
*/
if (stmt->rowset_start >= num_tuples)
{
+ if (stmt->options.rowset_size > num_tuples)
+ {
+ stmt->errornumber = STMT_POS_BEFORE_RECORDSET;
+ stmt->errormsg = "fetch prior from eof and before the beggining";
+ }
stmt->rowset_start = num_tuples <= 0 ? 0 : (num_tuples - stmt->options.rowset_size);
}
else
+ {
+ if (stmt->rowset_start < stmt->options.rowset_size)
+ {
+ stmt->errormsg = "fetch prior and before the beggining";
+ stmt->errornumber = STMT_POS_BEFORE_RECORDSET;
+ }
stmt->rowset_start -= stmt->options.rowset_size;
+ }
break;
case SQL_FETCH_FIRST:
break;
default:
- SC_log_error(func, "Unsupported SQLExtendedFetch Direction", stmt);
+ SC_log_error(func, "Unsupported PGAPI_ExtendedFetch Direction", stmt);
return SQL_ERROR;
}
/* increment the base row in the tuple cache */
QR_set_rowset_size(res, stmt->options.rowset_size);
- QR_inc_base(res, stmt->last_fetch_count);
+ /* QR_inc_base(res, stmt->last_fetch_count); */
+ /* Is inc_base right ? */
+ res->base = stmt->rowset_start;
/* Physical Row advancement occurs for each row fetched below */
- mylog("SQLExtendedFetch: new currTuple = %d\n", stmt->currTuple);
+ mylog("PGAPI_ExtendedFetch: new currTuple = %d\n", stmt->currTuple);
truncated = error = FALSE;
for (i = 0; i < stmt->options.rowset_size; i++)
{
if (result == SQL_ERROR)
*(rgfRowStatus + i) = SQL_ROW_ERROR;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ /* this should be refined */
+ else if (result > 10 && result < 20)
+ *(rgfRowStatus + i) = result - 10;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
else
*(rgfRowStatus + i) = SQL_ROW_SUCCESS;
}
return SQL_ERROR;
else if (truncated)
return SQL_SUCCESS_WITH_INFO;
+ else if (stmt->errornumber == STMT_POS_BEFORE_RECORDSET)
+ return SQL_SUCCESS_WITH_INFO;
else
return SQL_SUCCESS;
}
*/
/* CC: return SQL_NO_DATA_FOUND since we do not support multiple result sets */
RETCODE SQL_API
-SQLMoreResults(
+PGAPI_MoreResults(
HSTMT hstmt)
{
return SQL_NO_DATA_FOUND;
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+RETCODE SQL_API
+SC_pos_reload(StatementClass *stmt, UWORD irow, UWORD *count)
+{
+ int i, res_cols;
+ UWORD rcnt, global_ridx;
+ QResultClass *res, *qres;
+ char selstr[4096];
+ RETCODE ret = SQL_ERROR;
+ char *tidval, *oidval;
+
+ mylog("positioned load fi=%x ti=%x\n", stmt->fi, stmt->ti);
+ rcnt = 0;
+ if (count)
+ *count = 0;
+ if (!(res = stmt->result))
+ return SQL_ERROR;
+ if (!stmt->ti)
+ parse_statement(stmt); /* not preferable */
+ if (!stmt->ti || stmt->ntab != 1)
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ return SQL_ERROR;
+ }
+ strcpy(selstr, "select");
+ global_ridx = irow + stmt->rowset_start;
+ res_cols = QR_NumResultCols(res);
+ if (!(oidval = QR_get_value_backend_row(res, global_ridx, res_cols - 1)))
+ {
+ return SQL_SUCCESS_WITH_INFO;
+ }
+ tidval = QR_get_value_backend_row(res, global_ridx, res_cols - 2);
+ res_cols -= 2;
+ for (i = 0; i < res_cols; i++)
+ sprintf(selstr, "%s \"%s\",", selstr, stmt->fi[i]->name);
+ sprintf(selstr, "%s CTID, OID from \"%s\" where ctid = currtid2('%s', '%s') and oid = %s",
+ selstr, stmt->ti[0]->name, stmt->ti[0]->name, tidval, oidval),
+ mylog("selstr=%s\n", selstr);
+ qres = CC_send_query(SC_get_conn(stmt), selstr, NULL);
+ if (qres && QR_command_successful(qres))
+ {
+ TupleField *tupleo, *tuplen;
+
+ rcnt = QR_get_num_tuples(qres);
+ tupleo = res->backend_tuples + res->num_fields * global_ridx;
+ if (rcnt == 1)
+ {
+ QR_set_position(qres, 0);
+ tuplen = res->tupleField;
+ for (i = 0; i < res->num_fields; i++)
+ {
+ if (tupleo[i].value)
+ free(tupleo[i].value);
+ tupleo[i].len = tuplen[i].len;
+ tuplen[i].len = 0;
+ tupleo[i].value = tuplen[i].value;
+ tuplen[i].value = NULL;
+ }
+ ret = SQL_SUCCESS;
+ }
+ else
+ {
+ stmt->errornumber = STMT_ROW_VERSION_CHANGED;
+ stmt->errormsg = "the content was deleted after last fetch";
+ ret = SQL_SUCCESS_WITH_INFO;
+ if (stmt->options.cursor_type == SQL_CURSOR_KEYSET_DRIVEN)
+ {
+ if (tupleo[res_cols + 1].value)
+ free(tupleo[res_cols + 1].value);
+ tupleo[res_cols + 1].value = NULL;
+ tupleo[res_cols + 1].len = 0;
+ }
+ }
+ }
+ else if (stmt->errornumber == 0)
+ stmt->errornumber = STMT_ERROR_TAKEN_FROM_BACKEND;
+ if (qres)
+ QR_Destructor(qres);
+ if (count)
+ *count = rcnt;
+ return ret;
+}
+
+RETCODE SQL_API
+SC_pos_newload(StatementClass *stmt, Int4 oid, const char *tidval)
+{
+ int i, res_cols;
+ QResultClass *res, *qres;
+ char selstr[4096];
+ RETCODE ret = SQL_ERROR;
+
+ mylog("positioned new fi=%x ti=%x\n", stmt->fi, stmt->ti);
+ if (!(res = stmt->result))
+ return SQL_ERROR;
+ if (!stmt->ti)
+ parse_statement(stmt); /* not preferable */
+ if (!stmt->ti || stmt->ntab != 1)
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ return SQL_ERROR;
+ }
+ sprintf(selstr, "select");
+ res_cols = QR_NumResultCols(res);
+ res_cols -= 2;
+ for (i = 0; i < res_cols; i++)
+ sprintf(selstr, "%s \"%s\",", selstr, stmt->fi[i]->name);
+ sprintf(selstr, "%s CTID, OID from \"%s\" where", selstr, stmt->ti[0]->name);
+ if (tidval)
+ sprintf(selstr, "%s ctid = currtid2('%s', '%s') and",
+ selstr, stmt->ti[0]->name, tidval);
+ sprintf(selstr, "%s oid = %u", selstr, oid),
+ mylog("selstr=%s\n", selstr);
+ qres = CC_send_query(SC_get_conn(stmt), selstr, NULL);
+ if (qres && QR_command_successful(qres))
+ {
+ TupleField *tupleo, *tuplen;
+ int count = QR_get_num_tuples(qres);
+ QR_set_position(qres, 0);
+ if (count == 1)
+ {
+ tuplen = qres->tupleField;
+ if (res->fcount >= res->count_allocated)
+ {
+ int tuple_size;
+ if (!res->count_allocated)
+ tuple_size = TUPLE_MALLOC_INC;
+ else
+ tuple_size = res->count_allocated * 2;
+ res->backend_tuples = (TupleField *) realloc(
+ res->backend_tuples,
+ res->num_fields * sizeof(TupleField) * tuple_size);
+ if (!res->backend_tuples)
+ {
+ stmt->errornumber = res->status = PGRES_FATAL_ERROR;
+ stmt->errormsg = "Out of memory while reading tuples.";
+ QR_Destructor(qres);
+ return SQL_ERROR;
+ }
+ res->count_allocated = tuple_size;
+ }
+ tupleo = res->backend_tuples + res->num_fields * res->fcount;
+ for (i = 0; i < res->num_fields; i++)
+ {
+ tupleo[i].len = tuplen[i].len;
+ tuplen[i].len = 0;
+ tupleo[i].value = tuplen[i].value;
+ tuplen[i].value = NULL;
+ }
+ res->fcount++;
+ ret = SQL_SUCCESS;
+ }
+ else
+ {
+ stmt->errornumber = STMT_ROW_VERSION_CHANGED;
+ stmt->errormsg = "the content was changed before updation";
+ ret = SQL_SUCCESS_WITH_INFO;
+ }
+ /*stmt->currTuple = stmt->rowset_start + irow;*/
+ }
+ if (qres)
+ QR_Destructor(qres);
+ return ret;
+}
+
+RETCODE SQL_API
+SC_pos_update(StatementClass *stmt,
+ UWORD irow)
+{
+ int i, res_cols, num_cols, upd_cols;
+ UWORD global_ridx;
+ QResultClass *res;
+ BindInfoClass *bindings = stmt->bindings;
+ char updstr[4096];
+ RETCODE ret;
+ char *tidval, *oidval;
+
+ mylog("POS UPDATE %d+%d fi=%x ti=%x\n", irow, stmt->result->base, stmt->fi, stmt->ti);
+ if (!(res = stmt->result))
+ return SQL_ERROR;
+ if (!stmt->ti)
+ parse_statement(stmt); /* not preferable */
+ if (!stmt->ti || stmt->ntab != 1)
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ return SQL_ERROR;
+ }
+ global_ridx = irow + stmt->rowset_start;
+ res_cols = QR_NumResultCols(res);
+ if (!(oidval = QR_get_value_backend_row(res, global_ridx, res_cols - 1)))
+ {
+ stmt->errormsg = "The row is already deleted";
+ return SQL_ERROR;
+ }
+ tidval = QR_get_value_backend_row(res, global_ridx, res_cols - 2);
+
+ sprintf(updstr, "update \"%s\" set", stmt->ti[0]->name);
+ num_cols = stmt->nfld;
+ for (i = upd_cols = 0; i < num_cols; i++)
+ {
+ if (bindings[i].used)
+ {
+ mylog("%d used=%d\n", i, *bindings[i].used);
+ if (*bindings[i].used != SQL_IGNORE)
+ {
+ if (upd_cols)
+ sprintf(updstr, "%s, \"%s\" = ?", updstr, stmt->fi[i]->name);
+ else
+ sprintf(updstr, "%s \"%s\" = ?", updstr, stmt->fi[i]->name);
+ upd_cols++;
+ }
+ }
+ else
+ mylog("%d null bind\n", i);
+ }
+ if (upd_cols > 0)
+ {
+ HSTMT hstmt;
+ int j;
+ int res_cols = QR_NumResultCols(res);
+ StatementClass *qstmt;
+
+ sprintf(updstr, "%s where ctid = '%s' and oid = %s", updstr,
+ tidval, oidval);
+ mylog("updstr=%s\n", updstr);
+ if (PGAPI_AllocStmt(SC_get_conn(stmt), &hstmt) != SQL_SUCCESS)
+ return SQL_ERROR;
+ qstmt = (StatementClass *) hstmt;
+ for (i = j = 0; i < num_cols; i++)
+ {
+ if (bindings[i].used)
+ {
+ mylog("%d used=%d\n", i, *bindings[i].used);
+ if (*bindings[i].used != SQL_IGNORE)
+ {
+ PGAPI_BindParameter(hstmt, (SQLUSMALLINT) ++j,
+ SQL_PARAM_INPUT, bindings[i].returntype,
+ pgtype_to_sqltype(stmt, QR_get_field_type(res, i)),
+ QR_get_fieldsize(res, i),
+ (SQLSMALLINT) stmt->fi[i]->precision,
+ bindings[i].buffer,
+ bindings[i].buflen,
+ bindings[i].used);
+ }
+ }
+ }
+ ret = PGAPI_ExecDirect(hstmt, updstr, strlen(updstr));
+ if (ret == SQL_ERROR)
+ {
+ stmt->errornumber = qstmt->errornumber;
+ stmt->errormsg = qstmt->errormsg;
+ }
+ else if (ret == SQL_NEED_DATA) /* must be fixed */
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ stmt->errornumber = STMT_INVALID_CURSOR_STATE_ERROR;
+ stmt->errormsg = "SetPos with data_at_exec not yet supported";
+ ret = SQL_ERROR;
+ }
+ if (ret != SQL_ERROR)
+ {
+ int updcnt;
+ const char *cmdstr = QR_get_command(qstmt->result);
+ if (cmdstr &&
+ sscanf(cmdstr, "UPDATE %d", &updcnt) == 1)
+ {
+ if (updcnt == 1)
+ SC_pos_reload(stmt, irow, (UWORD *) 0);
+ else if (updcnt == 0)
+ {
+ stmt->errornumber = STMT_ROW_VERSION_CHANGED;
+ stmt->errormsg = "the content was changed before updation";
+ ret = SQL_ERROR;
+ if (stmt->options.cursor_type == SQL_CURSOR_KEYSET_DRIVEN)
+ SC_pos_reload(stmt, irow, (UWORD *) 0);
+ }
+ else
+ ret = SQL_ERROR;
+ stmt->currTuple = stmt->rowset_start + irow;
+ }
+ else
+ ret = SQL_ERROR;
+ if (ret == SQL_ERROR && stmt->errornumber == 0)
+ {
+ stmt->errornumber = STMT_ERROR_TAKEN_FROM_BACKEND;
+ stmt->errormsg = "SetPos update return error";
+ }
+ }
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
+ }
+ else
+ ret = SQL_SUCCESS_WITH_INFO;
+ return ret;
+}
+RETCODE SQL_API
+SC_pos_delete(StatementClass *stmt,
+ UWORD irow)
+{
+ int res_cols;
+ UWORD global_ridx;
+ QResultClass *res, *qres;
+ BindInfoClass *bindings = stmt->bindings;
+ char dltstr[4096];
+ RETCODE ret;
+ char *oidval;
+
+ mylog("POS DELETE fi=%x ti=%x\n", stmt->fi, stmt->ti);
+ if (!(res = stmt->result))
+ return SQL_ERROR;
+ if (!stmt->ti)
+ parse_statement(stmt); /* not preferable */
+ if (!stmt->ti || stmt->ntab != 1)
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ return SQL_ERROR;
+ }
+ res_cols = QR_NumResultCols(res);
+ global_ridx = irow + stmt->rowset_start;
+ if (!(oidval = QR_get_value_backend_row(res, global_ridx, res_cols - 1)))
+ {
+ stmt->errormsg = "The row is already deleted";
+ return SQL_ERROR;
+ }
+ sprintf(dltstr, "delete from \"%s\" where ctid = '%s' and oid = %s",
+ stmt->ti[0]->name,
+ QR_get_value_backend_row(stmt->result, global_ridx, res_cols - 2),
+ oidval);
+
+ mylog("dltstr=%s\n", dltstr);
+ qres = CC_send_query(SC_get_conn(stmt), dltstr, NULL);
+ if (qres && QR_command_successful(qres))
+ {
+ int dltcnt;
+ const char *cmdstr = QR_get_command(qres);
+ if (cmdstr &&
+ sscanf(cmdstr, "DELETE %d", &dltcnt) == 1)
+ {
+ if (dltcnt == 1)
+ SC_pos_reload(stmt, irow, (UWORD *) 0);
+ else if (dltcnt == 0)
+ {
+ stmt->errornumber = STMT_ROW_VERSION_CHANGED;
+ stmt->errormsg = "the content was changed before deletion";
+ ret = SQL_ERROR;
+ if (stmt->options.cursor_type == SQL_CURSOR_KEYSET_DRIVEN)
+ SC_pos_reload(stmt, irow, (UWORD *) 0);
+ }
+ else
+ ret = SQL_ERROR;
+ stmt->currTuple = stmt->rowset_start + irow;
+ }
+ else
+ ret = SQL_ERROR;
+ }
+ else
+ ret = SQL_ERROR;
+ if (ret == SQL_ERROR && stmt->errornumber == 0)
+ {
+ stmt->errornumber = STMT_ERROR_TAKEN_FROM_BACKEND;
+ stmt->errormsg = "SetPos delete return error";
+ }
+ if (qres)
+ QR_Destructor(qres);
+ return ret;
+}
+RETCODE SQL_API
+SC_pos_add(StatementClass *stmt,
+ UWORD irow)
+{
+ int num_cols, add_cols, i;
+ HSTMT hstmt;
+ QResultClass *res;
+ BindInfoClass *bindings = stmt->bindings;
+ char addstr[4096];
+ RETCODE ret;
+
+ mylog("POS ADD fi=%x ti=%x\n", stmt->fi, stmt->ti);
+ if (!(res = stmt->result))
+ return SQL_ERROR;
+ if (!stmt->ti)
+ parse_statement(stmt); /* not preferable */
+ if (!stmt->ti || stmt->ntab != 1)
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ return SQL_ERROR;
+ }
+ num_cols = stmt->nfld;
+ sprintf(addstr, "insert into \"%s\" (", stmt->ti[0]->name);
+ if (PGAPI_AllocStmt(SC_get_conn(stmt), &hstmt) != SQL_SUCCESS)
+ return SQL_ERROR;
+ for (i = add_cols = 0; i < num_cols; i++)
+ {
+ if (bindings[i].used)
+ {
+ mylog("%d used=%d\n", i, *bindings[i].used);
+ if (*bindings[i].used != SQL_IGNORE)
+ {
+ if (add_cols)
+ sprintf(addstr, "%s, \"%s\"", addstr, stmt->fi[i]->name);
+ else
+ sprintf(addstr, "%s\"%s\"", addstr, stmt->fi[i]->name);
+ PGAPI_BindParameter(hstmt, (SQLUSMALLINT) ++add_cols,
+ SQL_PARAM_INPUT, bindings[i].returntype,
+ pgtype_to_sqltype(stmt, QR_get_field_type(res, i)),
+ QR_get_fieldsize(res, i),
+ (SQLSMALLINT) stmt->fi[i]->precision,
+ bindings[i].buffer,
+ bindings[i].buflen,
+ bindings[i].used);
+ }
+ }
+ else
+ mylog("%d null bind\n", i);
+ }
+ if (add_cols > 0)
+ {
+ StatementClass *qstmt = (StatementClass *) hstmt;
+
+ sprintf(addstr, "%s) values (", addstr);
+ for (i = 0; i < add_cols; i++)
+ {
+ if (i)
+ strcat(addstr, ", ?");
+ else
+ strcat(addstr, "?");
+ }
+ strcat(addstr, ")");
+ mylog("addstr=%s\n", addstr);
+ ret = PGAPI_ExecDirect(hstmt, addstr, strlen(addstr));
+ if (ret == SQL_NEED_DATA) /* must be fixed */
+ {
+ stmt->options.scroll_concurrency = SQL_CONCUR_READ_ONLY;
+ stmt->errornumber = STMT_INVALID_CURSOR_STATE_ERROR;
+ stmt->errormsg = "SetPos with data_at_exec not yet supported";
+ ret = SQL_ERROR;
+ }
+ if (ret == SQL_ERROR)
+ {
+ stmt->errornumber = qstmt->errornumber;
+ stmt->errormsg = qstmt->errormsg;
+ }
+ else
+ {
+ int addcnt;
+ Int4 oid;
+ const char *cmdstr = QR_get_command(qstmt->result);
+ if (cmdstr &&
+ sscanf(cmdstr, "INSERT %u %d", &oid, &addcnt) == 2 &&
+ addcnt == 1)
+ {
+ SC_pos_newload(stmt, oid, NULL);
+ if (stmt->bookmark.buffer)
+ {
+ char buf[32];
+
+ sprintf(buf, "%ld", res->fcount);
+ copy_and_convert_field(stmt, 0, buf,
+ SQL_C_ULONG, stmt->bookmark.buffer,
+ 0, stmt->bookmark.used);
+ }
+ }
+ else
+ {
+ stmt->errornumber = STMT_ERROR_TAKEN_FROM_BACKEND;
+ stmt->errormsg = "SetPos insert return error";
+ ret = SQL_ERROR;
+ }
+ }
+ }
+ else
+ ret = SQL_SUCCESS_WITH_INFO;
+ PGAPI_FreeStmt(hstmt, SQL_DROP);
+ return ret;
+}
+#endif /* DRIVER_CURSOR_IMPLEMENT */
+
/*
* This positions the cursor within a rowset, that was positioned using SQLExtendedFetch.
* This will be useful (so far) only when using SQLGetData after SQLExtendedFetch.
*/
RETCODE SQL_API
-SQLSetPos(
+PGAPI_SetPos(
HSTMT hstmt,
UWORD irow,
UWORD fOption,
UWORD fLock)
{
- static char *func = "SQLSetPos";
+ static char *func = "PGAPI_SetPos";
StatementClass *stmt = (StatementClass *) hstmt;
QResultClass *res;
int num_cols,
return SQL_INVALID_HANDLE;
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ mylog("SetPos fOption=%d irow=%d lock=%d currt=%d\n", fOption, irow, fLock, stmt->currTuple);
+ if (stmt->options.scroll_concurrency != SQL_CONCUR_READ_ONLY)
+ ;
+ else
+#endif /* DRIVER_CURSOR_IMPLEMENT */
if (fOption != SQL_POSITION && fOption != SQL_REFRESH)
{
stmt->errornumber = STMT_NOT_IMPLEMENTED_ERROR;
- stmt->errormsg = "Only SQL_POSITION/REFRESH is supported for SQLSetPos";
+ stmt->errormsg = "Only SQL_POSITION/REFRESH is supported for PGAPI_SetPos";
SC_log_error(func, "", stmt);
return SQL_ERROR;
}
if (!(res = stmt->result))
{
- stmt->errormsg = "Null statement result in SQLSetPos.";
+ stmt->errormsg = "Null statement result in PGAPI_SetPos.";
stmt->errornumber = STMT_SEQUENCE_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
irow--;
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ switch (fOption)
+ {
+ case SQL_UPDATE:
+ return SC_pos_update(stmt, irow);
+ case SQL_DELETE:
+ return SC_pos_delete(stmt, irow);
+ case SQL_ADD:
+ return SC_pos_add(stmt, irow);
+ }
+#endif /* DRIVER_CURSOR_IMPLEMENT */
/* Reset for SQLGetData */
for (i = 0; i < num_cols; i++)
bindings[i].data_left = -1;
+ if (fOption == SQL_REFRESH)
+ {
+ /* save the last_fetch_count */
+ int last_fetch = stmt->last_fetch_count;
+ int bind_save = stmt->bind_row;
+
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (stmt->options.cursor_type == SQL_CURSOR_KEYSET_DRIVEN)
+ SC_pos_reload(stmt, irow, (UWORD *) 0);
+#endif /* DRIVER_CURSOR_IMPLEMENT */
+ stmt->currTuple = stmt->rowset_start + irow - 1;
+ stmt->bind_row = irow;
+ SC_fetch(stmt);
+ /* restore the last_fetch_count */
+ stmt->last_fetch_count = last_fetch;
+ stmt->bind_row = bind_save;
+ }
+ else
+ stmt->currTuple = stmt->rowset_start + irow;
QR_set_position(res, irow);
- stmt->currTuple = stmt->rowset_start + irow;
-
return SQL_SUCCESS;
}
/* Sets options that control the behavior of cursors. */
RETCODE SQL_API
-SQLSetScrollOptions(
+PGAPI_SetScrollOptions(
HSTMT hstmt,
UWORD fConcurrency,
SDWORD crowKeyset,
UWORD crowRowset)
{
- static char *func = "SQLSetScrollOptions";
+ static char *func = "PGAPI_SetScrollOptions";
+ StatementClass *stmt = (StatementClass *) hstmt;
+ mylog("PGAPI_SetScrollOptions fConcurrency=%d crowKeyset=%d crowRowset=%d\n",
+ fConcurrency, crowKeyset, crowRowset);
+ stmt->errornumber = STMT_NOT_IMPLEMENTED_ERROR;
+ stmt->errormsg = "SetScroll option not implemeted";
- SC_log_error(func, "Function not implemented", (StatementClass *) hstmt);
+ SC_log_error(func, "Function not implemented", hstmt);
return SQL_ERROR;
}
/* Set the cursor name on a statement handle */
RETCODE SQL_API
-SQLSetCursorName(
+PGAPI_SetCursorName(
HSTMT hstmt,
UCHAR FAR *szCursor,
SWORD cbCursor)
{
- static char *func = "SQLSetCursorName";
+ static char *func = "PGAPI_SetCursorName";
StatementClass *stmt = (StatementClass *) hstmt;
int len;
- mylog("SQLSetCursorName: hstmt=%u, szCursor=%u, cbCursorMax=%d\n", hstmt, szCursor, cbCursor);
+ mylog("PGAPI_SetCursorName: hstmt=%u, szCursor=%u, cbCursorMax=%d\n", hstmt, szCursor, cbCursor);
if (!stmt)
{
/* Return the cursor name for a statement handle */
RETCODE SQL_API
-SQLGetCursorName(
+PGAPI_GetCursorName(
HSTMT hstmt,
UCHAR FAR *szCursor,
SWORD cbCursorMax,
SWORD FAR *pcbCursor)
{
- static char *func = "SQLGetCursorName";
+ static char *func = "PGAPI_GetCursorName";
StatementClass *stmt = (StatementClass *) hstmt;
int len = 0;
RETCODE result;
- mylog("SQLGetCursorName: hstmt=%u, szCursor=%u, cbCursorMax=%d, pcbCursor=%u\n", hstmt, szCursor, cbCursorMax, pcbCursor);
+ mylog("PGAPI_GetCursorName: hstmt=%u, szCursor=%u, cbCursorMax=%d, pcbCursor=%u\n", hstmt, szCursor, cbCursorMax, pcbCursor);
if (!stmt)
{
#include <windows.h>
#include <sql.h>
#endif
+#include "pgapifunc.h"
extern GLOBAL_VALUES globals;
RETCODE SQL_API
-SQLAllocStmt(HDBC hdbc,
+PGAPI_AllocStmt(HDBC hdbc,
HSTMT FAR *phstmt)
{
- static char *func = "SQLAllocStmt";
+ static char *func = "PGAPI_AllocStmt";
ConnectionClass *conn = (ConnectionClass *) hdbc;
StatementClass *stmt;
stmt = SC_Constructor();
- mylog("**** SQLAllocStmt: hdbc = %u, stmt = %u\n", hdbc, stmt);
+ mylog("**** PGAPI_AllocStmt: hdbc = %u, stmt = %u\n", hdbc, stmt);
if (!stmt)
{
RETCODE SQL_API
-SQLFreeStmt(HSTMT hstmt,
+PGAPI_FreeStmt(HSTMT hstmt,
UWORD fOption)
{
- static char *func = "SQLFreeStmt";
+ static char *func = "PGAPI_FreeStmt";
StatementClass *stmt = (StatementClass *) hstmt;
mylog("%s: entering...hstmt=%u, fOption=%d\n", func, hstmt, fOption);
SC_free_params(stmt, STMT_FREE_PARAMS_ALL);
else
{
- stmt->errormsg = "Invalid option passed to SQLFreeStmt.";
+ stmt->errormsg = "Invalid option passed to PGAPI_FreeStmt.";
stmt->errornumber = STMT_OPTION_OUT_OF_RANGE_ERROR;
SC_log_error(func, "", stmt);
return SQL_ERROR;
self->pre_executing = TRUE;
self->inaccurate_result = FALSE;
- SQLExecute(self);
+ PGAPI_Execute(self);
self->pre_executing = old_pre_executing;
static char *func = "SC_fetch";
QResultClass *res = self->result;
int retval,
- result;
+ result, updret;
Int2 num_cols,
lf;
Oid type;
char *value;
ColumnInfoClass *ci;
-
+extern WORD addrow;
/* TupleField *tupleField; */
self->last_fetch_count = 0;
return SQL_NO_DATA_FOUND;
}
- mylog("**** SQLFetch: manual_result\n");
+ mylog("**** SC_fetch: manual_result\n");
(self->currTuple)++;
}
else
retval = QR_next_tuple(res);
if (retval < 0)
{
- mylog("**** SQLFetch: end_tuples\n");
+ mylog("**** SC_fetch: end_tuples\n");
return SQL_NO_DATA_FOUND;
}
else if (retval > 0)
(self->currTuple)++;/* all is well */
else
{
- mylog("SQLFetch: error\n");
+ mylog("SC_fetch: error\n");
self->errornumber = STMT_EXEC_ERROR;
self->errormsg = "Error fetching next row";
SC_log_error(func, "", self);
SQL_C_ULONG, self->bookmark.buffer, 0, self->bookmark.used);
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ updret = 0;
+ if (self->options.scroll_concurrency != SQL_CONCUR_READ_ONLY)
+ {
+ if (!QR_get_value_backend_row(res, self->currTuple, num_cols - 1))
+ updret = SQL_ROW_DELETED;
+ num_cols -= 2;
+ }
+ if (!self->options.retrieve_data) /* data isn't required */
+ return updret ? updret + 10 : SQL_SUCCESS;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
for (lf = 0; lf < num_cols; lf++)
{
mylog("fetch: cols=%d, lf=%d, self = %u, self->bindings = %u, buffer[] = %u\n", num_cols, lf, self, self->bindings, self->bindings[lf].buffer);
}
}
+#ifdef DRIVER_CURSOR_IMPLEMENT
+ if (updret)
+ result = updret + 10;
+#endif /* DRIVER_CURSOR_IMPLEMENT */
return result;
}
ok = QR_command_successful(res);
- mylog("SQLExecute: ok = %d, status = %d\n", ok, QR_get_status(res));
+ mylog("SC_exec: begin ok = %d, status = %d\n", ok, QR_get_status(res));
QR_Destructor(res);
{ /* get the return value of the procedure call */
RETCODE ret;
HSTMT hstmt = (HSTMT) self;
- ret = SQLBindCol(hstmt, 1, self->parameters[0].CType, self->parameters[0].buffer, self->parameters[0].buflen, self->parameters[0].used);
+ ret = PGAPI_BindCol(hstmt, 1, self->parameters[0].CType, self->parameters[0].buffer, self->parameters[0].buflen, self->parameters[0].used);
if (ret == SQL_SUCCESS || ret == SQL_SUCCESS_WITH_INFO)
SC_fetch(hstmt);
else
self->errormsg = "BindCol to Procedure return failed.";
}
if (ret == SQL_SUCCESS || ret == SQL_SUCCESS_WITH_INFO)
- SQLBindCol(hstmt, 1, self->parameters[0].CType, NULL, 0, NULL);
+ PGAPI_BindCol(hstmt, 1, self->parameters[0].CType, NULL, 0, NULL);
else
{
self->errornumber = STMT_EXEC_ERROR;
STMT_EXECUTING /* statement execution is still going on */
} STMT_Status;
+#define STMT_ROW_VERSION_CHANGED (-4)
+#define STMT_POS_BEFORE_RECORDSET (-3)
#define STMT_TRUNCATED (-2)
#define STMT_INFO_ONLY (-1) /* not an error message,
* just a notification
#define STMT_OPERATION_INVALID 25
#define STMT_PROGRAM_TYPE_OUT_OF_RANGE 26
#define STMT_BAD_ERROR 27
+#define STMT_INVALID_OPTION_IDENTIFIER 28
/* statement types */
enum
-@erase "$(INTDIR)\statement.obj"
-@erase "$(INTDIR)\tuple.obj"
-@erase "$(INTDIR)\tuplelist.obj"
+ -@erase "$(INTDIR)\odbcapi.obj"
+ -@erase "$(INTDIR)\odbcapi30.obj"
-@erase "$(INTDIR)\vc60.idb"
-@erase "$(OUTDIR)\psqlodbc.dll"
-@erase "$(OUTDIR)\psqlodbc.exp"
"$(INTDIR)\statement.obj" \
"$(INTDIR)\tuple.obj" \
"$(INTDIR)\tuplelist.obj" \
+ "$(INTDIR)\odbcapi.obj" \
+ "$(INTDIR)\odbcapi30.obj" \
"$(INTDIR)\psqlodbc.res"
"$(OUTDIR)\psqlodbc.dll" : "$(OUTDIR)" $(DEF_FILE) $(LINK32_OBJS)
-@erase "$(INTDIR)\statement.obj"
-@erase "$(INTDIR)\tuple.obj"
-@erase "$(INTDIR)\tuplelist.obj"
+ -@erase "$(INTDIR)\odbcapi.obj"
+ -@erase "$(INTDIR)\odbcapi30.obj"
-@erase "$(INTDIR)\vc60.idb"
-@erase "$(INTDIR)\vc60.pdb"
-@erase "$(OUTDIR)\psqlodbc.dll"
"$(INTDIR)\statement.obj" \
"$(INTDIR)\tuple.obj" \
"$(INTDIR)\tuplelist.obj" \
+ "$(INTDIR)\odbcapi.obj" \
+ "$(INTDIR)\odbcapi30.obj" \
"$(INTDIR)\psqlodbc.res"
"$(OUTDIR)\psqlodbc.dll" : "$(OUTDIR)" $(DEF_FILE) $(LINK32_OBJS)
$(CPP) $(CPP_PROJ) $(SOURCE)
+SOURCE=odbcapi.c
+
+"$(INTDIR)\odbcapi.obj" : $(SOURCE) "$(INTDIR)"
+ $(CPP) $(CPP_PROJ) $(SOURCE)
+
+
+SOURCE=odbcapi30.c
+
+"$(INTDIR)\odbcapi30.obj" : $(SOURCE) "$(INTDIR)"
+ $(CPP) $(CPP_PROJ) $(SOURCE)
+
+
!ENDIF
projects / postgresql / commitdiff