#include "ODBC.h"
DBISTATE_DECLARE;
MODULE = DBD::ODBC PACKAGE = DBD::ODBC
INCLUDE: ODBC.xsi
MODULE = DBD::ODBC PACKAGE = DBD::ODBC::dr
void
_data_sources( drh, attribs=Nullsv )
SV * drh
SV * attribs
CODE:
{
AV *ds = dbd_data_sources( drh );
ST(0) = sv_2mortal( newRV_noinc( (SV*)ds ) );
}
MODULE = DBD::ODBC PACKAGE = DBD::ODBC::st
void odbc_describe_param(sth, param)
SV * sth
SV * param
PPCODE:
D_imp_sth(sth);
D_imp_xxh(sth);
SQLRETURN rc;
SQLSMALLINT data_type;
SQLULEN size;
SQLSMALLINT dd;
SQLSMALLINT nullable;
rc = SQLDescribeParam(imp_sth->hstmt, SvIV(param), &data_type, &size, &dd, &nullable);
if (SQL_SUCCEEDED(rc)) {
XPUSHs(sv_2mortal(newSViv(data_type)));
XPUSHs(sv_2mortal(newSViv(size)));
XPUSHs(sv_2mortal(newSViv(dd)));
XPUSHs(sv_2mortal(newSViv(nullable)));
} else {
DBIh_SET_ERR_CHAR(
sth, imp_xxh, Nullch, 1,
"SQLDescribeParam failed",
"IM008", Nullch);
}
IV odbc_rows(sth)
SV * sth
PREINIT:
IV ret;
CODE:
ret = odbc_st_rowcount(sth);
if (ret == 0)
XST_mPV(0, "0E0");
else if (ret < -1)
XST_mUNDEF(0);
else
XST_mIV(0, ret);
void
odbc_execute_for_fetch(sth, tuples, count, tuple_status)
SV * sth
SV * tuples
IV count
SV * tuple_status
PREINIT:
IV ret;
CODE:
/*printf("odbc_execute_array\n");*/
ret = odbc_st_execute_for_fetch(sth, tuples, count, tuple_status);
if (ret == 0)
XST_mPV(0, "0E0");
else if (ret < -1) /* Error */
XST_mUNDEF(0);
else
XST_mIV(0, ret);
void odbc_getdiagrec(sth, record)
SV * sth
unsigned short record
PPCODE:
SQLINTEGER native;
SQLCHAR state[10];
SQLCHAR msg[256];
SQLRETURN rc;
SQLSMALLINT msg_len;
D_imp_sth(sth);
D_imp_xxh(sth);
rc = SQLGetDiagRec(SQL_HANDLE_STMT, imp_sth->hstmt, record,
state, &native, msg, sizeof(msg), &msg_len);
if (SQL_SUCCEEDED(rc)) {
XPUSHs(sv_2mortal(newSVpv(state, 0)));
XPUSHs(sv_2mortal(newSViv(native)));
XPUSHs(sv_2mortal(newSVpv(msg, 0)));
} else if (rc == SQL_NO_DATA) {
# no diags found
} else {
DBIh_SET_ERR_CHAR(
sth, imp_xxh, Nullch, 1,
"SQLGetDiagField failed",
"IM008", Nullch);
}
void odbc_getdiagfield(sth, record, identifier)
SV * sth
unsigned short record
int identifier
PPCODE:
SQLCHAR buf[256];
SQLSMALLINT buf_len;
SQLLEN len_type = 0;
SQLINTEGER int_type = 0;
SQLRETURN ret_type = 0;
SQLPOINTER info_ptr;
SQLRETURN rc;
D_imp_sth(sth);
D_imp_xxh(sth);
switch(identifier) {
case SQL_DIAG_CURSOR_ROW_COUNT:
case SQL_DIAG_ROW_COUNT:
case SQL_DIAG_ROW_NUMBER:
{
info_ptr = &len_type;
break;
}
case SQL_DIAG_DYNAMIC_FUNCTION_CODE:
case SQL_DIAG_NUMBER:
case SQL_DIAG_COLUMN_NUMBER:
case SQL_DIAG_NATIVE:
{
info_ptr = &int_type;
break;
}
case SQL_DIAG_RETURNCODE:
{
info_ptr = &ret_type;
break;
}
default:
{
info_ptr = buf;
break;
}
}
rc = SQLGetDiagField(SQL_HANDLE_STMT, imp_sth->hstmt, record,
identifier, info_ptr, sizeof(buf), &buf_len);
if (SQL_SUCCEEDED(rc)) {
if (info_ptr == &int_type) {
XPUSHs(sv_2mortal(newSViv(int_type)));
} else if (info_ptr == &len_type) {
XPUSHs(sv_2mortal(newSViv(len_type)));
} else if (info_ptr == &ret_type) {
XPUSHs(sv_2mortal(newSViv(ret_type)));
} else {
XPUSHs(sv_2mortal(newSVpvn(buf, buf_len)));
}
} else if (rc == SQL_NO_DATA) {
# no diags found
} else {
DBIh_SET_ERR_CHAR(
sth, imp_xxh, Nullch, 1,
"SQLGetDiagField failed",
"IM008", Nullch);
# TO_DO wrong state
}
SV *
odbc_lob_read(sth, colno, bufsv, length, attr = NULL)
SV *sth
int colno
SV *bufsv
UV length
SV *attr;
PROTOTYPE: $$$$;$
PREINIT:
char *buf;
IV ret_len;
IV sql_type = 0;
INIT:
if (length == 0) {
croak("Cannot retrieve 0 length lob");
}
CODE:
if (attr) {
SV **svp;
DBD_ATTRIBS_CHECK("odbc_lob_read", sth, attr);
DBD_ATTRIB_GET_IV(attr, "TYPE", 4, svp, sql_type);
}
if (SvROK(bufsv)) {
bufsv = SvRV(bufsv);
}
sv_setpvn(bufsv, "", 0); /* ensure we can grow ok */
buf = SvGROW(bufsv, length + 1);
ret_len = odbc_st_lob_read(sth, colno, bufsv, length, sql_type);
if (ret_len >= 0) {
SvCUR_set(bufsv, ret_len); /* set length in SV */
*SvEND(bufsv) = '\0'; /* NUL terminate */
SvSETMAGIC(bufsv);
RETVAL = newSViv(ret_len);
} else {
XSRETURN_UNDEF;
}
OUTPUT:
RETVAL
# ColAttributes was down in the TO_DO list to remove since it duplicated
# some functionality in DBI statement attributes. However, ColAttributes
# can do more
void
_ColAttributes(sth, colno, ftype)
SV * sth
int colno
int ftype
CODE:
ST(0) = odbc_col_attributes(sth, colno, ftype);
void
_Cancel(sth)
SV * sth
CODE:
ST(0) = odbc_cancel(sth);
void
_tables(dbh, sth, catalog, schema, table, type)
SV * dbh
SV * sth
SV * catalog
SV * schema
SV * table
SV * type
CODE:
/* list all tables and views (0 as last parameter) */
ST(0) = dbd_st_tables(dbh, sth, catalog, schema, table, type) ? &PL_sv_yes : &PL_sv_no;
void
_primary_keys(dbh, sth, catalog, schema, table)
SV * dbh
SV * sth
char * catalog
char * schema
char * table
CODE:
ST(0) = dbd_st_primary_keys(dbh, sth, catalog, schema, table) ? &PL_sv_yes : &PL_sv_no;
void
_statistics(dbh, sth, catalog, schema, table, unique, quick)
SV * dbh
SV * sth
char * catalog
char * schema
char * table
int unique
int quick
CODE:
ST(0) = dbd_st_statistics(dbh, sth, catalog, schema, table,
unique, quick) ? &PL_sv_yes : &PL_sv_no;
#void
#DescribeCol(sth, colno)
# SV *sth
# int colno
#
# PPCODE:
#
# char ColumnName[SQL_MAX_COLUMN_NAME_LEN];
# I16 NameLength;
# I16 DataType;
# U32 ColumnSize;
# I16 DecimalDigits;
# I16 Nullable;
# int rc;
#
# rc = odbc_describe_col(sth, colno, ColumnName, sizeof(ColumnName), &NameLength,
# &DataType, &ColumnSize, &DecimalDigits, &Nullable);
# if (rc) {
# XPUSHs(newSVpv(ColumnName, 0));
# XPUSHs(newSViv(DataType));
# XPUSHs(newSViv(ColumnSize));
# XPUSHs(newSViv(DecimalDigits));
# XPUSHs(newSViv(Nullable));
# }
# ------------------------------------------------------------
# database level interface
# ------------------------------------------------------------
MODULE = DBD::ODBC PACKAGE = DBD::ODBC::db
void
_ExecDirect( dbh, stmt )
SV * dbh
SV * stmt
CODE:
{
/*STRLEN lna;*/
/*char *pstmt = SvOK(stmt) ? SvPV(stmt,lna) : "";*/
ST(0) = sv_2mortal(newSViv( dbd_db_execdirect( dbh, stmt ) ) );
}
void odbc_getdiagrec(dbh, record)
SV * dbh
unsigned short record
PPCODE:
SQLINTEGER native;
SQLCHAR state[10];
SQLCHAR msg[256];
SQLRETURN rc;
SQLSMALLINT msg_len;
D_imp_dbh(dbh);
D_imp_xxh(dbh);
rc = SQLGetDiagRec(SQL_HANDLE_DBC, imp_dbh->hdbc, record,
state, &native, msg, sizeof(msg), &msg_len);
if (SQL_SUCCEEDED(rc)) {
XPUSHs(sv_2mortal(newSVpv(state, 0)));
XPUSHs(sv_2mortal(newSViv(native)));
XPUSHs(sv_2mortal(newSVpvn(msg, msg_len)));
} else if (rc == SQL_NO_DATA) {
# no diags found
} else {
DBIh_SET_ERR_CHAR(
dbh, imp_xxh, Nullch, 1,
"SQLGetDiagRec failed",
"IM008", Nullch);
}
void odbc_getdiagfield(dbh, record, identifier)
SV * dbh
unsigned short record
int identifier
PPCODE:
SQLCHAR buf[256];
SQLSMALLINT buf_len;
SQLLEN len_type;
SQLINTEGER int_type;
SQLRETURN ret_type;
SQLPOINTER info_ptr;
SQLRETURN rc;
D_imp_dbh(dbh);
D_imp_xxh(dbh);
switch(identifier) {
case SQL_DIAG_CURSOR_ROW_COUNT:
case SQL_DIAG_ROW_COUNT:
case SQL_DIAG_ROW_NUMBER:
{
info_ptr = &len_type;
break;
}
case SQL_DIAG_DYNAMIC_FUNCTION_CODE:
case SQL_DIAG_NUMBER:
case SQL_DIAG_COLUMN_NUMBER:
case SQL_DIAG_NATIVE:
{
info_ptr = &int_type;
break;
}
case SQL_DIAG_RETURNCODE:
{
info_ptr = &ret_type;
break;
}
default:
{
info_ptr = buf;
break;
}
}
rc = SQLGetDiagField(SQL_HANDLE_DBC, imp_dbh->hdbc, record,
identifier, info_ptr, sizeof(buf), &buf_len);
if (SQL_SUCCEEDED(rc)) {
if (info_ptr == &int_type) {
XPUSHs(sv_2mortal(newSViv(int_type)));
} else if (info_ptr == &len_type) {
XPUSHs(sv_2mortal(newSViv(len_type)));
} else if (info_ptr == &ret_type) {
XPUSHs(sv_2mortal(newSViv(ret_type)));
} else {
XPUSHs(sv_2mortal(newSVpvn(buf, buf_len)));
}
} else if (rc == SQL_NO_DATA) {
# no diags found
} else {
DBIh_SET_ERR_CHAR(
dbh, imp_xxh, Nullch, 1,
"SQLGetDiagField failed",
"IM008", Nullch);
# TO_DO wrong state
}
# called from column_info
void
_columns(dbh, sth, catalog, schema, table, column)
SV * dbh
SV * sth
SV * catalog
SV * schema
SV * table
SV * column
CODE:
ST(0) = odbc_db_columns(dbh, sth, catalog, schema, table, column) ? &PL_sv_yes : &PL_sv_no;
void
_GetInfo(dbh, ftype)
SV * dbh
int ftype
CODE:
ST(0) = odbc_get_info(dbh, ftype);
void
_GetTypeInfo(dbh, sth, ftype)
SV * dbh
SV * sth
int ftype
CODE:
ST(0) = odbc_get_type_info(dbh, sth, ftype) ? &PL_sv_yes : &PL_sv_no;
void
_GetStatistics(dbh, sth, CatalogName, SchemaName, TableName, Unique)
SV * dbh
SV * sth
char * CatalogName
char * SchemaName
char * TableName
int Unique
CODE:
ST(0) = dbd_st_statistics(dbh, sth, CatalogName, SchemaName,
TableName, Unique, 0) ? &PL_sv_yes : &PL_sv_no;
void
_GetPrimaryKeys(dbh, sth, CatalogName, SchemaName, TableName)
SV * dbh
SV * sth
char * CatalogName
char * SchemaName
char * TableName
CODE:
/* the following will end up in dbdimp.c/dbd_st_primary_keys */
ST(0) = odbc_st_primary_keys(dbh, sth, CatalogName, SchemaName, TableName) ? &PL_sv_yes : &PL_sv_no;
void
_GetSpecialColumns(dbh, sth, Identifier, CatalogName, SchemaName, TableName, Scope, Nullable)
SV * dbh
SV * sth
int Identifier
char * CatalogName
char * SchemaName
char * TableName
int Scope
int Nullable
CODE:
ST(0) = odbc_get_special_columns(dbh, sth, Identifier, CatalogName, SchemaName, TableName, Scope, Nullable) ? &PL_sv_yes : &PL_sv_no;
void
_GetForeignKeys(dbh, sth, PK_CatalogName, PK_SchemaName, PK_TableName, FK_CatalogName, FK_SchemaName, FK_TableName)
SV * dbh
SV * sth
char * PK_CatalogName
char * PK_SchemaName
char * PK_TableName
char * FK_CatalogName
char * FK_SchemaName
char * FK_TableName
CODE:
ST(0) = odbc_get_foreign_keys(dbh, sth, PK_CatalogName, PK_SchemaName, PK_TableName, FK_CatalogName, FK_SchemaName, FK_TableName) ? &PL_sv_yes : &PL_sv_no;
#
# Corresponds to ODBC 2.0. 3.0's SQL_API_ODBC3_ALL_FUNCTIONS is handled also
# scheme
void
GetFunctions(dbh, func)
SV * dbh
unsigned short func
PPCODE:
UWORD pfExists[SQL_API_ODBC3_ALL_FUNCTIONS_SIZE];
RETCODE rc;
int i;
int j;
D_imp_dbh(dbh);
rc = SQLGetFunctions(imp_dbh->hdbc, func, pfExists);
if (SQL_ok(rc)) {
switch (func) {
case SQL_API_ALL_FUNCTIONS:
for (i = 0; i < 100; i++) {
XPUSHs(pfExists[i] ? &PL_sv_yes : &PL_sv_no);
}
break;
case SQL_API_ODBC3_ALL_FUNCTIONS:
for (i = 0; i < SQL_API_ODBC3_ALL_FUNCTIONS_SIZE; i++) {
for (j = 0; j < 8 * sizeof(pfExists[i]); j++) {
XPUSHs((pfExists[i] & (1 << j)) ? &PL_sv_yes : &PL_sv_no);
}
}
break;
default:
XPUSHs(pfExists[0] ? &PL_sv_yes : &PL_sv_no);
}
}
MODULE = DBD::ODBC PACKAGE = DBD::ODBC::db