2
0

sq_sqlite3.cpp 61 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091
  1. /* Code generated by script */
  2. #include "squirrel.h"
  3. #include "sqlite3.h"
  4. #include <string.h>
  5. #include <stdio.h>
  6. #include "sqstdblobimpl.h"
  7. typedef struct sq_sqlite3_sdb sq_sqlite3_sdb;
  8. typedef struct sq_sqlite3_sdb_func sq_sqlite3_sdb_func;
  9. /* to use as C user data so i know what function sqlite is calling */
  10. struct sq_sqlite3_sdb_func {
  11. /* references to associated lua values */
  12. HSQOBJECT fn_step;
  13. HSQOBJECT fn_finalize;
  14. HSQOBJECT udata;
  15. sq_sqlite3_sdb *sdb;
  16. sq_sqlite3_sdb_func *next;
  17. };
  18. /* information about database */
  19. struct sq_sqlite3_sdb {
  20. /* associated squirrel vm */
  21. HSQUIRRELVM v;
  22. /* sqlite database handle */
  23. sqlite3 *db;
  24. /* sql functions stack usage */
  25. sq_sqlite3_sdb_func *func; /* top SQL function being called */
  26. /* references */
  27. HSQOBJECT busy_cb; /* busy callback */
  28. HSQOBJECT busy_udata;
  29. HSQOBJECT progress_cb; /* progress handler */
  30. HSQOBJECT progress_udata;
  31. HSQOBJECT trace_cb; /* trace callback */
  32. HSQOBJECT trace_udata;
  33. HSQOBJECT null_value;
  34. };
  35. SQ_OPT_STRING_STRLEN();
  36. static const SQChar *SQLite3_TAG = "SQLite3";
  37. static const SQChar *SQLite3_Stmt_TAG = "SQLite3Stmt";
  38. static const SQChar sqlite3_NULL_Name[] = _SC("sqlite3_NULL");
  39. static const SQChar nullName[] = _SC("Null");
  40. static SQRESULT sqlite3_NULL_tostring(HSQUIRRELVM v){
  41. sq_pushstring(v, "", 0);
  42. return 1;
  43. }
  44. SQRegFunction sqlite3_NULL_methods[]={
  45. {_SC("_tostring"),sqlite3_NULL_tostring,1, _SC(".")},
  46. {0,0}
  47. };
  48. static SQRESULT get_sqlite3_instance(HSQUIRRELVM v, SQInteger idx, sq_sqlite3_sdb **sdb){
  49. SQRESULT _rc_;
  50. if((_rc_ = sq_getinstanceup(v,idx,(SQUserPointer*)sdb,(void*)SQLite3_TAG)) < 0) return _rc_;
  51. if(!*sdb) return sq_throwerror(v, _SC("database is closed"));
  52. return _rc_;
  53. }
  54. static SQRESULT get_sqlite3_stmt_instance(HSQUIRRELVM v, SQInteger idx, sqlite3_stmt **stmt){
  55. SQRESULT _rc_;
  56. if((_rc_ = sq_getinstanceup(v,idx,(SQUserPointer*)stmt,(void*)SQLite3_Stmt_TAG)) < 0) return _rc_;
  57. if(!*stmt) return sq_throwerror(v, _SC("statement is closed"));
  58. return _rc_;
  59. }
  60. //#define push_sqlite3_null(v) sq_getonregistrytable(v, sqlite3_NULL_Name, sizeof(sqlite3_NULL_Name)-1);
  61. //#define push_sqlite3_null(v) sq_pushobject(v, sqlite3_NULL);
  62. //#define push_sqlite3_null(v) sq_getbyname(v, 1, nullName, sizeof(nullName)-1)
  63. //#define push_sqlite3_null(v) sq_pushfromregistrytable(v, nullName, sizeof(nullName)-1)
  64. //#define push_sqlite3_null(v) {sq_pushregistrytable(v);sq_pushstring(v, sqlite3_NULL_Name, sizeof(sqlite3_NULL_Name)-1);sq_get(v, -2);sq_remove(v,-2);}
  65. //the line bellow is the fastest one, any other attempt till now was slower
  66. #define push_sqlite3_null(v) {sq_pushstring(v, nullName, sizeof(nullName)-1);sq_get(v, 1);}
  67. #define GET_sqlite3_INSTANCE_AT(idx) \
  68. sq_sqlite3_sdb *sdb=NULL; \
  69. if((_rc_ = get_sqlite3_instance(v,idx,&sdb)) < 0) return _rc_;\
  70. sqlite3 *self = sdb->db;
  71. #define GET_sqlite3_INSTANCE() GET_sqlite3_INSTANCE_AT(1)
  72. //#define GET_sqlite3_INSTANCE() SQ_GET_INSTANCE(v, 1, sqlite3, SQLite3_TAG)
  73. #define GET_sqlite3_stmt_INSTANCE() \
  74. sqlite3_stmt *self=NULL; \
  75. if((_rc_ = get_sqlite3_stmt_instance(v,1,&self)) < 0) return _rc_;
  76. enum e_type_result {tr_first_row_first_col, tr_first_row, tr_all_rows, tr_ddml};
  77. #define AS_STRING_ALWAYS 0x01
  78. #define NULL_AS_EMPTY_STR 0x02
  79. static void sqlite3_stmt_push_string(HSQUIRRELVM v, sqlite3_stmt *stmt, int col, int flags){
  80. const char *value = (const char*) sqlite3_column_text(stmt, col);
  81. if(value) sq_pushstring(v, value, sqlite3_column_bytes(stmt, col));
  82. else push_sqlite3_null(v);
  83. }
  84. static SQRESULT sqlite3_stmt_push_value(HSQUIRRELVM v, sqlite3_stmt *stmt, int col, int flags){
  85. const char *value;
  86. if(flags & AS_STRING_ALWAYS) sqlite3_stmt_push_string(v, stmt, col, flags);
  87. else
  88. {
  89. switch (sqlite3_column_type(stmt, col)) {
  90. case SQLITE_INTEGER:
  91. {
  92. sqlite_int64 i64 = sqlite3_column_int64(stmt, col);
  93. SQInteger n = (SQInteger)i64;
  94. if (n == i64)
  95. sq_pushinteger(v, n);
  96. else
  97. sq_pushstring(v, (const char*) sqlite3_column_text(stmt, col), sqlite3_column_bytes(stmt, col));
  98. }
  99. break;
  100. case SQLITE_FLOAT:
  101. sq_pushfloat(v, sqlite3_column_double(stmt, col));
  102. break;
  103. case SQLITE_TEXT:
  104. sqlite3_stmt_push_string(v, stmt, col, flags);
  105. break;
  106. case SQLITE_BLOB:
  107. value = (const char*) sqlite3_column_blob(stmt, col);
  108. if(value) sq_pushstring(v, value, sqlite3_column_bytes(stmt, col));
  109. else push_sqlite3_null(v);
  110. break;
  111. case SQLITE_NULL:
  112. push_sqlite3_null(v);
  113. break;
  114. default:
  115. push_sqlite3_null(v);
  116. break;
  117. }
  118. }
  119. return 1;
  120. }
  121. static void sqlite3_stmt_row_asArray(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags){
  122. int col_count = sqlite3_column_count(stmt);
  123. sq_newarray(v, col_count);
  124. for(int i=0; i<col_count; ++i){
  125. sq_pushinteger(v, i);
  126. sqlite3_stmt_push_value(v, stmt, i, flags);
  127. sq_rawset(v, -3);
  128. }
  129. }
  130. static void sqlite3_stmt_row_asTable(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags){
  131. int col_count = sqlite3_column_count(stmt);
  132. sq_newtable(v);
  133. for(int i=0; i<col_count; ++i){
  134. sq_pushstring(v, sqlite3_column_name(stmt, i), -1);
  135. sqlite3_stmt_push_value(v, stmt, i, flags);
  136. sq_rawset(v, -3);
  137. }
  138. }
  139. static void sqlite3_stmt_asArrayOfArrays(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags){
  140. sq_newarray(v, 0);
  141. while(sqlite3_step(stmt) == SQLITE_ROW){
  142. sqlite3_stmt_row_asArray(v, stmt, flags);
  143. sq_arrayappend(v, -2);
  144. }
  145. }
  146. static void sqlite3_stmt_asArrayOfTables(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags){
  147. sq_newarray(v, 0);
  148. while(sqlite3_step(stmt) == SQLITE_ROW){
  149. sqlite3_stmt_row_asTable(v, stmt, flags);
  150. sq_arrayappend(v, -2);
  151. }
  152. }
  153. static SQRESULT sqlite3_stmt_bind_value(HSQUIRRELVM v, sqlite3_stmt *stmt, int npar, int argn){
  154. int _rc_ = 0;
  155. SQObjectType ptype = sq_gettype(v, argn);
  156. switch(ptype){
  157. case OT_BOOL:
  158. SQ_GET_BOOL(v, argn, param_bool);
  159. _rc_ = sqlite3_bind_int(stmt, npar, param_bool == SQTrue ? 1 : 0);
  160. break;
  161. case OT_INTEGER:
  162. SQ_GET_INTEGER(v, argn, param_integer);
  163. _rc_ = sqlite3_bind_int64(stmt, npar, param_integer);
  164. break;
  165. case OT_FLOAT:
  166. SQ_GET_FLOAT(v, argn, param_float);
  167. _rc_ = sqlite3_bind_double(stmt, npar, param_float);
  168. break;
  169. case OT_STRING:{
  170. SQ_GET_STRING(v, argn, param_string);
  171. _rc_ = sqlite3_bind_text(stmt, npar, param_string, param_string_size, SQLITE_TRANSIENT);
  172. }
  173. break;
  174. case OT_NULL:
  175. _rc_ = sqlite3_bind_null(stmt, npar);
  176. break;
  177. default:
  178. return sq_throwerror(v, "Invalid bind parameter %d", npar);
  179. }
  180. if(_rc_ != SQLITE_OK) {
  181. sqlite3 *db = sqlite3_db_handle(stmt);
  182. return sq_throwerror(v, sqlite3_errmsg(db));
  183. }
  184. return SQ_OK;
  185. }
  186. static SQRESULT sq_sqlite3_stmt_prepare_aux(HSQUIRRELVM v, sqlite3 *db, sqlite3_stmt **stmt, int params_start){
  187. SQ_FUNC_VARS(v);
  188. SQ_GET_STRING(v, params_start, szSQL);
  189. const char* szTail=0;
  190. if(sqlite3_prepare_v2(db, szSQL, szSQL_size, stmt, &szTail) != SQLITE_OK)
  191. {
  192. return sq_throwerror(v, sqlite3_errmsg(db));
  193. }
  194. if(_top_ > params_start){
  195. int nparams = sqlite3_bind_parameter_count(*stmt);
  196. int nparams_given = _top_-params_start;
  197. if(nparams != nparams_given){
  198. return sq_throwerror(v, "expect %d parameters but only %d given", nparams, nparams_given);
  199. }
  200. for(int i=1; i <= nparams; ++i){
  201. int argn = i+params_start;
  202. _rc_ = sqlite3_stmt_bind_value(v, *stmt, i, argn);
  203. if(_rc_ < 0) return _rc_;
  204. }
  205. }
  206. return SQ_OK;
  207. }
  208. static SQRESULT sq_sqlite3_stmt_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  209. {
  210. sqlite3_stmt *stmt = ((sqlite3_stmt *)p);
  211. if(stmt) sqlite3_finalize(stmt);
  212. return 0;
  213. }
  214. static SQRESULT sq_sqlite3_stmt_constructor(HSQUIRRELVM v)
  215. {
  216. SQ_FUNC_VARS(v);
  217. _rc_ = SQ_ERROR;
  218. GET_sqlite3_INSTANCE_AT(2);
  219. sqlite3_stmt *stmt = 0;
  220. if(_top_ > 2){
  221. _rc_ = sq_sqlite3_stmt_prepare_aux(v, self, &stmt, 3);
  222. }
  223. else
  224. {
  225. const char* szTail=0;
  226. if(sqlite3_prepare_v2(self, "select 'statement not prepared';", -1, &stmt, &szTail) != SQLITE_OK)
  227. {
  228. _rc_ = sq_throwerror(v, sqlite3_errmsg(self));
  229. }
  230. else _rc_ = SQ_OK;
  231. }
  232. sq_setinstanceup(v, 1, stmt); //replace self for this instance with this new sqlite3_stmt
  233. sq_setreleasehook(v,1, sq_sqlite3_stmt_releasehook);
  234. return _rc_;
  235. }
  236. static SQRESULT sq_sqlite3_stmt_get_db(HSQUIRRELVM v){
  237. SQ_FUNC_VARS_NO_TOP(v);
  238. GET_sqlite3_stmt_INSTANCE();
  239. sqlite3 *db = sqlite3_db_handle(self);
  240. sq_pushuserpointer(v, db);
  241. if(sq_getonregistrytable(v) == SQ_OK){
  242. sq_getweakrefval(v, -1);
  243. }
  244. else return sq_throwerror(v, _SC("could not retrive database, maybe it was already closed"));
  245. return 1;
  246. }
  247. static SQRESULT sq_sqlite3_stmt_stmt_ptr(HSQUIRRELVM v){
  248. SQ_FUNC_VARS_NO_TOP(v);
  249. GET_sqlite3_stmt_INSTANCE();
  250. sq_pushuserpointer(v, self);
  251. return 1;
  252. }
  253. static SQRESULT sq_sqlite3_stmt_finalize(HSQUIRRELVM v){
  254. SQ_FUNC_VARS_NO_TOP(v);
  255. GET_sqlite3_stmt_INSTANCE();
  256. if(sqlite3_finalize(self) == SQLITE_OK){
  257. sq_setinstanceup(v, 1, 0); //next calls will fail with "statement is closed"
  258. }
  259. else {
  260. sqlite3 *db = sqlite3_db_handle(self);
  261. return sq_throwerror(v, sqlite3_errmsg(db));
  262. }
  263. return 0;
  264. }
  265. static SQRESULT sq_sqlite3_stmt_prepare(HSQUIRRELVM v){
  266. SQ_FUNC_VARS_NO_TOP(v);
  267. GET_sqlite3_stmt_INSTANCE();
  268. sqlite3 *db = sqlite3_db_handle(self);
  269. sqlite3_stmt *stmt = 0;
  270. _rc_ = sq_sqlite3_stmt_prepare_aux(v, db, &stmt, 2);
  271. if(stmt){
  272. sqlite3_finalize(self); //finalize the previous sqlite3_stmt
  273. sq_setinstanceup(v, 1, stmt); //replace self for this instance with this new sqlite3_stmt
  274. }
  275. return _rc_;
  276. }
  277. static SQRESULT sq_sqlite3_stmt_get_sql(HSQUIRRELVM v){
  278. SQ_FUNC_VARS_NO_TOP(v);
  279. GET_sqlite3_stmt_INSTANCE();
  280. sq_pushstring(v, sqlite3_sql(self), -1);
  281. return 1;
  282. }
  283. static SQRESULT sq_sqlite3_stmt_bind(HSQUIRRELVM v){
  284. SQ_FUNC_VARS_NO_TOP(v);
  285. GET_sqlite3_stmt_INSTANCE();
  286. SQ_GET_INTEGER(v, 2, npar);
  287. return sqlite3_stmt_bind_value(v, self, npar, 3);
  288. }
  289. static SQRESULT sq_sqlite3_stmt_bind_empty_null(HSQUIRRELVM v){
  290. SQ_FUNC_VARS_NO_TOP(v);
  291. GET_sqlite3_stmt_INSTANCE();
  292. SQ_GET_INTEGER(v, 2, npar);
  293. if(sq_gettype(v, 3) == OT_STRING && sq_getsize(v, 3) == 0){
  294. sq_pushnull(v);
  295. sq_replace(v, 3);
  296. }
  297. return sqlite3_stmt_bind_value(v, self, npar, 3);
  298. }
  299. static SQRESULT sq_sqlite3_stmt_bind_blob(HSQUIRRELVM v){
  300. SQ_FUNC_VARS_NO_TOP(v);
  301. GET_sqlite3_stmt_INSTANCE();
  302. SQ_GET_INTEGER(v, 2, npar);
  303. SQ_GET_STRING(v, 3, blob);
  304. if(sqlite3_bind_blob(self, npar, blob, blob_size, SQLITE_TRANSIENT) != SQLITE_OK) {
  305. sqlite3 *db = sqlite3_db_handle(self);
  306. return sq_throwerror(v, sqlite3_errmsg(db));
  307. }
  308. return SQ_OK;
  309. }
  310. static SQRESULT sq_sqlite3_stmt_bind_values(HSQUIRRELVM v){
  311. SQ_FUNC_VARS(v);
  312. GET_sqlite3_stmt_INSTANCE();
  313. if (_top_ - 1 != sqlite3_bind_parameter_count(self))
  314. return sq_throwerror(v,
  315. _SC("incorrect number of parameters to bind (%d given, %d to bind)"),
  316. _top_ - 1,
  317. sqlite3_bind_parameter_count(self));
  318. for (int n = 2; n <= _top_; ++n) {
  319. if (sqlite3_stmt_bind_value(v, self, n-1, n) != SQ_OK) return SQ_ERROR;
  320. }
  321. return 0;
  322. }
  323. static SQRESULT sq_sqlite3_stmt_bind_names(HSQUIRRELVM v){
  324. SQ_FUNC_VARS_NO_TOP(v);
  325. GET_sqlite3_stmt_INSTANCE();
  326. SQObjectType ptype = sq_gettype(v, 2);
  327. int count = sqlite3_bind_parameter_count(self);
  328. int result;
  329. for (int n = 1; n <= count; ++n) {
  330. const char *name = sqlite3_bind_parameter_name(self, n);
  331. if (name && (name[0] == ':' || name[0] == '$' || name[0] == '@')) {
  332. if(ptype == OT_TABLE){
  333. sq_pushstring(v, ++name, -1);
  334. if(sq_get(v, 2) == SQ_OK){
  335. result = sqlite3_stmt_bind_value(v, self, n, -1);
  336. sq_poptop(v);
  337. }
  338. else return sq_throwerror(v, _SC("bind parameter (%s) not found"), name);
  339. }
  340. else return sq_throwerror(v, _SC("table expected to bind named parameters"));
  341. }
  342. else {
  343. if(ptype == OT_ARRAY){
  344. sq_pushinteger(v, n);
  345. if(sq_get(v, 2) == SQ_OK){
  346. result = sqlite3_stmt_bind_value(v, self, n, -1);
  347. sq_poptop(v);
  348. }
  349. else return sq_throwerror(v, _SC("bind parameter (%d) not found"), n);
  350. }
  351. else return sq_throwerror(v, _SC("array expected to bind numbered parameters"));
  352. }
  353. if (result != SQ_OK) return result;
  354. }
  355. return 0;
  356. }
  357. static SQRESULT sq_sqlite3_stmt_bind_parameter_index(HSQUIRRELVM v){
  358. SQ_FUNC_VARS_NO_TOP(v);
  359. GET_sqlite3_stmt_INSTANCE();
  360. SQ_GET_STRING(v, 2, spar);
  361. sq_pushinteger(v, sqlite3_bind_parameter_index(self, spar));
  362. return 1;
  363. }
  364. static SQRESULT sq_sqlite3_stmt_reset(HSQUIRRELVM v){
  365. SQ_FUNC_VARS_NO_TOP(v);
  366. GET_sqlite3_stmt_INSTANCE();
  367. sq_pushinteger(v, sqlite3_reset(self));
  368. return 1;
  369. }
  370. static SQRESULT sq_sqlite3_stmt_step(HSQUIRRELVM v){
  371. SQ_FUNC_VARS_NO_TOP(v);
  372. GET_sqlite3_stmt_INSTANCE();
  373. sq_pushinteger(v, sqlite3_step(self));
  374. return 1;
  375. }
  376. static SQRESULT sq_sqlite3_stmt_next_row(HSQUIRRELVM v){
  377. SQ_FUNC_VARS_NO_TOP(v);
  378. GET_sqlite3_stmt_INSTANCE();
  379. sq_pushbool(v, sqlite3_step(self) == SQLITE_ROW);
  380. return 1;
  381. }
  382. static SQRESULT sq_sqlite3_stmt_col_count(HSQUIRRELVM v){
  383. SQ_FUNC_VARS_NO_TOP(v);
  384. GET_sqlite3_stmt_INSTANCE();
  385. sq_pushinteger(v, sqlite3_column_count(self));
  386. return 1;
  387. }
  388. static SQRESULT sq_sqlite3_stmt_colsAsArray(HSQUIRRELVM v){
  389. SQ_FUNC_VARS_NO_TOP(v);
  390. GET_sqlite3_stmt_INSTANCE();
  391. int col_count = sqlite3_column_count(self);
  392. sq_newarray(v, col_count);
  393. for(int i=0; i<col_count; ++i){
  394. sq_pushinteger(v, i);
  395. sq_pushstring(v, sqlite3_column_name(self, i), -1);
  396. sq_rawset(v, -3);
  397. }
  398. return 1;
  399. }
  400. static SQRESULT sq_sqlite3_stmt_colsAsTable(HSQUIRRELVM v){
  401. SQ_FUNC_VARS_NO_TOP(v);
  402. GET_sqlite3_stmt_INSTANCE();
  403. int col_count = sqlite3_column_count(self);
  404. sq_newtable(v);
  405. for(int i=0; i<col_count; ++i){
  406. sq_pushstring(v, sqlite3_column_name(self, i), -1);
  407. sq_pushinteger(v, i);
  408. sq_rawset(v, -3);
  409. }
  410. return 1;
  411. }
  412. static SQRESULT sq_sqlite3_stmt_col_name(HSQUIRRELVM v){
  413. SQ_FUNC_VARS_NO_TOP(v);
  414. GET_sqlite3_stmt_INSTANCE();
  415. SQ_GET_INTEGER(v, 2, col);
  416. sq_pushstring(v, sqlite3_column_name(self, col), -1);
  417. return 1;
  418. }
  419. static SQRESULT sq_sqlite3_stmt_col_type(HSQUIRRELVM v){
  420. SQ_FUNC_VARS_NO_TOP(v);
  421. GET_sqlite3_stmt_INSTANCE();
  422. SQ_GET_INTEGER(v, 2, col);
  423. sq_pushinteger(v, sqlite3_column_type(self, col));
  424. return 1;
  425. }
  426. static SQRESULT sq_sqlite3_stmt_col_declared_type(HSQUIRRELVM v){
  427. SQ_FUNC_VARS_NO_TOP(v);
  428. GET_sqlite3_stmt_INSTANCE();
  429. SQ_GET_INTEGER(v, 2, col);
  430. sq_pushstring(v, sqlite3_column_decltype(self, col), -1);
  431. return 1;
  432. }
  433. static int get_col_index(HSQUIRRELVM v, sqlite3_stmt *self){
  434. SQInteger _rc_, col;
  435. switch(sq_gettype(v, 2)){
  436. case OT_INTEGER:
  437. sq_getinteger(v, 2, &col);
  438. break;
  439. case OT_STRING:{
  440. SQ_GET_STRING(v, 2, col_name);
  441. if(col_name_size == 0) return sq_throwerror(v, "column name can not be empty");
  442. col = -1;
  443. for(int i=0, len=sqlite3_column_count(self); i<len; ++i){
  444. if(strcasecmp(col_name, sqlite3_column_name(self, i)) == 0){
  445. col = i;
  446. break;
  447. }
  448. }
  449. if(col == -1) return sq_throwerror(v, "column name not found \"%s\"", col_name);
  450. }
  451. break;
  452. default:
  453. return sq_throwerror(v, "wrong parameter expected integer|string");
  454. }
  455. return col;
  456. }
  457. static SQRESULT sq_sqlite3_stmt_col(HSQUIRRELVM v){
  458. SQ_FUNC_VARS_NO_TOP(v);
  459. GET_sqlite3_stmt_INSTANCE();
  460. int col = get_col_index(v, self);
  461. if(col < 0) return col;
  462. sqlite3_stmt_push_value(v, self, col, 0);
  463. return 1;
  464. }
  465. static SQRESULT sq_sqlite3_stmt_asBool(HSQUIRRELVM v){
  466. SQ_FUNC_VARS_NO_TOP(v);
  467. GET_sqlite3_stmt_INSTANCE();
  468. int col = get_col_index(v, self);
  469. if(col < 0) return col;
  470. const unsigned char *b = sqlite3_column_text(self, col);
  471. sq_pushbool(v, b && *b == '1');
  472. return 1;
  473. }
  474. static SQRESULT sq_sqlite3_stmt_asInteger(HSQUIRRELVM v){
  475. SQ_FUNC_VARS_NO_TOP(v);
  476. GET_sqlite3_stmt_INSTANCE();
  477. int col = get_col_index(v, self);
  478. if(col < 0) return col;
  479. sq_pushinteger(v, sqlite3_column_int64(self, col));
  480. return 1;
  481. }
  482. static SQRESULT sq_sqlite3_stmt_asFloat(HSQUIRRELVM v){
  483. SQ_FUNC_VARS_NO_TOP(v);
  484. GET_sqlite3_stmt_INSTANCE();
  485. int col = get_col_index(v, self);
  486. if(col < 0) return col;
  487. sq_pushfloat(v, sqlite3_column_double(self, col));
  488. return 1;
  489. }
  490. static SQRESULT sq_sqlite3_stmt_StringOrNull(HSQUIRRELVM v, int withNull){
  491. SQ_FUNC_VARS_NO_TOP(v);
  492. GET_sqlite3_stmt_INSTANCE();
  493. int col = get_col_index(v, self);
  494. if(col < 0) return col;
  495. sqlite3_stmt_push_string(v, self, col, withNull ? 0 : NULL_AS_EMPTY_STR);
  496. return 1;
  497. }
  498. static SQRESULT sq_sqlite3_stmt_asString(HSQUIRRELVM v){
  499. return sq_sqlite3_stmt_StringOrNull(v, 0);
  500. }
  501. static SQRESULT sq_sqlite3_stmt_asStringOrNull(HSQUIRRELVM v){
  502. return sq_sqlite3_stmt_StringOrNull(v, 1);
  503. }
  504. static SQRESULT sq_sqlite3_stmt_asTable(HSQUIRRELVM v){
  505. SQ_FUNC_VARS(v);
  506. GET_sqlite3_stmt_INSTANCE();
  507. SQ_OPT_INTEGER(v, 2, flags, 0);
  508. sqlite3_stmt_row_asTable(v, self, flags);
  509. return 1;
  510. }
  511. static SQRESULT sq_sqlite3_stmt_asArray(HSQUIRRELVM v){
  512. SQ_FUNC_VARS(v);
  513. GET_sqlite3_stmt_INSTANCE();
  514. SQ_OPT_INTEGER(v, 2, flags, 0);
  515. sqlite3_stmt_row_asArray(v, self, flags);
  516. return 1;
  517. }
  518. static SQRESULT sq_sqlite3_stmt_asArrayOfArrays(HSQUIRRELVM v){
  519. SQ_FUNC_VARS(v);
  520. GET_sqlite3_stmt_INSTANCE();
  521. SQ_OPT_INTEGER(v, 2, flags, 0);
  522. sqlite3_stmt_asArrayOfArrays(v, self, flags);
  523. sqlite3_reset(self);
  524. return 1;
  525. }
  526. static SQRESULT sq_sqlite3_stmt_asArrayOfTables(HSQUIRRELVM v){
  527. SQ_FUNC_VARS(v);
  528. GET_sqlite3_stmt_INSTANCE();
  529. SQ_OPT_INTEGER(v, 2, flags, 0);
  530. sqlite3_stmt_asArrayOfTables(v, self, flags);
  531. sqlite3_reset(self);
  532. return 1;
  533. }
  534. /*utility functions*/
  535. static void append_escaping_json(SQBlob &json, const char *sz){
  536. if(sz){ //escape string
  537. int last_idx, idx;
  538. idx = last_idx = 0;
  539. for(; sz[idx]; ++idx){
  540. char c = sz[idx];
  541. switch(c){
  542. case '"':
  543. case '\n':
  544. case '\r':
  545. case '\\':{
  546. json.Write(sz+last_idx, idx-last_idx);
  547. last_idx = idx;
  548. if(c == '\n') {
  549. json.Write("\\n", 2);
  550. ++last_idx;
  551. }
  552. else if(c == '\r'){
  553. //skip it
  554. ++last_idx;
  555. }
  556. else
  557. {
  558. json.Write("\\", 1);
  559. }
  560. }
  561. }
  562. }
  563. //last part
  564. json.Write(sz+last_idx, idx-last_idx);
  565. }
  566. }
  567. static SQRESULT sq_sqlite3_stmt_asJsonArray(HSQUIRRELVM v) {
  568. SQ_FUNC_VARS(v);
  569. GET_sqlite3_stmt_INSTANCE();
  570. SQ_OPT_INTEGER(v, 3, withMetadata, 0);
  571. int col_count = sqlite3_column_count(self);
  572. int i;
  573. const char* value;
  574. SQBlob json(0, 8192);
  575. if(withMetadata){
  576. json.WriteZstr("{\n\"columns\":[\n");
  577. for(i=0; i < col_count; ++i){
  578. json.WriteZstr((i == 0 ? "\"" : ",\""));
  579. json.WriteZstr(sqlite3_column_name(self, i));
  580. json.WriteZstr("\"");
  581. }
  582. json.WriteZstr("\n],\n\"column_types\":[\n");
  583. for(i=0; i < col_count; ++i){
  584. json.WriteZstr((i == 0 ? "\"" : ",\""));
  585. json.WriteZstr(sqlite3_column_decltype(self, i));
  586. json.WriteZstr("\"");
  587. }
  588. json.WriteZstr("\n],\n\"rows\":[\n");
  589. }
  590. else {
  591. json.WriteZstr("[\n");
  592. }
  593. int row_count = 0;
  594. while(sqlite3_step(self) == SQLITE_ROW){
  595. json.WriteZstr((row_count++ == 0 ? "[" : ",["));
  596. for(i=0; i < col_count; ++i){
  597. json.WriteZstr((i == 0 ? "\"" : ",\""));
  598. value = (const char*)sqlite3_column_text(self, i);
  599. if(value)
  600. {
  601. switch(sqlite3_column_type(self, i))
  602. {
  603. case SQLITE_TEXT:
  604. {
  605. append_escaping_json(json, value);
  606. }
  607. break;
  608. default:
  609. json.WriteZstr(value);
  610. }
  611. }
  612. json.WriteZstr("\"");
  613. }
  614. json.WriteZstr("]\n");
  615. }
  616. json.WriteZstr("]");
  617. if(withMetadata) json.WriteZstr("\n}");
  618. sq_pushstring(v, (const SQChar*)json.GetBuf(), json.Len());
  619. return 1;
  620. }
  621. static SQRESULT sq_sqlite3_stmt_asJsonObject(HSQUIRRELVM v) {
  622. SQ_FUNC_VARS_NO_TOP(v);
  623. GET_sqlite3_stmt_INSTANCE();
  624. int col_count = sqlite3_column_count(self);
  625. int i;
  626. const char* value;
  627. SQBlob json(0, 8192);
  628. json.WriteZstr("{");
  629. if(sqlite3_step(self) == SQLITE_ROW){
  630. for(i=0; i < col_count; ++i){
  631. json.WriteZstr((i == 0 ? "\"" : "\",\""));
  632. append_escaping_json(json, (const char*)sqlite3_column_name(self, i));
  633. json.WriteZstr("\":\"");
  634. value = (const char*)sqlite3_column_text(self, i);
  635. if(value)
  636. {
  637. switch(sqlite3_column_type(self, i))
  638. {
  639. case SQLITE_TEXT:
  640. {
  641. append_escaping_json(json, value);
  642. }
  643. break;
  644. default:
  645. json.WriteZstr(value);
  646. }
  647. }
  648. }
  649. json.WriteZstr("\"");
  650. }
  651. json.WriteZstr("}");
  652. sq_pushstring(v, (const SQChar*)json.GetBuf(), json.Len());
  653. return 1;
  654. }
  655. #define UNSIGNED(n) n##U
  656. #define IBYTE1 UNSIGNED(255)
  657. #define IBYTE2 UNSIGNED(255*255)
  658. #define IBYTE3 UNSIGNED(255*255*255)
  659. #define IBYTE4 UNSIGNED(255*255*255*255)
  660. #define SIZE1BYTE 250
  661. #define SIZE2BYTE 251
  662. #define SIZE3BYTE 252
  663. #define SIZE4BYTE 253
  664. #define SLEMARK 254
  665. #define SLEEND 255
  666. static SQRESULT sle2array(HSQUIRRELVM v, const unsigned char *p, size_t sle_size, const unsigned char **next)
  667. {
  668. size_t size, data_len = 0;
  669. if(sle_size == 0) {
  670. *next = 0;
  671. return 0;
  672. }
  673. while(*p != SLEEND) //data finished now follow digest
  674. {
  675. size = *p++;
  676. if(size >= SIZE1BYTE)
  677. {
  678. if(size == SIZE1BYTE)
  679. {
  680. //data bigger than 250 and less 500 next byte has more info
  681. size += *p++;
  682. }
  683. else if(size == SIZE2BYTE)
  684. {
  685. //data bigger than 250 next two bytes has more info
  686. size = (*p++ * IBYTE1);
  687. size += *p++;
  688. }
  689. else if(size == SIZE3BYTE)
  690. {
  691. //data bigger than 250 next three bytes has more info
  692. size = (*p++ * IBYTE2);
  693. size += (*p++ * IBYTE1);
  694. size += *p++;
  695. }
  696. else if(size == SIZE4BYTE)
  697. {
  698. //data bigger than 250 next four bytes has more info
  699. size = (*p++ * IBYTE3);
  700. size += (*p++ * IBYTE2);
  701. size += (*p++ * IBYTE1);
  702. size += *p++;
  703. }
  704. else if(size == SLEMARK)
  705. {
  706. //reserved can be used for multi part data, metadata, digest, ...
  707. break;
  708. }
  709. }
  710. sq_pushstring(v, (const char*)p, size);
  711. sq_arrayappend(v, -2);
  712. p += size;
  713. data_len += size;
  714. if(data_len > sle_size)
  715. {
  716. //something went wrong here
  717. return sq_throwerror(v, "We got more data than expected !");
  718. }
  719. }
  720. *next = ++p;
  721. return 0;
  722. }
  723. static SQRESULT sle2vec(HSQUIRRELVM v, const unsigned char *sle,
  724. size_t sle_size,
  725. const unsigned char **next)
  726. {
  727. int rc;
  728. sq_newarray(v, 0);
  729. if(sle[0] != '[') {
  730. return sq_throwerror(v, "Invalid encoded vector !");
  731. }
  732. if(sle[1] == ']') {
  733. *next = sle+2; //empty array
  734. return 0;
  735. }
  736. if((rc = sle2array(v, sle+1, sle_size-1, next)) < 0) return rc;
  737. if(!*next || *next[0] != ']'){
  738. return sq_throwerror(v, "Invalid end of vector !");
  739. }
  740. (*next)++;
  741. return 0;
  742. }
  743. static SQRESULT sq_sle2vecOfvec(HSQUIRRELVM v)
  744. {
  745. SQ_FUNC_VARS(v);
  746. SQBlob *blob = NULL;
  747. const SQChar *sle, *sle_start;
  748. SQInteger sle_size;
  749. SQObjectType ptype = sq_gettype(v, 2);
  750. switch(ptype){
  751. case OT_STRING:
  752. sq_getstr_and_size(v, 2, &sle, &sle_size);
  753. break;
  754. case OT_INSTANCE:
  755. if(SQ_FAILED(sq_getinstanceup(v,2,(SQUserPointer*)&blob,(SQUserPointer)SQBlob::SQBlob_TAG)))
  756. return sq_throwerror(v,_SC("invalid type tag"));
  757. if(!blob || !blob->IsValid())
  758. return sq_throwerror(v,_SC("the blob is invalid"));
  759. sle = (const SQChar*)blob->GetBuf();
  760. sle_size = blob->Len();
  761. break;
  762. default:
  763. return sq_throwerror(v,_SC("invalid parameter 1 of type %s"), sq_gettypename(v, 2));
  764. }
  765. if(sq_gettype(v, 3) != OT_ARRAY)
  766. return sq_throwerror(v,_SC("invalid parameter 2 of type %s"), sq_gettypename(v, 3));
  767. SQ_OPT_INTEGER(v, 4, start, 0);
  768. if(start < 0) return sq_throwerror(v, _SC("invalid start position (%d)"), start);
  769. sq_push(v, 3);
  770. int rc, data_count = 1;
  771. const unsigned char *next;
  772. sle_start = sle + start;
  773. sle_size -= start;
  774. if(sle_start[0] != '[') {
  775. return sq_throwerror(v, "Invalid encoded vector !");
  776. }
  777. if(sle_start[1] == ']') {
  778. //sq_pushinteger(v, start+2);
  779. return 1; //empty array
  780. }
  781. int saved_top = sq_gettop(v);
  782. if((rc=sle2vec(v, (const unsigned char *)sle_start+1, sle_size-1, &next)) < 0) return rc;
  783. while(next && *next == '['){
  784. sq_arrayappend(v, -2);
  785. data_count++;
  786. if((rc=sle2vec(v, next, sle_size - (next - (const unsigned char *)sle_start), &next)) < 0) return rc;
  787. }
  788. if(sq_gettop(v) != saved_top){
  789. //last added table left
  790. sq_arrayappend(v, -2);
  791. data_count++;
  792. }
  793. if(!next || *next != ']'){
  794. return sq_throwerror(v, "Invalid end of vector !");
  795. }
  796. sq_pushinteger(v, ((const SQChar*)(++next)) - sle);
  797. return 1;
  798. }
  799. typedef unsigned char slebuf_t[8];
  800. static int sleSize2buf(slebuf_t sle, size_t size){
  801. size_t next_size, tmp_size;
  802. if(size < SIZE1BYTE)
  803. {
  804. sle[0] = size;
  805. return 1;
  806. }
  807. else if(size < (SIZE1BYTE*2))
  808. {
  809. sle[0] = SIZE1BYTE;
  810. next_size = size - 250;
  811. sle[1] = next_size;
  812. return 2;
  813. }
  814. else if(size < IBYTE2)
  815. {
  816. sle[0] = SIZE2BYTE;
  817. next_size = size/IBYTE1;
  818. sle[1] = next_size;
  819. next_size = size%IBYTE1;
  820. sle[2] = next_size;
  821. return 3;
  822. }
  823. else if(size < IBYTE3)
  824. {
  825. sle[0] = SIZE3BYTE;
  826. next_size = size/IBYTE2;
  827. sle[1] = next_size;
  828. tmp_size = size%IBYTE2;
  829. next_size = tmp_size/IBYTE1;
  830. sle[2] = next_size;
  831. next_size = tmp_size%IBYTE1;
  832. sle[3] = next_size;
  833. return 4;
  834. }
  835. else if(size < IBYTE4)
  836. {
  837. sle[0] = SIZE4BYTE;
  838. next_size = size/IBYTE3;
  839. sle[1] = next_size;
  840. tmp_size = size%IBYTE3;
  841. next_size = tmp_size/IBYTE2;
  842. sle[2] = next_size;
  843. tmp_size = tmp_size%IBYTE2;
  844. next_size = tmp_size/IBYTE1;
  845. sle[3] = next_size;
  846. next_size = tmp_size%IBYTE1;
  847. sle[5] = next_size;
  848. return 5;
  849. }
  850. return 0;
  851. }
  852. static SQRESULT sq_get_sle_size(HSQUIRRELVM v){
  853. SQ_FUNC_VARS_NO_TOP(v);
  854. slebuf_t slebuf;
  855. SQ_GET_INTEGER(v, 2, size);
  856. int slesize = sleSize2buf(slebuf, size);
  857. if(slesize) {
  858. sq_pushstring(v, (const char *)slebuf, slesize);
  859. return 1;
  860. }
  861. return 0;
  862. }
  863. static int add2sle(SQBlob &sle, const char *str, size_t size){
  864. slebuf_t slebuf;
  865. int slesize = sleSize2buf(slebuf, size);
  866. if(slesize) sle.Write((const char *)slebuf, slesize);
  867. if(size) sle.Write(str, size);
  868. return size;
  869. }
  870. static SQRESULT sq_sqlite3_stmt_asSleArray(HSQUIRRELVM v) {
  871. SQ_FUNC_VARS_NO_TOP(v);
  872. GET_sqlite3_stmt_INSTANCE();
  873. int col_count = sqlite3_column_count(self);
  874. int i;
  875. const char *value;
  876. SQBlob sle(0, 8192);
  877. sle.WriteZstr("[[");
  878. for(i=0; i < col_count; ++i){
  879. value = sqlite3_column_name(self, i);
  880. add2sle(sle, value, strlen(value));
  881. }
  882. sle.WriteChar(SLEEND);
  883. sle.WriteChar(']');
  884. while(sqlite3_step(self) == SQLITE_ROW){
  885. sle.WriteChar('[');
  886. for(i=0; i < col_count; ++i){
  887. switch(sqlite3_column_type(self, i))
  888. {
  889. case SQLITE_BLOB:
  890. {
  891. add2sle(sle, (const char*)sqlite3_column_blob(self, i),
  892. sqlite3_column_bytes(self, i));
  893. }
  894. break;
  895. default:
  896. add2sle(sle, (const char*)sqlite3_column_text(self, i),
  897. sqlite3_column_bytes(self, i));
  898. }
  899. }
  900. sle.WriteChar(SLEEND);
  901. sle.WriteChar(']');
  902. }
  903. sle.WriteChar(']');
  904. sq_pushstring(v, (const SQChar*)sle.GetBuf(), sle.Len());
  905. return 1;
  906. }
  907. #define _DECL_FUNC(name,nparams,tycheck, isStatic) {_SC(#name), sq_sqlite3_stmt_##name,nparams,tycheck, isStatic}
  908. static SQRegFunction sq_sqlite3_stmt_methods[] =
  909. {
  910. _DECL_FUNC(constructor, -2, _SC("xxs s|n|b|o"), SQFalse),
  911. _DECL_FUNC(stmt_ptr, 1, _SC("x"), SQFalse),
  912. _DECL_FUNC(get_db, 1, _SC("x"), SQFalse),
  913. _DECL_FUNC(finalize, 1, _SC("x"), SQFalse),
  914. _DECL_FUNC(prepare, -2, _SC("xs s|n|b|o"), SQFalse),
  915. _DECL_FUNC(get_sql, 1, _SC("x"), SQFalse),
  916. _DECL_FUNC(bind, 3, _SC("xi s|n|b|o"), SQFalse),
  917. _DECL_FUNC(bind_empty_null, 3, _SC("xi s|n|b|o"), SQFalse),
  918. _DECL_FUNC(bind_blob, 3, _SC("xis"), SQFalse),
  919. _DECL_FUNC(bind_values, -2, _SC("x s|n|b|o"), SQFalse),
  920. _DECL_FUNC(bind_names, 2, _SC("x t|a"), SQFalse),
  921. _DECL_FUNC(bind_parameter_index, 2, _SC("xs"), SQFalse),
  922. _DECL_FUNC(step, 1, _SC("x"), SQFalse),
  923. _DECL_FUNC(reset, 1, _SC("x"), SQFalse),
  924. _DECL_FUNC(next_row, 1, _SC("x"), SQFalse),
  925. _DECL_FUNC(colsAsArray, 1, _SC("x"), SQFalse),
  926. _DECL_FUNC(colsAsTable, 1, _SC("x"), SQFalse),
  927. _DECL_FUNC(col_count, 1, _SC("x"), SQFalse),
  928. _DECL_FUNC(col_name, 2, _SC("xi"), SQFalse),
  929. _DECL_FUNC(col_type, 2, _SC("xi"), SQFalse),
  930. _DECL_FUNC(col_declared_type, 2, _SC("xi"), SQFalse),
  931. _DECL_FUNC(asArray, -1, _SC("xi"), SQFalse),
  932. _DECL_FUNC(asTable, -1, _SC("xi"), SQFalse),
  933. _DECL_FUNC(asArrayOfArrays, -1, _SC("xi"), SQFalse),
  934. _DECL_FUNC(asArrayOfTables, -1, _SC("xi"), SQFalse),
  935. _DECL_FUNC(asSleArray, 1, _SC("x"), SQFalse),
  936. _DECL_FUNC(col, 2, _SC("x i|s"), SQFalse),
  937. _DECL_FUNC(asString, 2, _SC("x i|s"), SQFalse),
  938. _DECL_FUNC(asStringOrNull, 2, _SC("x i|s"), SQFalse),
  939. _DECL_FUNC(asInteger, 2, _SC("x i|s"), SQFalse),
  940. _DECL_FUNC(asBool, 2, _SC("x i|s"), SQFalse),
  941. _DECL_FUNC(asFloat, 2, _SC("x i|s"), SQFalse),
  942. {0,0}
  943. };
  944. #undef _DECL_FUNC
  945. static SQRESULT sqlite3_exec_fmt(HSQUIRRELVM v, e_type_result type_result, int null_as_empty_str=1){
  946. SQ_FUNC_VARS_NO_TOP(v);
  947. GET_sqlite3_INSTANCE();
  948. SQ_GET_STRING(v, 2, szSQL);
  949. sqlite3_stmt *stmt = 0;
  950. _rc_ = sq_sqlite3_stmt_prepare_aux(v, self, &stmt, 2);
  951. if(_rc_ < 0){
  952. if(stmt) sqlite3_finalize(stmt);
  953. return _rc_;
  954. }
  955. int rc = sqlite3_step(stmt);
  956. if(type_result == tr_ddml) {
  957. if(rc != SQLITE_DONE) {
  958. sqlite3_finalize(stmt);
  959. return sq_throwerror(v, "SQL is not a DDML %d %s", rc, sqlite3_errmsg(self));
  960. }
  961. sq_pushinteger(v, sqlite3_changes(sqlite3_db_handle(stmt)));
  962. }
  963. else
  964. {
  965. if(rc != SQLITE_ROW) {
  966. sqlite3_finalize(stmt);
  967. return sq_throwerror(v, "%d %s", rc, sqlite3_errmsg(self));
  968. }
  969. switch(type_result){
  970. case tr_first_row_first_col:
  971. sqlite3_stmt_push_value(v, stmt, 0, 0);
  972. break;
  973. case tr_first_row:
  974. sqlite3_stmt_row_asArray(v, stmt, NULL_AS_EMPTY_STR|AS_STRING_ALWAYS);
  975. break;
  976. case tr_all_rows:
  977. sqlite3_stmt_asArrayOfArrays(v, stmt, NULL_AS_EMPTY_STR|AS_STRING_ALWAYS);
  978. break;
  979. default:
  980. sqlite3_finalize(stmt);
  981. return sq_throwerror(v, "Unknown requested return type %d", type_result);
  982. }
  983. }
  984. sqlite3_finalize(stmt);
  985. return 1;
  986. }
  987. static SQRESULT sq_sqlite3_close_release(HSQUIRRELVM v, sq_sqlite3_sdb *sdb){
  988. SQRESULT rc = SQ_ERROR;
  989. if(sdb){
  990. if(sqlite3_close_v2(sdb->db) == SQLITE_OK){
  991. rc = SQ_OK;
  992. //remove waekref from registrytable
  993. sq_pushregistrytable(sdb->v);
  994. sq_pushuserpointer(sdb->v, sdb->db);
  995. sq_deleteslot(sdb->v, -2, SQFalse);
  996. sq_poptop(sdb->v);
  997. if(sdb->func){
  998. sq_sqlite3_sdb_func *func, *func_next;
  999. func = sdb->func;
  1000. while (func) {
  1001. func_next = func->next;
  1002. sq_release(sdb->v, &func->fn_step);
  1003. sq_release(sdb->v, &func->fn_finalize);
  1004. sq_release(sdb->v, &func->udata);
  1005. sq_free(func, sizeof(sq_sqlite3_sdb_func));
  1006. func = func_next;
  1007. }
  1008. sdb->func = NULL;
  1009. }
  1010. /* 'free' all references */
  1011. sq_release(sdb->v, &sdb->busy_cb);
  1012. sq_release(sdb->v, &sdb->busy_udata);
  1013. sq_release(sdb->v, &sdb->progress_cb);
  1014. sq_release(sdb->v, &sdb->progress_udata);
  1015. sq_release(sdb->v, &sdb->trace_cb);
  1016. sq_release(sdb->v, &sdb->trace_udata);
  1017. sq_release(sdb->v, &sdb->null_value);
  1018. sq_free(sdb, sizeof(sq_sqlite3_sdb));
  1019. }
  1020. }
  1021. return rc;
  1022. }
  1023. static SQRESULT sq_sqlite3_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  1024. {
  1025. sq_sqlite3_sdb *sdb = ((sq_sqlite3_sdb *)p);
  1026. sq_sqlite3_close_release(v, sdb);
  1027. return 0;
  1028. }
  1029. static SQRESULT sq_sqlite3_constructor(HSQUIRRELVM v)
  1030. {
  1031. SQ_FUNC_VARS(v);
  1032. SQ_GET_STRING(v, 2, dbname);
  1033. SQ_OPT_INTEGER(v, 3, flags, SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_SHAREDCACHE | SQLITE_OPEN_SUBLATIN_NA_LIKE);
  1034. sqlite3 *db;
  1035. int rc = sqlite3_open_v2(dbname, &db, flags, 0);
  1036. if(rc != SQLITE_OK) return sq_throwerror(v, "Failed to open database ! %d", rc);
  1037. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb *)sq_malloc(sizeof(sq_sqlite3_sdb));
  1038. memset(sdb, 0, sizeof(sq_sqlite3_sdb));
  1039. sdb->db = db;
  1040. sdb->v = v;
  1041. sq_resetobject(&sdb->busy_cb);
  1042. sq_resetobject(&sdb->busy_udata);
  1043. sq_resetobject(&sdb->progress_cb);
  1044. sq_resetobject(&sdb->progress_udata);
  1045. sq_resetobject(&sdb->trace_cb);
  1046. sq_resetobject(&sdb->trace_udata);
  1047. sq_resetobject(&sdb->null_value);
  1048. sq_setinstanceup(v, 1, sdb);
  1049. sq_setreleasehook(v,1, sq_sqlite3_releasehook);
  1050. //save a weakref to allow statement return it's db
  1051. sq_pushuserpointer(v, sdb->db);
  1052. sq_weakref(v, 1);
  1053. sq_setonregistrytable(v);
  1054. return 1;
  1055. }
  1056. static SQRESULT sq_sqlite3_close(HSQUIRRELVM v){
  1057. SQ_FUNC_VARS_NO_TOP(v);
  1058. GET_sqlite3_INSTANCE();
  1059. if(sq_sqlite3_close_release(v, sdb) == SQ_OK){
  1060. sq_setinstanceup(v, 1, 0); //next calls will fail with "database is closed"
  1061. }
  1062. else {
  1063. return sq_throwerror(v, sqlite3_errmsg(self));
  1064. }
  1065. return 0;
  1066. }
  1067. static SQRESULT sq_sqlite3_db_ptr(HSQUIRRELVM v){
  1068. SQ_FUNC_VARS_NO_TOP(v);
  1069. GET_sqlite3_INSTANCE();
  1070. sq_pushuserpointer(v, self);
  1071. return 1;
  1072. }
  1073. /* bool IsAutoCommitOn( ) */
  1074. static SQRESULT sq_sqlite3_IsAutoCommitOn(HSQUIRRELVM v){
  1075. SQ_FUNC_VARS_NO_TOP(v);
  1076. GET_sqlite3_INSTANCE();
  1077. sq_pushbool(v, sqlite3_get_autocommit(self) ? SQTrue : SQFalse);
  1078. return 1;
  1079. }
  1080. /* int changes( ) */
  1081. static SQRESULT sq_sqlite3_changes(HSQUIRRELVM v){
  1082. SQ_FUNC_VARS_NO_TOP(v);
  1083. GET_sqlite3_INSTANCE();
  1084. sq_pushinteger(v, sqlite3_total_changes(self));
  1085. return 1;
  1086. }
  1087. static SQRESULT sq_sqlite3_exec(HSQUIRRELVM v){
  1088. return sqlite3_exec_fmt(v, tr_all_rows);
  1089. }
  1090. /* int exec_dml( const char * szSQL ) */
  1091. static SQRESULT sq_sqlite3_exec_dml(HSQUIRRELVM v){
  1092. return sqlite3_exec_fmt(v, tr_ddml);
  1093. }
  1094. /* bool exec_get_one( std::string & result , const char * szSQL ) */
  1095. static SQRESULT sq_sqlite3_exec_get_one(HSQUIRRELVM v){
  1096. return sqlite3_exec_fmt(v, tr_first_row_first_col);
  1097. }
  1098. static SQRESULT sq_sqlite3_exec_get_first_row(HSQUIRRELVM v){
  1099. return sqlite3_exec_fmt(v, tr_first_row);
  1100. }
  1101. /* const char * get_db_name( ) */
  1102. static SQRESULT sq_sqlite3_get_db_name(HSQUIRRELVM v){
  1103. SQ_FUNC_VARS_NO_TOP(v);
  1104. GET_sqlite3_INSTANCE();
  1105. sq_pushstring(v, sqlite3_db_filename(self, "main"), -1);
  1106. return 1;
  1107. }
  1108. /* sqlite3_int64 last_row_id( ) */
  1109. static SQRESULT sq_sqlite3_last_row_id(HSQUIRRELVM v){
  1110. SQ_FUNC_VARS_NO_TOP(v);
  1111. GET_sqlite3_INSTANCE();
  1112. sq_pushinteger(v, sqlite3_last_insert_rowid(self));
  1113. return 1;
  1114. }
  1115. /* stmt * prepare( const char * sql ) */
  1116. static SQRESULT sq_sqlite3_prepare(HSQUIRRELVM v){
  1117. SQ_FUNC_VARS_NO_TOP(v);
  1118. GET_sqlite3_INSTANCE();
  1119. SQ_GET_STRING(v, 2, sql);
  1120. sq_pushstring(v, SQLite3_Stmt_TAG, -1);
  1121. if(sq_getonroottable(v) == SQ_ERROR) return SQ_ERROR;
  1122. sq_pushroottable(v);
  1123. sq_push(v, 1);
  1124. sq_push(v, 2);
  1125. if(sq_call(v, 3, SQTrue, SQFalse) != SQ_OK) return SQ_ERROR;
  1126. return 1;
  1127. }
  1128. /* void set_busy_timeout( int nMillisecs ) */
  1129. static SQRESULT sq_sqlite3_set_busy_timeout(HSQUIRRELVM v){
  1130. SQ_FUNC_VARS_NO_TOP(v);
  1131. GET_sqlite3_INSTANCE();
  1132. SQ_GET_INTEGER(v, 2, nMillisecs);
  1133. //self->set_busy_timeout(nMillisecs);
  1134. return 0;
  1135. }
  1136. /* int total_changes( ) */
  1137. static SQRESULT sq_sqlite3_total_changes(HSQUIRRELVM v){
  1138. SQ_FUNC_VARS_NO_TOP(v);
  1139. GET_sqlite3_INSTANCE();
  1140. sq_pushinteger(v, sqlite3_total_changes(self));
  1141. return 1;
  1142. }
  1143. static SQRESULT sq_sqlite3_enable_shared_cache(HSQUIRRELVM v) {
  1144. SQ_FUNC_VARS_NO_TOP(v);
  1145. SQ_GET_BOOL(v, 2, bhow);
  1146. sq_pushbool(v, sqlite3_enable_shared_cache(bhow) == SQLITE_OK);
  1147. return 1;
  1148. }
  1149. static SQRESULT sq_sqlite3_sleep(HSQUIRRELVM v) {
  1150. SQ_FUNC_VARS_NO_TOP(v);
  1151. SQ_GET_INTEGER(v, 2, n);
  1152. sqlite3_sleep(n);
  1153. return 0;
  1154. }
  1155. static SQRESULT sq_sqlite3_version(HSQUIRRELVM v) {
  1156. sq_pushstring(v, sqlite3_libversion(), -1);
  1157. return 1;
  1158. }
  1159. static SQRESULT sq_sqlite3_errcode(HSQUIRRELVM v) {
  1160. SQ_FUNC_VARS_NO_TOP(v);
  1161. GET_sqlite3_INSTANCE();
  1162. sq_pushinteger(v, sqlite3_errcode(self));
  1163. return 1;
  1164. }
  1165. static SQRESULT sq_sqlite3_errmsg(HSQUIRRELVM v) {
  1166. SQ_FUNC_VARS_NO_TOP(v);
  1167. GET_sqlite3_INSTANCE();
  1168. sq_pushstring(v, sqlite3_errmsg(self), -1);
  1169. return 1;
  1170. }
  1171. #ifndef WIN32
  1172. static SQRESULT sq_sqlite3_temp_directory(HSQUIRRELVM v) {
  1173. SQ_FUNC_VARS(v);
  1174. const char *oldtemp = sqlite3_temp_directory;
  1175. if (_top_ > 1) {
  1176. SQ_GET_STRING(v, 2, temp);
  1177. if (sqlite3_temp_directory) {
  1178. sqlite3_free((char*)sqlite3_temp_directory);
  1179. }
  1180. if (temp && temp_size) {
  1181. sqlite3_temp_directory = sqlite3_mprintf("%s", temp);
  1182. }
  1183. else {
  1184. sqlite3_temp_directory = NULL;
  1185. }
  1186. }
  1187. sq_pushstring(v, oldtemp, -1);
  1188. return 1;
  1189. }
  1190. #endif
  1191. #ifdef SQLITE_HAS_CODEC
  1192. //#include "codecext.h"
  1193. /*
  1194. ** Params: db, sql
  1195. ** returns: code, compiled length or error message
  1196. */
  1197. static SQRESULT sq_sqlite3_key(HSQUIRRELVM v) {
  1198. SQ_FUNC_VARS_NO_TOP(v);
  1199. GET_sqlite3_INSTANCE();
  1200. SQ_GET_STRING(v, 2, key);
  1201. sq_pushinteger(v, sqlite3_key(self, key, key_size));
  1202. return 1;
  1203. }
  1204. /*
  1205. ** Params: db, sql
  1206. ** returns: code, compiled length or error message
  1207. */
  1208. static SQRESULT sq_sqlite3_rekey(HSQUIRRELVM v) {
  1209. SQ_FUNC_VARS_NO_TOP(v);
  1210. GET_sqlite3_INSTANCE();
  1211. SQ_GET_STRING(v, 2, key);
  1212. sq_pushinteger(v, sqlite3_rekey(self, key, key_size));
  1213. return 1;
  1214. }
  1215. #endif
  1216. #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK
  1217. /*
  1218. ** progress handler:
  1219. ** Params: database, number of opcodes, callback function, userdata
  1220. **
  1221. ** callback function:
  1222. ** Params: userdata
  1223. ** returns: 0 to return immediatly and return SQLITE_ABORT, non-zero to continue
  1224. */
  1225. static int db_progress_callback(void *user) {
  1226. int result = 1; /* abort by default */
  1227. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)user;
  1228. HSQUIRRELVM v = sdb->v;
  1229. int top = sq_gettop(v);
  1230. sq_pushobject(v, sdb->progress_cb);
  1231. sq_pushroottable(v); //this
  1232. sq_pushobject(v, sdb->progress_udata);
  1233. /* call lua function */
  1234. if (sq_call(v, 2, SQTrue, SQFalse) == SQ_OK)
  1235. sq_getinteger(v, -1, &result);
  1236. sq_settop(v, top);
  1237. return result;
  1238. }
  1239. static SQRESULT sq_sqlite3_progress_handler(HSQUIRRELVM v) {
  1240. SQ_FUNC_VARS(v);
  1241. GET_sqlite3_INSTANCE();
  1242. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL) {
  1243. sq_release(v, &sdb->progress_cb);
  1244. sq_release(v, &sdb->progress_udata);
  1245. sq_resetobject(&sdb->progress_cb);
  1246. sq_resetobject(&sdb->progress_udata);
  1247. /* clear busy handler */
  1248. sqlite3_progress_handler(self, 0, NULL, NULL);
  1249. }
  1250. else {
  1251. SQ_GET_INTEGER(v, 2, nop);
  1252. if(sq_gettype(v, 3) != OT_CLOSURE)
  1253. return sq_throwerror(v, _SC("invalid second parameter expected closure"));
  1254. sq_getstackobj(v, 3, &sdb->progress_cb);
  1255. sq_addref(v, &sdb->progress_cb);
  1256. if(_top_ > 3){
  1257. sq_getstackobj(v, 4, &sdb->progress_udata);
  1258. sq_addref(v, &sdb->progress_udata);
  1259. }
  1260. /* set progress callback */
  1261. sqlite3_progress_handler(self, nop, db_progress_callback, sdb);
  1262. }
  1263. return 0;
  1264. }
  1265. #else /* #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK */
  1266. static SQRESULT sq_sqlite3_progress_handler(HSQUIRRELVM v) {
  1267. return sq_throwerror(v, _SC("progress callback support disabled at compile time"));
  1268. return 0;
  1269. }
  1270. #endif /* #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK */
  1271. /*
  1272. ** trace callback:
  1273. ** Params: database, callback function, userdata
  1274. **
  1275. ** callback function:
  1276. ** Params: userdata, sql
  1277. */
  1278. static void db_trace_callback(void *user, const char *sql) {
  1279. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)user;
  1280. HSQUIRRELVM v = sdb->v;
  1281. int top = sq_gettop(v);
  1282. /* setup squirrel callback call */
  1283. sq_pushobject(v, sdb->trace_cb);
  1284. sq_pushroottable(v);
  1285. sq_pushobject(v, sdb->trace_udata);
  1286. sq_pushstring(v, sql, -1); /* traced sql statement */
  1287. /* call squirrel function */
  1288. sq_call(v, 3, SQFalse, SQFalse);
  1289. /* ignore any error generated by this function */
  1290. sq_settop(v, top);
  1291. }
  1292. static SQRESULT sq_sqlite3_trace(HSQUIRRELVM v) {
  1293. SQ_FUNC_VARS(v);
  1294. GET_sqlite3_INSTANCE();
  1295. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL) {
  1296. sq_release(v, &sdb->trace_cb);
  1297. sq_release(v, &sdb->trace_udata);
  1298. sq_resetobject(&sdb->trace_cb);
  1299. sq_resetobject(&sdb->trace_udata);
  1300. /* clear trace handler */
  1301. sqlite3_trace(self, NULL, NULL);
  1302. }
  1303. else {
  1304. if(sq_gettype(v, 2) != OT_CLOSURE)
  1305. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1306. sq_getstackobj(v, 2, &sdb->trace_cb);
  1307. sq_addref(v, &sdb->trace_cb);
  1308. if(_top_ > 2){
  1309. sq_getstackobj(v, 3, &sdb->trace_udata);
  1310. sq_addref(v, &sdb->trace_udata);
  1311. }
  1312. /* set trace callback */
  1313. sqlite3_trace(self, db_trace_callback, sdb);
  1314. }
  1315. return 0;
  1316. }
  1317. /*
  1318. ** busy handler:
  1319. ** Params: database, callback function, userdata
  1320. **
  1321. ** callback function:
  1322. ** Params: userdata, number of tries
  1323. ** returns: 0 to return immediatly and return SQLITE_BUSY, non-zero to try again
  1324. */
  1325. static int db_busy_callback(void *user, int tries) {
  1326. SQBool retry = SQFalse; /* abort by default */
  1327. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)user;
  1328. HSQUIRRELVM v = sdb->v;
  1329. int top = sq_gettop(v);
  1330. sq_pushobject(v, sdb->busy_cb);
  1331. sq_pushroottable(v);
  1332. sq_pushobject(v, sdb->busy_udata);
  1333. sq_pushinteger(v, tries);
  1334. /* call lua function */
  1335. if (sq_call(v, 3, SQTrue, SQFalse) == SQ_OK)
  1336. sq_getbool(v, -1, &retry);
  1337. sq_settop(v, top);
  1338. return retry == SQTrue;
  1339. }
  1340. static SQRESULT sq_sqlite3_busy_handler(HSQUIRRELVM v) {
  1341. SQ_FUNC_VARS(v);
  1342. GET_sqlite3_INSTANCE();
  1343. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL) {
  1344. sq_release(v, &sdb->busy_cb);
  1345. sq_release(v, &sdb->busy_udata);
  1346. sq_resetobject(&sdb->busy_cb);
  1347. sq_resetobject(&sdb->busy_udata);
  1348. /* clear busy handler */
  1349. sqlite3_busy_handler(self, NULL, NULL);
  1350. }
  1351. else {
  1352. if(sq_gettype(v, 2) != OT_CLOSURE)
  1353. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1354. sq_getstackobj(v, 2, &sdb->busy_cb);
  1355. sq_addref(v, &sdb->busy_cb);
  1356. if(_top_ > 2){
  1357. sq_getstackobj(v, 3, &sdb->busy_udata);
  1358. sq_addref(v, &sdb->busy_udata);
  1359. }
  1360. /* set busy callback */
  1361. sqlite3_busy_handler(self, db_busy_callback, sdb);
  1362. }
  1363. return 0;
  1364. }
  1365. static SQRESULT sq_sqlite3_busy_timeout(HSQUIRRELVM v) {
  1366. SQ_FUNC_VARS_NO_TOP(v);
  1367. GET_sqlite3_INSTANCE();
  1368. SQ_GET_INTEGER(v, 2, timeout);
  1369. sqlite3_busy_timeout(self, timeout);
  1370. /* if there was a timeout callback registered, it is now
  1371. ** invalid/useless. free any references we may have */
  1372. sq_release(v, &sdb->busy_cb);
  1373. sq_resetobject(&sdb->busy_cb);
  1374. sq_release(v, &sdb->busy_udata);
  1375. sq_resetobject(&sdb->busy_udata);
  1376. return 0;
  1377. }
  1378. static SQRESULT sq_sqlite3_interrupt(HSQUIRRELVM v) {
  1379. SQ_FUNC_VARS_NO_TOP(v);
  1380. GET_sqlite3_INSTANCE();
  1381. sqlite3_interrupt(self);
  1382. return 0;
  1383. }
  1384. /*
  1385. ** =======================================================
  1386. ** User Defined Functions - Context Methods
  1387. ** =======================================================
  1388. */
  1389. typedef struct {
  1390. sqlite3_context *ctx;
  1391. HSQOBJECT udata;
  1392. } sq_sqlite3_context_st;
  1393. static const SQChar sq_sqlite3_context_TAG[] = _SC(":sqlite3:ctx");
  1394. static SQRESULT sq_sqlite3_context_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  1395. {
  1396. sq_sqlite3_context_st *ctx = ((sq_sqlite3_context_st *)p);
  1397. /* 'free' all references */
  1398. sq_free(ctx, sizeof(sq_sqlite3_context_st));
  1399. return 0;
  1400. }
  1401. static SQRESULT sq_sqlite3_context_constructor(HSQUIRRELVM v) {
  1402. sq_sqlite3_context_st *ctx = (sq_sqlite3_context_st*)sq_malloc(sizeof(sq_sqlite3_context_st));
  1403. ctx->ctx = NULL;
  1404. sq_resetobject(&ctx->udata);
  1405. sq_setinstanceup(v, 1, ctx);
  1406. sq_setreleasehook(v,1, sq_sqlite3_context_releasehook);
  1407. return 1;
  1408. }
  1409. #define SQ_SQLITE3_GETCONTEXT(v, idx) \
  1410. sq_sqlite3_context_st *self;\
  1411. if((_rc_ = sq_getinstanceup(v, idx, (void**)&self, (void*)sq_sqlite3_context_TAG)) < 0) return _rc_;
  1412. #define GET_sqlite3_context_INSTANCE() SQ_SQLITE3_GETCONTEXT(v,1)
  1413. static SQRESULT sq_sqlite3_context__tostring(HSQUIRRELVM v) {
  1414. SQ_FUNC_VARS_NO_TOP(v);
  1415. GET_sqlite3_context_INSTANCE();
  1416. char buff[64];
  1417. snprintf(buff, sizeof(buff), "sqlite function context (%p)", self);
  1418. sq_pushstring(v, buff, -1);
  1419. return 1;
  1420. }
  1421. static SQRESULT sq_sqlite3_context_check_aggregate(HSQUIRRELVM v, sq_sqlite3_context_st *ctx) {
  1422. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(ctx->ctx);
  1423. if (sq_isclosure(func->fn_finalize)) {
  1424. return sq_throwerror(v, "attempt to call aggregate method from scalar function");
  1425. }
  1426. return 1;
  1427. }
  1428. static SQRESULT sq_sqlite3_context_user_data(HSQUIRRELVM v) {
  1429. SQ_FUNC_VARS_NO_TOP(v);
  1430. GET_sqlite3_context_INSTANCE();
  1431. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(self->ctx);
  1432. sq_pushobject(v, func->udata);
  1433. return 1;
  1434. }
  1435. static SQRESULT sq_sqlite3_context_aggregate_data(HSQUIRRELVM v) {
  1436. SQ_FUNC_VARS(v);
  1437. GET_sqlite3_context_INSTANCE();
  1438. sq_sqlite3_context_check_aggregate(v, self);
  1439. if(_top_ < 2){
  1440. sq_pushobject(v, self->udata);
  1441. }
  1442. else
  1443. {
  1444. sq_release(v, &self->udata);
  1445. sq_getstackobj(v, 2, &self->udata);
  1446. sq_addref(v, &self->udata);
  1447. }
  1448. return 0;
  1449. }
  1450. static SQRESULT sq_sqlite3_context_aggregate_count(HSQUIRRELVM v) {
  1451. SQ_FUNC_VARS_NO_TOP(v);
  1452. GET_sqlite3_context_INSTANCE();
  1453. sq_sqlite3_context_check_aggregate(v, self);
  1454. sq_pushinteger(v, sqlite3_aggregate_count(self->ctx));
  1455. return 1;
  1456. }
  1457. #if 0
  1458. void *sqlite3_get_auxdata(sqlite3_context*, int);
  1459. void sqlite3_set_auxdata(sqlite3_context*, int, void*, void (*)(void*));
  1460. #endif
  1461. static SQRESULT sq_sqlite3_context_result_blob(HSQUIRRELVM v) {
  1462. SQ_FUNC_VARS_NO_TOP(v);
  1463. GET_sqlite3_context_INSTANCE();
  1464. SQ_GET_STRING(v, 2, blob);
  1465. sqlite3_result_blob(self->ctx, (const void*)blob, blob_size, SQLITE_TRANSIENT);
  1466. return 0;
  1467. }
  1468. static SQRESULT sq_sqlite3_context_result_double(HSQUIRRELVM v) {
  1469. SQ_FUNC_VARS_NO_TOP(v);
  1470. GET_sqlite3_context_INSTANCE();
  1471. SQ_GET_FLOAT(v, 2, d);
  1472. sqlite3_result_double(self->ctx, d);
  1473. return 0;
  1474. }
  1475. static SQRESULT sq_sqlite3_context_result_error(HSQUIRRELVM v) {
  1476. SQ_FUNC_VARS_NO_TOP(v);
  1477. GET_sqlite3_context_INSTANCE();
  1478. SQ_GET_STRING(v,2, err);
  1479. sqlite3_result_error(self->ctx, err, err_size);
  1480. return 0;
  1481. }
  1482. static SQRESULT sq_sqlite3_context_result_int(HSQUIRRELVM v) {
  1483. SQ_FUNC_VARS_NO_TOP(v);
  1484. GET_sqlite3_context_INSTANCE();
  1485. SQ_GET_INTEGER(v, 2, i);
  1486. sqlite3_result_int(self->ctx, i);
  1487. return 0;
  1488. }
  1489. static SQRESULT sq_sqlite3_context_result_null(HSQUIRRELVM v) {
  1490. SQ_FUNC_VARS_NO_TOP(v);
  1491. GET_sqlite3_context_INSTANCE();
  1492. sqlite3_result_null(self->ctx);
  1493. return 0;
  1494. }
  1495. static SQRESULT sq_sqlite3_context_result_text(HSQUIRRELVM v) {
  1496. SQ_FUNC_VARS_NO_TOP(v);
  1497. GET_sqlite3_context_INSTANCE();
  1498. SQ_GET_STRING(v, 2, text);
  1499. sqlite3_result_text(self->ctx, text, text_size, SQLITE_TRANSIENT);
  1500. return 0;
  1501. }
  1502. #define _DECL_FUNC(name,nparams,tycheck) {_SC(#name), sq_sqlite3_context_##name,nparams,tycheck}
  1503. static SQRegFunction sq_sqlite3_context_methods[] =
  1504. {
  1505. _DECL_FUNC(constructor, 1, _SC("x")),
  1506. _DECL_FUNC(user_data, 1, _SC("x")),
  1507. _DECL_FUNC(aggregate_data, -1, _SC("x.")),
  1508. _DECL_FUNC(aggregate_count, 1, _SC("x")),
  1509. _DECL_FUNC(result_null, 1, _SC("x")),
  1510. _DECL_FUNC(result_double, 2, _SC("xf")),
  1511. _DECL_FUNC(result_int, 2, _SC("xi")),
  1512. _DECL_FUNC(result_text, 2, _SC("xs")),
  1513. _DECL_FUNC(result_blob, 2, _SC("xs")),
  1514. _DECL_FUNC(result_error, 2, _SC("xs")),
  1515. _DECL_FUNC(_tostring, -1, _SC("x")),
  1516. {0,0}
  1517. };
  1518. #undef _DECL_FUNC
  1519. /*
  1520. ** callback functions used when calling registered sql functions
  1521. */
  1522. static void sqlite3_push_value(HSQUIRRELVM v, sqlite3_value *value) {
  1523. const char *tmp_value;
  1524. switch (sqlite3_value_type(value)) {
  1525. case SQLITE_TEXT:
  1526. tmp_value = (const char*) sqlite3_value_text(value);
  1527. if(tmp_value) sq_pushstring(v, tmp_value, sqlite3_value_bytes(value));
  1528. else push_sqlite3_null(v);
  1529. break;
  1530. case SQLITE_INTEGER:
  1531. {
  1532. sqlite_int64 i64 = sqlite3_value_int64(value);
  1533. SQInteger n = (SQInteger)i64;
  1534. if (n == i64)
  1535. sq_pushinteger(v, n);
  1536. else
  1537. sq_pushstring(v, (const char*) sqlite3_value_text(value), sqlite3_value_bytes(value));
  1538. }
  1539. break;
  1540. case SQLITE_FLOAT:
  1541. sq_pushfloat(v, sqlite3_value_double(value));
  1542. break;
  1543. case SQLITE_BLOB:
  1544. tmp_value = (const char*) sqlite3_value_blob(value);
  1545. if(tmp_value) sq_pushstring(v, tmp_value, sqlite3_value_bytes(value));
  1546. else push_sqlite3_null(v);
  1547. break;
  1548. case SQLITE_NULL:
  1549. push_sqlite3_null(v);
  1550. break;
  1551. default:
  1552. /* things done properly (SQLite + Lua SQLite)
  1553. ** this should never happen */
  1554. push_sqlite3_null(v);
  1555. break;
  1556. }
  1557. }
  1558. //#if 0
  1559. static SQRESULT new_context_instance(HSQUIRRELVM v, sq_sqlite3_context_st **ctx){
  1560. sq_pushregistrytable(v);
  1561. sq_pushstring(v,_SC("sqite3_context"),-1);
  1562. int rc = sq_rawget(v, -2);
  1563. sq_remove(v, -2); //remove registrytable
  1564. sq_pushroottable(v);
  1565. rc = sq_call(v, 1, SQTrue, SQFalse);
  1566. sq_remove(v, -2); //class
  1567. rc = sq_getinstanceup(v, -1, (void**)ctx, (void*)sq_sqlite3_context_TAG);
  1568. return rc;
  1569. }
  1570. /* scalar function to be called
  1571. ** callback params: context, values... */
  1572. static void db_sql_normal_function(sqlite3_context *context, int argc, sqlite3_value **argv) {
  1573. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(context);
  1574. HSQUIRRELVM v = func->sdb->v;
  1575. int n;
  1576. sq_sqlite3_context_st *ctx;
  1577. int top = sq_gettop(v);
  1578. /* ensure there is enough space in the stack */
  1579. sq_reservestack(v, argc + 5);
  1580. sq_pushobject(v, func->fn_step);
  1581. sq_pushroottable(v);
  1582. if (!sq_isclosure(func->fn_finalize)) {
  1583. new_context_instance(v, &ctx);
  1584. }
  1585. else {
  1586. /* reuse context userdata value */
  1587. void *p = sqlite3_aggregate_context(context, 1);
  1588. /* i think it is OK to use assume that using a light user data
  1589. ** as an entry on LUA REGISTRY table will be unique */
  1590. sq_pushregistrytable(v);
  1591. sq_pushuserpointer(v, p);
  1592. /* context table */
  1593. if(sq_rawget(v, -2) != SQ_OK){
  1594. /* not yet created? */
  1595. sq_poptop(v); //remove null
  1596. new_context_instance(v, &ctx);
  1597. sq_pushuserpointer(v, p);
  1598. sq_push(v, -2);
  1599. sq_rawset(v, -4); //insert into registrytable
  1600. }
  1601. sq_remove(v, -2); //remove registrytable
  1602. }
  1603. /* push params */
  1604. for (n = 0; n < argc; ++n) {
  1605. sqlite3_push_value(v, argv[n]);
  1606. }
  1607. /* set context */
  1608. ctx->ctx = context;
  1609. if (sq_call(v, argc + 2, SQFalse, SQFalse) != SQ_OK) { //2 = roottable + ctx
  1610. sqlite3_result_error(context, sq_getlasterror_str(v), -1);
  1611. }
  1612. /* invalidate context */
  1613. ctx->ctx = NULL;
  1614. if (!sq_isclosure(func->fn_finalize)) {
  1615. sq_release(v, &ctx->udata);
  1616. sq_resetobject(&ctx->udata);
  1617. }
  1618. sq_settop(v, top);
  1619. }
  1620. static void db_sql_finalize_function(sqlite3_context *context) {
  1621. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(context);
  1622. HSQUIRRELVM v = func->sdb->v;
  1623. void *p = sqlite3_aggregate_context(context, 1); /* minimal mem usage */
  1624. sq_sqlite3_context_st *ctx;
  1625. int top = sq_gettop(v);
  1626. sq_pushobject(v, func->fn_finalize);
  1627. sq_pushroottable(v);
  1628. /* i think it is OK to use assume that using a light user data
  1629. ** as an entry on LUA REGISTRY table will be unique */
  1630. sq_pushregistrytable(v);
  1631. sq_pushuserpointer(v, p);
  1632. /* remove it from registry but we'll use it last time here */
  1633. /* context table */
  1634. if(sq_deleteslot(v, -2, SQTrue) != SQ_OK){
  1635. /* not yet created? - shouldn't happen in finalize function */
  1636. sq_pop(v, 1);
  1637. new_context_instance(v, &ctx);
  1638. sq_pushuserpointer(v, p);
  1639. sq_push(v, -2);
  1640. sq_rawset(v, -4);
  1641. }
  1642. sq_remove(v, -2); //registrytable
  1643. /* set context */
  1644. ctx->ctx = context;
  1645. if (sq_call(v, 1, SQFalse, SQFalse) != SQ_OK) {
  1646. sqlite3_result_error(context, sq_getlasterror_str(v), -1);
  1647. }
  1648. /* invalidate context */
  1649. ctx->ctx = NULL;
  1650. /* cleanup context */
  1651. sq_release(v, &ctx->udata);
  1652. sq_resetobject(&ctx->udata);
  1653. sq_settop(v, top);
  1654. }
  1655. /*
  1656. ** Register a normal function
  1657. ** Params: db, function name, number arguments, [ callback | step, finalize], user data
  1658. ** Returns: true on sucess
  1659. **
  1660. ** Normal function:
  1661. ** Params: context, params
  1662. **
  1663. ** Aggregate function:
  1664. ** Params of step: context, params
  1665. ** Params of finalize: context
  1666. */
  1667. static SQRESULT db_register_function(HSQUIRRELVM v, int aggregate) {
  1668. SQ_FUNC_VARS(v);
  1669. GET_sqlite3_INSTANCE();
  1670. SQ_GET_STRING(v, 2, name);
  1671. SQ_GET_INTEGER(v, 3, nargs);
  1672. if(sq_gettype(v, 4) != OT_CLOSURE)
  1673. return sq_throwerror(v, "invalid parameter 3 expected closure");
  1674. if (aggregate) {
  1675. if(sq_gettype(v,5) != OT_CLOSURE)
  1676. return sq_throwerror(v, "invalid parameter 4 expected closure");
  1677. }
  1678. sq_sqlite3_sdb_func *func;
  1679. /* maybe an alternative way to allocate memory should be used/avoided */
  1680. func = (sq_sqlite3_sdb_func*)sq_malloc(sizeof(sq_sqlite3_sdb_func));
  1681. memset(func, 0, sizeof(sq_sqlite3_sdb_func));
  1682. _rc_ = sqlite3_create_function(
  1683. self, name, nargs, SQLITE_UTF8, func,
  1684. aggregate ? NULL : db_sql_normal_function,
  1685. aggregate ? db_sql_normal_function : NULL,
  1686. aggregate ? db_sql_finalize_function : NULL
  1687. );
  1688. if (_rc_ == SQLITE_OK) {
  1689. /* save registered function in db function list */
  1690. func->sdb = sdb;
  1691. func->next = sdb->func;
  1692. sdb->func = func;
  1693. /* save the setp/normal function callback */
  1694. sq_resetobject(&func->fn_step);
  1695. sq_getstackobj(v, 4, &func->fn_step);
  1696. sq_addref(v, &func->fn_step);
  1697. /* save the finalize function callback */
  1698. sq_resetobject(&func->fn_finalize);
  1699. if (aggregate) {
  1700. sq_getstackobj(v, 5, &func->fn_finalize);
  1701. sq_addref(v, &func->fn_finalize);
  1702. }
  1703. /* save user data */
  1704. sq_resetobject(&func->udata);
  1705. int udata_idx = aggregate ? 6 : 5;
  1706. if(_top_ >= udata_idx){
  1707. sq_getstackobj(v, udata_idx, &func->udata);
  1708. sq_addref(v, &func->udata);
  1709. }
  1710. }
  1711. else {
  1712. /* free allocated memory */
  1713. sq_free(func, sizeof(sq_sqlite3_sdb_func));
  1714. }
  1715. sq_pushbool(v, _rc_ == SQLITE_OK ? 1 : 0);
  1716. return 1;
  1717. }
  1718. //#endif
  1719. static SQRESULT sq_sqlite3_create_function(HSQUIRRELVM v) {
  1720. return db_register_function(v, 0);
  1721. }
  1722. static SQRESULT sq_sqlite3_create_aggregate(HSQUIRRELVM v) {
  1723. return db_register_function(v, 1);
  1724. }
  1725. #define _DECL_FUNC(name,nparams,tycheck) {_SC(#name), sq_sqlite3_##name,nparams,tycheck}
  1726. static SQRegFunction sq_sqlite3_methods[] =
  1727. {
  1728. _DECL_FUNC(constructor, -2, _SC("xsi")),
  1729. _DECL_FUNC(close, 1, _SC("x")),
  1730. _DECL_FUNC(db_ptr, 1, _SC("x")),
  1731. _DECL_FUNC(IsAutoCommitOn, 1, _SC("x")),
  1732. _DECL_FUNC(close, 1, _SC("x")),
  1733. _DECL_FUNC(version, 1, _SC("x")),
  1734. _DECL_FUNC(errcode, 1, _SC("x")),
  1735. _DECL_FUNC(errmsg, 1, _SC("x")),
  1736. _DECL_FUNC(sleep, 1, _SC("x")),
  1737. _DECL_FUNC(interrupt, 1, _SC("x")),
  1738. _DECL_FUNC(progress_handler, -2, _SC("x i|o c .")),
  1739. _DECL_FUNC(trace, -2, _SC("x c|o .")),
  1740. _DECL_FUNC(busy_handler, -2, _SC("x c|o .")),
  1741. _DECL_FUNC(busy_timeout, 2, _SC("xi")),
  1742. _DECL_FUNC(create_function, 4, _SC("xsic")),
  1743. _DECL_FUNC(create_aggregate, 5, _SC("xsicc")),
  1744. #ifndef WIN32
  1745. _DECL_FUNC(temp_directory, 2, _SC("xs")),
  1746. #endif
  1747. _DECL_FUNC(enable_shared_cache, 2, _SC("xb")),
  1748. _DECL_FUNC(changes, 1, _SC("x")),
  1749. _DECL_FUNC(exec, 2, _SC("xs")),
  1750. _DECL_FUNC(exec_dml, 2, _SC("xs")),
  1751. _DECL_FUNC(exec_get_first_row, 2, _SC("xs")),
  1752. _DECL_FUNC(exec_get_one, 2, _SC("xs")),
  1753. _DECL_FUNC(get_db_name, 1, _SC("x")),
  1754. _DECL_FUNC(last_row_id, 1, _SC("x")),
  1755. _DECL_FUNC(prepare, 2, _SC("xs")),
  1756. _DECL_FUNC(set_busy_timeout, -1, _SC("xi")),
  1757. _DECL_FUNC(total_changes, 1, _SC("x")),
  1758. #ifdef SQLITE_HAS_CODEC
  1759. _DECL_FUNC(key, 2, _SC("xs")),
  1760. _DECL_FUNC(rekey, 2, _SC("xs")),
  1761. #endif
  1762. {0,0}
  1763. };
  1764. #undef _DECL_FUNC
  1765. #define INT_CONST(v,num) sq_pushstring(v,_SC(#num),-1);sq_pushinteger(v,num);sq_newslot(v,-3,SQTrue);
  1766. #ifdef __cplusplus
  1767. extern "C" {
  1768. #endif
  1769. SQRESULT sqext_register_SQLite3(HSQUIRRELVM v)
  1770. {
  1771. sq_insertfunc(v, _SC("sle2vecOfvec"), sq_sle2vecOfvec, -2, _SC(". s|x a i"), SQTrue);
  1772. sq_insertfunc(v, _SC("get_sle_size"), sq_get_sle_size, -2, _SC(".i"), SQTrue);
  1773. HSQOBJECT sqlite3_NULL;
  1774. sq_pushregistrytable(v);
  1775. sq_pushstring(v, sqlite3_NULL_Name,-1);
  1776. sq_newuserdata(v, sizeof(void*));
  1777. sq_resetobject(&sqlite3_NULL);
  1778. sq_getstackobj(v, -1, &sqlite3_NULL);
  1779. sq_newtable(v);
  1780. sq_insert_reg_funcs(v, sqlite3_NULL_methods);
  1781. sq_setdelegate(v, -2);
  1782. sq_newslot(v,-3,SQTrue);
  1783. sq_pushstring(v,_SC("sqite3_context"),-1);
  1784. sq_newclass(v,SQFalse);
  1785. sq_settypetag(v,-1,(void*)sq_sqlite3_context_TAG);
  1786. sq_insert_reg_funcs(v, sq_sqlite3_context_methods);
  1787. sq_newslot(v,-3,SQTrue);
  1788. sq_poptop(v); //remove registrytable
  1789. sq_pushstring(v,SQLite3_TAG,-1);
  1790. sq_newclass(v,SQFalse);
  1791. sq_settypetag(v,-1,(void*)SQLite3_TAG);
  1792. sq_insert_reg_funcs(v, sq_sqlite3_methods);
  1793. INT_CONST(v,SQLITE_OPEN_CREATE);
  1794. INT_CONST(v,SQLITE_OPEN_READWRITE);
  1795. INT_CONST(v,SQLITE_OPEN_SHAREDCACHE);
  1796. INT_CONST(v,SQLITE_OPEN_SUBLATIN_NA_LIKE);
  1797. INT_CONST(v,SQLITE_OK);
  1798. INT_CONST(v,SQLITE_INTERRUPT);
  1799. //push sqlite3_NULL as a member
  1800. sq_pushstring(v, nullName,-1);
  1801. sq_pushobject(v, sqlite3_NULL);
  1802. sq_newslot(v,-3,SQTrue);
  1803. sq_newslot(v,-3,SQTrue);
  1804. sq_pushstring(v, SQLite3_Stmt_TAG,-1);
  1805. sq_newclass(v,SQFalse);
  1806. sq_settypetag(v,-1,(void*)SQLite3_Stmt_TAG);
  1807. sq_insert_reg_funcs(v, sq_sqlite3_stmt_methods);
  1808. INT_CONST(v,SQLITE_OK);
  1809. INT_CONST(v,SQLITE_ROW);
  1810. INT_CONST(v,SQLITE_DONE);
  1811. INT_CONST(v,AS_STRING_ALWAYS);
  1812. INT_CONST(v,NULL_AS_EMPTY_STR);
  1813. //push sqlite3_NULL as a member
  1814. sq_pushstring(v, nullName,-1);
  1815. sq_pushobject(v, sqlite3_NULL);
  1816. sq_newslot(v,-3,SQTrue);
  1817. sq_newslot(v,-3,SQTrue);
  1818. return 1;
  1819. }
  1820. #ifdef __cplusplus
  1821. }
  1822. #endif