diff options
Diffstat (limited to 'storage/connect/jdbconn.h')
| -rw-r--r-- | storage/connect/jdbconn.h | 190 |
1 files changed, 49 insertions, 141 deletions
diff --git a/storage/connect/jdbconn.h b/storage/connect/jdbconn.h index 73271c8f5be..56f318d238b 100644 --- a/storage/connect/jdbconn.h +++ b/storage/connect/jdbconn.h @@ -1,61 +1,7 @@ /***********************************************************************/ /* JDBConn.h : header file for the JDBC connection classes. */ /***********************************************************************/ -//nclude <windows.h> /* Windows include file */ -//nclude <windowsx.h> /* Message crackers */ - -/***********************************************************************/ -/* Included C-definition files required by the interface. */ -/***********************************************************************/ -#include "block.h" - -/***********************************************************************/ -/* JDBC interface. */ -/***********************************************************************/ -#include <jni.h> - -/***********************************************************************/ -/* Constants and defines. */ -/***********************************************************************/ -// Miscellaneous sizing info -#define MAX_NUM_OF_MSG 10 // Max number of error messages -//efine MAX_CURRENCY 30 // Max size of Currency($) string -#define MAX_TNAME_LEN 32 // Max size of table names -//efine MAX_FNAME_LEN 256 // Max size of field names -//efine MAX_STRING_INFO 256 // Max size of string from SQLGetInfo -//efine MAX_DNAME_LEN 256 // Max size of Recordset names -//efine MAX_CONNECT_LEN 512 // Max size of Connect string -//efine MAX_CURSOR_NAME 18 // Max size of a cursor name -#define DEFAULT_FIELD_TYPE 0 // TYPE_NULL - -#if !defined(__WIN__) -typedef unsigned char *PUCHAR; -#endif // !__WIN__ - -enum JCATINFO { - CAT_TAB = 1, // JDBC Tables - CAT_COL = 2, // JDBC Columns - CAT_KEY = 3, // JDBC PrimaryKeys -//CAT_STAT = 4, // SQLStatistics -//CAT_SPC = 5 // SQLSpecialColumns -}; - -/***********************************************************************/ -/* This structure is used to control the catalog functions. */ -/***********************************************************************/ -typedef struct tagJCATPARM { - JCATINFO Id; // Id to indicate function - PQRYRES Qrp; // Result set pointer - PCSZ DB; // Database (Schema) - PCSZ Tab; // Table name or pattern - PCSZ Pat; // Table type or column pattern -} JCATPARM; - -typedef jint(JNICALL *CRTJVM) (JavaVM **, void **, void *); -typedef jint(JNICALL *GETJVM) (JavaVM **, jsize, jsize *); -#if defined(_DEBUG) -typedef jint(JNICALL *GETDEF) (void *); -#endif // _DEBUG +#include "javaconn.h" // JDBC connection to a data source class TDBJDBC; @@ -66,7 +12,7 @@ class TDBXJDC; /***********************************************************************/ /* JDBConn class. */ /***********************************************************************/ -class JDBConn : public BLOCK { +class JDBConn : public JAVAConn { friend class TDBJDBC; friend class TDBXJDC; //friend PQRYRES GetColumnInfo(PGLOBAL, char*&, char *, int, PVBLK&); @@ -74,118 +20,80 @@ private: JDBConn(); // Standard (unused) constructor public: - JDBConn(PGLOBAL g, TDBJDBC *tdbp); + // Constructor + JDBConn(PGLOBAL g, PCSZ wrapper); - int Open(PJPARM sop); - int Rewind(PCSZ sql); - void Close(void); - PQRYRES AllocateResult(PGLOBAL g); + virtual void AddJars(PSTRG jpop, char sep); + PQRYRES AllocateResult(PGLOBAL g, PTDB tdbp); // Attributes public: - char *GetQuoteChar(void) { return m_IDQuoteChar; } - // Database successfully opened? - bool IsOpen(void) { return m_Opened; } -//PSZ GetStringInfo(ushort infotype); - int GetMaxValue(int infotype); -//PSZ GetConnect(void) { return m_Connect; } + char *GetQuoteChar(void) { return m_IDQuoteChar; } + virtual int GetMaxValue(int infotype); public: // Operations - //void SetLoginTimeout(DWORD sec) {m_LoginTimeout = sec;} - //void SetQueryTimeout(DWORD sec) {m_QueryTimeout = sec;} - //void SetUserName(PSZ user) {m_User = user;} - //void SetUserPwd(PSZ pwd) {m_Pwd = pwd;} - int GetResultSize(PCSZ sql, JDBCCOL *colp); - int ExecuteQuery(PCSZ sql); - int ExecuteUpdate(PCSZ sql); - int Fetch(int pos = 0); + virtual bool Connect(PJPARM sop); + virtual bool MakeCursor(PGLOBAL g, PTDB tdbp, PCSZ options, + PCSZ filter, bool pipe) {return true;} + virtual int GetResultSize(PCSZ sql, PCOL colp); + virtual int ExecuteCommand(PCSZ sql); + virtual int ExecuteQuery(PCSZ sql); + virtual int ExecuteUpdate(PCSZ sql); + virtual int Fetch(int pos = 0); + virtual void SetColumnValue(int rank, PSZ name, PVAL val); + + // Jdbc operations bool PrepareSQL(PCSZ sql); - int ExecuteSQL(void); + int ExecuteSQL(void); // Prepared statement bool SetParam(JDBCCOL *colp); - int ExecSQLcommand(PCSZ sql); - void SetColumnValue(int rank, PSZ name, PVAL val); int GetCatInfo(JCATPARM *cap); - //bool GetDataSources(PQRYRES qrp); bool GetDrivers(PQRYRES qrp); PQRYRES GetMetaData(PGLOBAL g, PCSZ src); - -public: - // Set static variables - static void SetJVM(void) { - LibJvm = NULL; - CreateJavaVM = NULL; - GetCreatedJavaVMs = NULL; -#if defined(_DEBUG) - GetDefaultJavaVMInitArgs = NULL; -#endif // _DEBUG - } // end of SetJVM - - static void ResetJVM(void); - static bool GetJVM(PGLOBAL g); + int Rewind(PCSZ sql); // Implementation public: //virtual ~JDBConn(); - // JDBC operations -protected: - bool gmID(PGLOBAL g, jmethodID& mid, const char *name, const char *sig); - bool Check(jint rc = 0); -//void ThrowDJX(int rc, PSZ msg/*, HSTMT hstmt = SQL_NULL_HSTMT*/); -//void ThrowDJX(PSZ msg); -//void Free(void); - protected: // Members -#if defined(__WIN__) - static HANDLE LibJvm; // Handle to the jvm DLL -#else // !__WIN__ - static void *LibJvm; // Handle for the jvm shared library -#endif // !__WIN__ - static CRTJVM CreateJavaVM; - static GETJVM GetCreatedJavaVMs; -#if defined(_DEBUG) - static GETDEF GetDefaultJavaVMInitArgs; -#endif // _DEBUG - PGLOBAL m_G; - TDBJDBC *m_Tdb; - JavaVM *jvm; // Pointer to the JVM (Java Virtual Machine) - JNIEnv *env; // Pointer to native interface - jclass jdi; // Pointer to the java wrapper class - jobject job; // The java wrapper class object - jmethodID xqid; // The ExecuteQuery method ID - jmethodID xuid; // The ExecuteUpdate method ID - jmethodID xid; // The Execute method ID - jmethodID grs; // The GetResult method ID - jmethodID readid; // The ReadNext method ID - jmethodID fetchid; // The Fetch method ID - jmethodID typid; // The ColumnType method ID - jmethodID prepid; // The CreatePrepStmt method ID - jmethodID xpid; // The ExecutePrep method ID - jmethodID pcid; // The ClosePrepStmt method ID - jmethodID errid; // The GetErrmsg method ID - jmethodID objfldid; // The ObjectField method ID - jmethodID chrfldid; // The StringField method ID - jmethodID intfldid; // The IntField method ID - jmethodID dblfldid; // The DoubleField method ID - jmethodID fltfldid; // The FloatField method ID - jmethodID datfldid; // The DateField method ID - jmethodID timfldid; // The TimeField method ID - jmethodID tspfldid; // The TimestampField method ID - jmethodID bigfldid; // The BigintField method ID - PCSZ Msg; - char *m_Wrap; +#if 0 + JavaVM *jvm; // Pointer to the JVM (Java Virtual Machine) + JNIEnv *env; // Pointer to native interface + jclass jdi; // Pointer to the java wrapper class + jobject job; // The java wrapper class object + jmethodID errid; // The GetErrmsg method ID +#endif // 0 + jmethodID xqid; // The ExecuteQuery method ID + jmethodID xuid; // The ExecuteUpdate method ID + jmethodID xid; // The Execute method ID + jmethodID grs; // The GetResult method ID + jmethodID readid; // The ReadNext method ID + jmethodID fetchid; // The Fetch method ID + jmethodID typid; // The ColumnType method ID + jmethodID prepid; // The CreatePrepStmt method ID + jmethodID xpid; // The ExecutePrep method ID + jmethodID pcid; // The ClosePrepStmt method ID + jmethodID objfldid; // The ObjectField method ID + jmethodID chrfldid; // The StringField method ID + jmethodID intfldid; // The IntField method ID + jmethodID dblfldid; // The DoubleField method ID + jmethodID fltfldid; // The FloatField method ID + jmethodID datfldid; // The DateField method ID + jmethodID timfldid; // The TimeField method ID + jmethodID tspfldid; // The TimestampField method ID + jmethodID bigfldid; // The BigintField method ID +// PCSZ Msg; +// PCSZ m_Wrap; char m_IDQuoteChar[2]; PCSZ m_Pwd; int m_Ncol; int m_Aff; - int m_Rows; int m_Fetch; int m_RowsetSize; jboolean m_Updatable; jboolean m_Transact; jboolean m_Scrollable; - bool m_Opened; bool m_Full; }; // end of JDBConn class definition |