com_firstworks_sqlrelay_sqlrcursor.c

适合于Unix/Linux下的一个持久数据库连接池

// Copyright (c) 2001  David Muse
// See the file COPYING for more information.

#ifdef __CYGWIN__
	#include <windows.h>
#endif

#include <sqlrelay/sqlrclient.h>
#include <com_firstworks_sqlrelay_SQLRCursor.h>
#include <config.h>

#ifdef __cplusplus
extern "C" {
#endif

char	*curGetStringUTFChars(JNIEnv *env, jstring string, jboolean *modifier) {
	if (string) {
		return (char *)env->GetStringUTFChars(string,modifier);
	}
	return (char *)NULL;
}

void	curReleaseStringUTFChars(JNIEnv *env, jstring string, char *chararray) {
	if (string && chararray) {
		env->ReleaseStringUTFChars(string,chararray);
	}
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    alloc
 * Signature: (LSQLRConnection;)V
 */
JNIEXPORT jlong JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_alloc
  (JNIEnv *env, jobject self, jlong con) {
	sqlrcursor	*cur=new sqlrcursor((sqlrconnection *)con);
	cur->copyReferences();
	return (jlong)cur;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    delete
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_delete
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	delete cur;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    setResultSetBufferSize
 * Signature: (J)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_setResultSetBufferSize
  (JNIEnv *env, jobject self, jlong rows) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->setResultSetBufferSize((uint64_t)rows);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    getResultSetBufferSize
 * Signature: ()J
 */
JNIEXPORT jlong JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_getResultSetBufferSize
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	return (jlong)cur->getResultSetBufferSize();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    dontGetColumnInfo
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_dontGetColumnInfo
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->dontGetColumnInfo();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    getColumnInfo
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_getColumnInfo
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->getColumnInfo();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    mixedCaseColumnNames
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_mixedCaseColumnNames
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->mixedCaseColumnNames();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    upperCaseColumnNames
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_upperCaseColumnNames
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->upperCaseColumnNames();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    lowerCaseColumnNames
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_lowerCaseColumnNames
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->lowerCaseColumnNames();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    cacheToFile
 * Signature: (Ljava/lang/String;)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_cacheToFile
  (JNIEnv *env, jobject self, jstring filename) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*filenamestring=curGetStringUTFChars(env,filename,0);
	cur->cacheToFile(filenamestring);
	curReleaseStringUTFChars(env,filename,filenamestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    setCacheTtl
 * Signature: (I)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_setCacheTtl
  (JNIEnv *env, jobject self, jint ttl) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->setCacheTtl((uint32_t)ttl);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    getCacheFileName
 * Signature: ()Ljava/lang/String;
 */
JNIEXPORT jstring JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_getCacheFileName
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	return env->NewStringUTF(cur->getCacheFileName());
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    cacheOff
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_cacheOff
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->cacheOff();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    sendQuery
 * Signature: (Ljava/lang/String;)Z
 */
JNIEXPORT jboolean JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_sendQuery__Ljava_lang_String_2
  (JNIEnv *env, jobject self, jstring query) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*querystring=curGetStringUTFChars(env,query,0);
	jboolean	retval=
		(cur->sendQuery(querystring))?JNI_TRUE:JNI_FALSE;
	curReleaseStringUTFChars(env,query,querystring);
	return retval;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    sendQuery
 * Signature: (Ljava/lang/String;I)Z
 */
JNIEXPORT jboolean JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_sendQuery__Ljava_lang_String_2I
  (JNIEnv *env, jobject self, jstring query, jint length) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*querystring=curGetStringUTFChars(env,query,0);
	jboolean	retval=
		(cur->sendQuery(querystring,(uint32_t)length))?
						JNI_TRUE:JNI_FALSE;
	curReleaseStringUTFChars(env,query,querystring);
	return retval;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    sendFileQuery
 * Signature: (Ljava/lang/String;Ljava/lang/String;)Z
 */
JNIEXPORT jboolean JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_sendFileQuery
  (JNIEnv *env, jobject self, jstring path, jstring filename) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*pathstring=curGetStringUTFChars(env,path,0);
	char	*filenamestring=curGetStringUTFChars(env,filename,0);
	jboolean	retval=
		(cur->sendFileQuery(pathstring,filenamestring))?
						JNI_TRUE:JNI_FALSE;
	curReleaseStringUTFChars(env,path,pathstring);
	curReleaseStringUTFChars(env,filename,filenamestring);
	return retval;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    prepareQuery
 * Signature: (Ljava/lang/String;)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_prepareQuery__Ljava_lang_String_2
  (JNIEnv *env, jobject self, jstring query) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*querystring=curGetStringUTFChars(env,query,0);
	cur->prepareQuery(querystring);
	curReleaseStringUTFChars(env,query,querystring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    prepareQuery
 * Signature: (Ljava/lang/String;I)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_prepareQuery__Ljava_lang_String_2I
  (JNIEnv *env, jobject self, jstring query, jint length) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*querystring=curGetStringUTFChars(env,query,0);
	cur->prepareQuery(querystring,(uint32_t)length);
	curReleaseStringUTFChars(env,query,querystring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    prepareFileQuery
 * Signature: (Ljava/lang/String;Ljava/lang/String;)Z
 */
JNIEXPORT jboolean JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_prepareFileQuery
  (JNIEnv *env, jobject self, jstring path, jstring filename) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*pathstring=curGetStringUTFChars(env,path,0);
	char	*filenamestring=curGetStringUTFChars(env,filename,0);
	jboolean	retval=
		(cur->prepareFileQuery(pathstring,filenamestring))?
							JNI_TRUE:JNI_FALSE;
	curReleaseStringUTFChars(env,path,pathstring);
	curReleaseStringUTFChars(env,filename,filenamestring);
	return retval;
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    clearBinds
 * Signature: ()V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_clearBinds
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	cur->clearBinds();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    substitution
 * Signature: (Ljava/lang/String;Ljava/lang/String;)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_substitution__Ljava_lang_String_2Ljava_lang_String_2
  (JNIEnv *env, jobject self, jstring variable, jstring value) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	char	*valuestring=curGetStringUTFChars(env,value,0);
	cur->substitution(variablestring,valuestring);
	curReleaseStringUTFChars(env,variable,variablestring);
	curReleaseStringUTFChars(env,value,valuestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    substitution
 * Signature: (Ljava/lang/String;J)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_substitution__Ljava_lang_String_2J
  (JNIEnv *env, jobject self, jstring variable, jlong value) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	cur->substitution(variablestring,(int64_t)value);
	curReleaseStringUTFChars(env,variable,variablestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    substitution
 * Signature: (Ljava/lang/String;DII)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_substitution__Ljava_lang_String_2DII
  (JNIEnv *env, jobject self, jstring variable, jdouble value, jint precision, jint scale) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	cur->substitution(variablestring,(double)value,
				(uint32_t)precision,
				(uint32_t)scale);
	curReleaseStringUTFChars(env,variable,variablestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    countBindVariables
 * Signature: ()S
 */
JNIEXPORT jshort JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_countBindVariables
  (JNIEnv *env, jobject self) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	return (jshort)cur->countBindVariables();
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    inputBind
 * Signature: (Ljava/lang/String;Ljava/lang/String;)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_inputBind__Ljava_lang_String_2Ljava_lang_String_2
  (JNIEnv *env, jobject self, jstring variable, jstring value) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	char	*valuestring=curGetStringUTFChars(env,value,0);
	cur->inputBind(variablestring,valuestring);
	curReleaseStringUTFChars(env,variable,variablestring);
	curReleaseStringUTFChars(env,value,valuestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    inputBind
 * Signature: (Ljava/lang/String;J)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_inputBind__Ljava_lang_String_2J
  (JNIEnv *env, jobject self, jstring variable, jlong value) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	cur->inputBind(variablestring,(int64_t)value);
	curReleaseStringUTFChars(env,variable,variablestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    inputBind
 * Signature: (Ljava/lang/String;DII)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_inputBind__Ljava_lang_String_2DII
  (JNIEnv *env, jobject self, jstring variable, jdouble value, jint precision, jint scale) {
	jclass		cls=env->GetObjectClass(self);
	sqlrcursor	*cur=(sqlrcursor *)env->GetIntField(self,
				env->GetFieldID(cls,"cursor","J"));
	char	*variablestring=curGetStringUTFChars(env,variable,0);
	cur->inputBind(variablestring,(double)value,
				(uint32_t)precision,
				(uint32_t)scale);
	curReleaseStringUTFChars(env,variable,variablestring);
}

/*
 * Class:     com_firstworks_sqlrelay_SQLRCursor
 * Method:    inputBindBlob
 * Signature: (Ljava/lang/String;[BJ)V
 */
JNIEXPORT void JNICALL Java_com_firstworks_sqlrelay_SQLRCursor_inputBindBlob
  (JNIEnv *env, jobject self, jstring variable, jbyteArray value, jlong size) {