sq_sqlite3.cpp 82 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863
  1. /* Code generated by script */
  2. #include "sq_sqlite3.h"
  3. //return error if parameter exists but is not a blob
  4. //return 1 if the parameter exists and is a blob
  5. //return 0 if the parameter doesn't exists and creates a new blob
  6. static SQRESULT getOptionalBlob(HSQUIRRELVM v, SQInteger idx, SQBlob **blob)
  7. {
  8. if(sq_gettop(v) >= idx) {
  9. if(SQ_FAILED(sq_getinstanceup(v,3,(SQUserPointer*)blob,(SQUserPointer)SQBlob::SQBlob_TAG)))
  10. return sq_throwerror(v,_SC("expect a blob as second parameter"));
  11. if(!(*blob) || !(*blob)->IsValid())
  12. return sq_throwerror(v,_SC("the blob is invalid"));
  13. } else {
  14. *blob = new SQBlob(0, 8192);
  15. return 0;
  16. }
  17. return 1;
  18. }
  19. static SQRESULT sqlite3_NULL_tostring(HSQUIRRELVM v)
  20. {
  21. sq_pushstring(v, "", 0);
  22. return 1;
  23. }
  24. SQRegFunction sqlite3_NULL_methods[]=
  25. {
  26. {_SC("_tostring"),sqlite3_NULL_tostring,1, _SC(".")},
  27. {0,0}
  28. };
  29. static SQRESULT get_sqlite3_instance(HSQUIRRELVM v, SQInteger idx, sq_sqlite3_sdb **sdb)
  30. {
  31. SQRESULT _rc_;
  32. if((_rc_ = sq_getinstanceup(v,idx,(SQUserPointer*)sdb,(void*)SQLite3_TAG)) < 0) return _rc_;
  33. if(!*sdb) return sq_throwerror(v, _SC("database is closed"));
  34. return _rc_;
  35. }
  36. static SQRESULT get_sqlite3_stmt_instance(HSQUIRRELVM v, SQInteger idx, sqlite3_stmt **stmt)
  37. {
  38. SQRESULT _rc_;
  39. if((_rc_ = sq_getinstanceup(v,idx,(SQUserPointer*)stmt,(void*)SQLite3_Stmt_TAG)) < 0) return _rc_;
  40. if(!*stmt) return sq_throwerror(v, _SC("statement is closed"));
  41. return _rc_;
  42. }
  43. //#define push_sqlite3_null(v) sq_getonregistrytable(v, sqlite3_NULL_Name, sizeof(sqlite3_NULL_Name)-1);
  44. //#define push_sqlite3_null(v) sq_pushobject(v, sqlite3_NULL);
  45. //#define push_sqlite3_null(v) sq_getbyname(v, 1, nullName, sizeof(nullName)-1)
  46. //#define push_sqlite3_null(v) sq_pushfromregistrytable(v, nullName, sizeof(nullName)-1)
  47. //#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);}
  48. //the line bellow is the fastest one, any other attempt till now was slower
  49. #define push_sqlite3_null(v) {sq_pushstring(v, nullName, sizeof(nullName)-1);sq_get(v, 1);}
  50. #define GET_sqlite3_INSTANCE_AT(idx) \
  51. sq_sqlite3_sdb *sdb=NULL; \
  52. if((_rc_ = get_sqlite3_instance(v,idx,&sdb)) < 0) return _rc_;\
  53. sqlite3 *self = sdb->db;
  54. #define GET_sqlite3_INSTANCE() GET_sqlite3_INSTANCE_AT(1)
  55. //#define GET_sqlite3_INSTANCE() SQ_GET_INSTANCE(v, 1, sqlite3, SQLite3_TAG)
  56. #define GET_sqlite3_stmt_INSTANCE() \
  57. sqlite3_stmt *self=NULL; \
  58. if((_rc_ = get_sqlite3_stmt_instance(v,1,&self)) < 0) return _rc_;
  59. enum e_type_result {tr_first_row_first_col, tr_first_row, tr_all_rows, tr_ddml};
  60. #define AS_STRING_ALWAYS 0x01
  61. #define NULL_AS_EMPTY_STR 0x02
  62. #define WITH_COL_NAMES 0x04
  63. #define WITH_BLOB_AS_NULL 0x08
  64. #define WITH_SQ_NULL 0x100
  65. static void sqlite3_stmt_push_string(HSQUIRRELVM v, sqlite3_stmt *stmt, int col, int flags)
  66. {
  67. const char *value = (const char*) sqlite3_column_text(stmt, col);
  68. if(value) sq_pushstring(v, value, sqlite3_column_bytes(stmt, col));
  69. else
  70. {
  71. if(flags & AS_STRING_ALWAYS) sq_pushliteral(v, "");
  72. else push_sqlite3_null(v);
  73. }
  74. }
  75. static SQRESULT sqlite3_stmt_push_value(HSQUIRRELVM v, sqlite3_stmt *stmt, int col, int flags)
  76. {
  77. const char *value;
  78. int col_type = 0;
  79. if(flags & WITH_BLOB_AS_NULL)
  80. {
  81. col_type = sqlite3_column_type(stmt, col);
  82. if(col_type == SQLITE_BLOB)
  83. {
  84. if(flags & AS_STRING_ALWAYS) sq_pushliteral(v, "");
  85. else push_sqlite3_null(v);
  86. return 1;
  87. }
  88. }
  89. if(flags & AS_STRING_ALWAYS)
  90. {
  91. sqlite3_stmt_push_string(v, stmt, col, flags);
  92. }
  93. else
  94. {
  95. if(!col_type) col_type = sqlite3_column_type(stmt, col);
  96. switch (col_type)
  97. {
  98. case SQLITE_INTEGER:
  99. {
  100. sqlite_int64 i64 = sqlite3_column_int64(stmt, col);
  101. SQInteger n = (SQInteger)i64;
  102. if (n == i64)
  103. sq_pushinteger(v, n);
  104. else
  105. sq_pushstring(v, (const char*) sqlite3_column_text(stmt, col), sqlite3_column_bytes(stmt, col));
  106. }
  107. break;
  108. case SQLITE_FLOAT:
  109. sq_pushfloat(v, sqlite3_column_double(stmt, col));
  110. break;
  111. case SQLITE_TEXT:
  112. sqlite3_stmt_push_string(v, stmt, col, flags);
  113. break;
  114. case SQLITE_BLOB:
  115. value = (const char*) sqlite3_column_blob(stmt, col);
  116. if(value) sq_pushstring(v, value, sqlite3_column_bytes(stmt, col));
  117. else push_sqlite3_null(v);
  118. break;
  119. case SQLITE_NULL:
  120. if(flags & WITH_SQ_NULL) sq_pushnull(v);
  121. else push_sqlite3_null(v);
  122. break;
  123. default:
  124. if(flags & WITH_SQ_NULL) sq_pushnull(v);
  125. else push_sqlite3_null(v);
  126. break;
  127. }
  128. }
  129. return 1;
  130. }
  131. static void sqlite3_stmt_row_asArray(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags)
  132. {
  133. int col_count = sqlite3_column_count(stmt);
  134. sq_newarray(v, col_count);
  135. for(int i=0; i<col_count; ++i)
  136. {
  137. sqlite3_stmt_push_value(v, stmt, i, flags);
  138. sq_arrayset(v, -2, i);
  139. }
  140. }
  141. static void sqlite3_stmt_row_asTable(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags)
  142. {
  143. int col_count = sqlite3_column_count(stmt);
  144. sq_newtable(v);
  145. for(int i=0; i<col_count; ++i)
  146. {
  147. sq_pushstring(v, sqlite3_column_name(stmt, i), -1);
  148. sqlite3_stmt_push_value(v, stmt, i, flags);
  149. sq_rawset(v, -3);
  150. }
  151. }
  152. static void sqlite3_stmt_asArrayOfArrays(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags)
  153. {
  154. sq_newarray(v, 0);
  155. if(flags & WITH_COL_NAMES)
  156. {
  157. int col_count = sqlite3_column_count(stmt);
  158. sq_newarray(v, col_count);
  159. for(int i=0; i<col_count; ++i)
  160. {
  161. sq_pushstring(v, sqlite3_column_name(stmt, i), -1);
  162. sq_arrayset(v, -2, i);
  163. }
  164. sq_arrayappend(v, -2);
  165. }
  166. while(sqlite3_step(stmt) == SQLITE_ROW)
  167. {
  168. sqlite3_stmt_row_asArray(v, stmt, flags);
  169. sq_arrayappend(v, -2);
  170. }
  171. }
  172. static void sqlite3_stmt_asArrayOfTables(HSQUIRRELVM v, sqlite3_stmt *stmt, int flags)
  173. {
  174. sq_newarray(v, 0);
  175. while(sqlite3_step(stmt) == SQLITE_ROW)
  176. {
  177. sqlite3_stmt_row_asTable(v, stmt, flags);
  178. sq_arrayappend(v, -2);
  179. }
  180. }
  181. static SQRESULT sqlite3_stmt_bind_value(HSQUIRRELVM v, sqlite3_stmt *stmt, int npar, int argn)
  182. {
  183. int _rc_ = 0;
  184. SQObjectType ptype = sq_gettype(v, argn);
  185. switch(ptype)
  186. {
  187. case OT_BOOL:
  188. SQ_GET_BOOL(v, argn, param_bool);
  189. _rc_ = sqlite3_bind_int(stmt, npar, param_bool == SQTrue ? 1 : 0);
  190. break;
  191. case OT_INTEGER:
  192. SQ_GET_INTEGER(v, argn, param_integer);
  193. _rc_ = sqlite3_bind_int64(stmt, npar, param_integer);
  194. break;
  195. case OT_FLOAT:
  196. SQ_GET_FLOAT(v, argn, param_float);
  197. _rc_ = sqlite3_bind_double(stmt, npar, param_float);
  198. break;
  199. case OT_STRING:
  200. {
  201. SQ_GET_STRING(v, argn, param_string);
  202. _rc_ = sqlite3_bind_text(stmt, npar, param_string, param_string_size, SQLITE_TRANSIENT);
  203. }
  204. break;
  205. case OT_NULL:
  206. _rc_ = sqlite3_bind_null(stmt, npar);
  207. break;
  208. default:
  209. return sq_throwerror(v, "Invalid bind parameter %d", npar);
  210. }
  211. if(_rc_ != SQLITE_OK)
  212. {
  213. sqlite3 *db = sqlite3_db_handle(stmt);
  214. return sq_throwerror(v, sqlite3_errmsg(db));
  215. }
  216. return SQ_OK;
  217. }
  218. static SQRESULT sq_sqlite3_stmt_prepare_aux(HSQUIRRELVM v, sqlite3 *db, sqlite3_stmt **stmt, int params_start)
  219. {
  220. SQ_FUNC_VARS(v);
  221. SQ_GET_STRING(v, params_start, szSQL);
  222. if(sqlite3_prepare_v2(db, szSQL, szSQL_size, stmt, 0) != SQLITE_OK)
  223. {
  224. return sq_throwerror(v, sqlite3_errmsg(db));
  225. }
  226. if(_top_ > params_start)
  227. {
  228. int nparams = sqlite3_bind_parameter_count(*stmt);
  229. int nparams_given = _top_-params_start;
  230. if(nparams != nparams_given)
  231. {
  232. return sq_throwerror(v, "expect %d parameters but only %d given", nparams, nparams_given);
  233. }
  234. for(int i=1; i <= nparams; ++i)
  235. {
  236. int argn = i+params_start;
  237. _rc_ = sqlite3_stmt_bind_value(v, *stmt, i, argn);
  238. if(_rc_ < 0) return _rc_;
  239. }
  240. }
  241. return SQ_OK;
  242. }
  243. static SQRESULT sq_sqlite3_stmt_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  244. {
  245. sqlite3_stmt *stmt = ((sqlite3_stmt *)p);
  246. if(stmt) sqlite3_finalize(stmt);
  247. return 0;
  248. }
  249. static SQRESULT sq_sqlite3_stmt_constructor(HSQUIRRELVM v)
  250. {
  251. SQ_FUNC_VARS(v);
  252. _rc_ = SQ_ERROR;
  253. GET_sqlite3_INSTANCE_AT(2);
  254. sqlite3_stmt *stmt = 0;
  255. if(_top_ > 2)
  256. {
  257. _rc_ = sq_sqlite3_stmt_prepare_aux(v, self, &stmt, 3);
  258. }
  259. else
  260. {
  261. if(sqlite3_prepare_v2(self, "select 'statement not prepared';", -1, &stmt, 0) != SQLITE_OK)
  262. {
  263. _rc_ = sq_throwerror(v, sqlite3_errmsg(self));
  264. }
  265. else _rc_ = SQ_OK;
  266. }
  267. sq_setinstanceup(v, 1, stmt); //replace self for this instance with this new sqlite3_stmt
  268. sq_setreleasehook(v,1, sq_sqlite3_stmt_releasehook);
  269. return _rc_;
  270. }
  271. static SQRESULT sq_sqlite3_stmt_get_db(HSQUIRRELVM v)
  272. {
  273. SQ_FUNC_VARS_NO_TOP(v);
  274. GET_sqlite3_stmt_INSTANCE();
  275. sqlite3 *db = sqlite3_db_handle(self);
  276. sq_pushuserpointer(v, db);
  277. if(sq_getonregistrytable(v) == SQ_OK)
  278. {
  279. sq_getweakrefval(v, -1);
  280. }
  281. else return sq_throwerror(v, _SC("could not retrive database, maybe it was already closed"));
  282. return 1;
  283. }
  284. static SQRESULT sq_sqlite3_stmt_stmt_ptr(HSQUIRRELVM v)
  285. {
  286. SQ_FUNC_VARS_NO_TOP(v);
  287. GET_sqlite3_stmt_INSTANCE();
  288. sq_pushuserpointer(v, self);
  289. return 1;
  290. }
  291. static SQRESULT sq_sqlite3_stmt_finalize(HSQUIRRELVM v)
  292. {
  293. SQ_FUNC_VARS_NO_TOP(v);
  294. GET_sqlite3_stmt_INSTANCE();
  295. sq_setinstanceup(v, 1, 0); //next calls will fail with "statement is closed"
  296. //printf("sq_sqlite3_stmt_finalize: %p : %s\n", self, sqlite3_sql(self));
  297. sq_pushinteger(v, sqlite3_finalize(self));
  298. return 1;
  299. }
  300. static SQRESULT sq_sqlite3_stmt_prepare(HSQUIRRELVM v)
  301. {
  302. SQ_FUNC_VARS_NO_TOP(v);
  303. GET_sqlite3_stmt_INSTANCE();
  304. sqlite3 *db = sqlite3_db_handle(self);
  305. sqlite3_stmt *stmt = 0;
  306. _rc_ = sq_sqlite3_stmt_prepare_aux(v, db, &stmt, 2);
  307. if(stmt)
  308. {
  309. sqlite3_finalize(self); //finalize the previous sqlite3_stmt
  310. sq_setinstanceup(v, 1, stmt); //replace self for this instance with this new sqlite3_stmt
  311. }
  312. return _rc_;
  313. }
  314. static SQRESULT sq_sqlite3_stmt_get_sql(HSQUIRRELVM v)
  315. {
  316. SQ_FUNC_VARS_NO_TOP(v);
  317. GET_sqlite3_stmt_INSTANCE();
  318. sq_pushstring(v, sqlite3_sql(self), -1);
  319. return 1;
  320. }
  321. static SQRESULT sq_sqlite3_stmt_bind(HSQUIRRELVM v)
  322. {
  323. SQ_FUNC_VARS_NO_TOP(v);
  324. GET_sqlite3_stmt_INSTANCE();
  325. SQ_GET_INTEGER(v, 2, npar);
  326. return sqlite3_stmt_bind_value(v, self, npar, 3);
  327. }
  328. static SQRESULT sq_sqlite3_stmt_bind_empty_null(HSQUIRRELVM v)
  329. {
  330. SQ_FUNC_VARS_NO_TOP(v);
  331. GET_sqlite3_stmt_INSTANCE();
  332. SQ_GET_INTEGER(v, 2, npar);
  333. if(sq_gettype(v, 3) == OT_STRING && sq_getsize(v, 3) == 0)
  334. {
  335. sq_pushnull(v);
  336. sq_replace(v, 3);
  337. }
  338. return sqlite3_stmt_bind_value(v, self, npar, 3);
  339. }
  340. static SQRESULT sq_sqlite3_stmt_bind_blob(HSQUIRRELVM v)
  341. {
  342. SQ_FUNC_VARS_NO_TOP(v);
  343. GET_sqlite3_stmt_INSTANCE();
  344. SQ_GET_INTEGER(v, 2, npar);
  345. SQ_GET_STRING(v, 3, blob);
  346. if(sqlite3_bind_blob(self, npar, blob, blob_size, SQLITE_TRANSIENT) != SQLITE_OK)
  347. {
  348. sqlite3 *db = sqlite3_db_handle(self);
  349. return sq_throwerror(v, sqlite3_errmsg(db));
  350. }
  351. return SQ_OK;
  352. }
  353. static SQRESULT sq_sqlite3_stmt_bind_values(HSQUIRRELVM v)
  354. {
  355. SQ_FUNC_VARS(v);
  356. GET_sqlite3_stmt_INSTANCE();
  357. if (_top_ - 1 != sqlite3_bind_parameter_count(self))
  358. return sq_throwerror(v,
  359. _SC("incorrect number of parameters to bind (%d given, %d to bind)"),
  360. _top_ - 1,
  361. sqlite3_bind_parameter_count(self));
  362. for (int n = 2; n <= _top_; ++n)
  363. {
  364. if (sqlite3_stmt_bind_value(v, self, n-1, n) != SQ_OK) return SQ_ERROR;
  365. }
  366. return 0;
  367. }
  368. static SQRESULT sq_sqlite3_stmt_bind_names(HSQUIRRELVM v)
  369. {
  370. SQ_FUNC_VARS_NO_TOP(v);
  371. GET_sqlite3_stmt_INSTANCE();
  372. SQObjectType ptype = sq_gettype(v, 2);
  373. int count = sqlite3_bind_parameter_count(self);
  374. int result;
  375. for (int n = 1; n <= count; ++n)
  376. {
  377. const char *name = sqlite3_bind_parameter_name(self, n);
  378. if (name && (name[0] == ':' || name[0] == '$' || name[0] == '@'))
  379. {
  380. if(ptype == OT_TABLE)
  381. {
  382. sq_pushstring(v, ++name, -1);
  383. if(sq_get(v, 2) == SQ_OK)
  384. {
  385. result = sqlite3_stmt_bind_value(v, self, n, -1);
  386. sq_poptop(v);
  387. }
  388. else return sq_throwerror(v, _SC("bind parameter (%s) not found"), name);
  389. }
  390. else return sq_throwerror(v, _SC("table expected to bind named parameters"));
  391. }
  392. else
  393. {
  394. if(ptype == OT_ARRAY)
  395. {
  396. sq_pushinteger(v, n);
  397. if(sq_get(v, 2) == SQ_OK)
  398. {
  399. result = sqlite3_stmt_bind_value(v, self, n, -1);
  400. sq_poptop(v);
  401. }
  402. else return sq_throwerror(v, _SC("bind parameter (%d) not found"), n);
  403. }
  404. else return sq_throwerror(v, _SC("array expected to bind numbered parameters"));
  405. }
  406. if (result != SQ_OK) return result;
  407. }
  408. return 0;
  409. }
  410. static SQRESULT sq_sqlite3_stmt_bind_parameter_index(HSQUIRRELVM v)
  411. {
  412. SQ_FUNC_VARS_NO_TOP(v);
  413. GET_sqlite3_stmt_INSTANCE();
  414. SQ_GET_STRING(v, 2, spar);
  415. sq_pushinteger(v, sqlite3_bind_parameter_index(self, spar));
  416. return 1;
  417. }
  418. static SQRESULT sq_sqlite3_stmt_bind_parameter_count(HSQUIRRELVM v)
  419. {
  420. SQ_FUNC_VARS_NO_TOP(v);
  421. GET_sqlite3_stmt_INSTANCE();
  422. sq_pushinteger(v, sqlite3_bind_parameter_count(self));
  423. return 1;
  424. }
  425. static SQRESULT sq_sqlite3_stmt_reset(HSQUIRRELVM v)
  426. {
  427. SQ_FUNC_VARS_NO_TOP(v);
  428. GET_sqlite3_stmt_INSTANCE();
  429. sq_pushinteger(v, sqlite3_reset(self));
  430. return 1;
  431. }
  432. static SQRESULT sq_sqlite3_stmt_step(HSQUIRRELVM v)
  433. {
  434. SQ_FUNC_VARS_NO_TOP(v);
  435. GET_sqlite3_stmt_INSTANCE();
  436. sq_pushinteger(v, sqlite3_step(self));
  437. return 1;
  438. }
  439. static SQRESULT sq_sqlite3_stmt_next_row(HSQUIRRELVM v)
  440. {
  441. SQ_FUNC_VARS_NO_TOP(v);
  442. GET_sqlite3_stmt_INSTANCE();
  443. sq_pushbool(v, sqlite3_step(self) == SQLITE_ROW);
  444. return 1;
  445. }
  446. static SQRESULT sq_sqlite3_stmt_col_count(HSQUIRRELVM v)
  447. {
  448. SQ_FUNC_VARS_NO_TOP(v);
  449. GET_sqlite3_stmt_INSTANCE();
  450. sq_pushinteger(v, sqlite3_column_count(self));
  451. return 1;
  452. }
  453. static SQRESULT sq_sqlite3_stmt_col_name(HSQUIRRELVM v)
  454. {
  455. SQ_FUNC_VARS_NO_TOP(v);
  456. GET_sqlite3_stmt_INSTANCE();
  457. SQ_GET_INTEGER(v, 2, col);
  458. sq_pushstring(v, sqlite3_column_name(self, col), -1);
  459. return 1;
  460. }
  461. static SQRESULT sq_sqlite3_stmt_col_type(HSQUIRRELVM v)
  462. {
  463. SQ_FUNC_VARS_NO_TOP(v);
  464. GET_sqlite3_stmt_INSTANCE();
  465. SQ_GET_INTEGER(v, 2, col);
  466. sq_pushinteger(v, sqlite3_column_type(self, col));
  467. return 1;
  468. }
  469. static const char *get_column_type(sqlite3_stmt *stmt, int col)
  470. {
  471. const char *column_type;
  472. int icol_type = sqlite3_column_type(stmt, col);
  473. switch(icol_type)
  474. {
  475. case SQLITE_INTEGER: column_type = "INTEGER"; break;
  476. case SQLITE_FLOAT: column_type = "FLOAT"; break;
  477. case SQLITE_BLOB: column_type = "BLOB"; break;
  478. case SQLITE_TEXT: column_type = "TEXT"; break;
  479. case SQLITE_NULL: column_type = "NULL"; break;
  480. default:
  481. column_type = "unknown";
  482. }
  483. return column_type;
  484. }
  485. static const char *get_column_dcltype(sqlite3_stmt *stmt, int col)
  486. {
  487. const char *column_type = sqlite3_column_decltype(stmt, col);
  488. if(!column_type) column_type = get_column_type(stmt, col);
  489. return column_type;
  490. }
  491. static SQRESULT sq_sqlite3_stmt_col_declared_type(HSQUIRRELVM v)
  492. {
  493. SQ_FUNC_VARS_NO_TOP(v);
  494. GET_sqlite3_stmt_INSTANCE();
  495. SQ_GET_INTEGER(v, 2, col);
  496. sq_pushstring(v, get_column_dcltype(self, col), -1);
  497. return 1;
  498. }
  499. static SQRESULT sq_sqlite3_stmt_colsAsArray(HSQUIRRELVM v)
  500. {
  501. SQ_FUNC_VARS_NO_TOP(v);
  502. GET_sqlite3_stmt_INSTANCE();
  503. int col_count = sqlite3_column_count(self);
  504. sq_newarray(v, col_count);
  505. for(int i=0; i<col_count; ++i)
  506. {
  507. sq_pushstring(v, sqlite3_column_name(self, i), -1);
  508. sq_arrayset(v, -2, i);
  509. }
  510. return 1;
  511. }
  512. static SQRESULT sq_sqlite3_stmt_colsTypeAsArray(HSQUIRRELVM v)
  513. {
  514. SQ_FUNC_VARS_NO_TOP(v);
  515. GET_sqlite3_stmt_INSTANCE();
  516. int col_count = sqlite3_column_count(self);
  517. sq_newarray(v, col_count);
  518. for(int i=0; i<col_count; ++i)
  519. {
  520. sq_pushstring(v, get_column_type(self, i), -1);
  521. sq_arrayset(v, -2, i);
  522. }
  523. return 1;
  524. }
  525. static SQRESULT sq_sqlite3_stmt_colsDeclTypeAsArray(HSQUIRRELVM v)
  526. {
  527. SQ_FUNC_VARS_NO_TOP(v);
  528. GET_sqlite3_stmt_INSTANCE();
  529. int col_count = sqlite3_column_count(self);
  530. sq_newarray(v, col_count);
  531. for(int i=0; i<col_count; ++i)
  532. {
  533. sq_pushstring(v, get_column_dcltype(self, i), -1);
  534. sq_arrayset(v, -2, i);
  535. }
  536. return 1;
  537. }
  538. static SQRESULT sq_sqlite3_stmt_colsNameAsArray(HSQUIRRELVM v)
  539. {
  540. SQ_FUNC_VARS_NO_TOP(v);
  541. GET_sqlite3_stmt_INSTANCE();
  542. int col_count = sqlite3_column_count(self);
  543. sq_newarray(v, col_count);
  544. for(int i=0; i<col_count; ++i)
  545. {
  546. sq_pushstring(v, sqlite3_column_name(self, i), -1);
  547. sq_arrayset(v, -2, i);
  548. }
  549. return 1;
  550. }
  551. static SQRESULT sq_sqlite3_stmt_colsAsTable(HSQUIRRELVM v)
  552. {
  553. SQ_FUNC_VARS_NO_TOP(v);
  554. GET_sqlite3_stmt_INSTANCE();
  555. int col_count = sqlite3_column_count(self);
  556. sq_newtable(v);
  557. for(int i=0; i<col_count; ++i)
  558. {
  559. sq_pushstring(v, sqlite3_column_name(self, i), -1);
  560. sq_pushinteger(v, i);
  561. sq_rawset(v, -3);
  562. }
  563. return 1;
  564. }
  565. static int get_col_index(HSQUIRRELVM v, sqlite3_stmt *self)
  566. {
  567. SQInteger _rc_, col;
  568. switch(sq_gettype(v, 2))
  569. {
  570. case OT_INTEGER:
  571. sq_getinteger(v, 2, &col);
  572. break;
  573. case OT_STRING:
  574. {
  575. SQ_GET_STRING(v, 2, col_name);
  576. if(col_name_size == 0) return sq_throwerror(v, "column name can not be empty");
  577. col = -1;
  578. for(int i=0, len=sqlite3_column_count(self); i<len; ++i)
  579. {
  580. if(strcasecmp(col_name, sqlite3_column_name(self, i)) == 0)
  581. {
  582. col = i;
  583. break;
  584. }
  585. }
  586. if(col == -1) return sq_throwerror(v, "column name not found \"%s\"", col_name);
  587. }
  588. break;
  589. default:
  590. return sq_throwerror(v, "wrong parameter expected integer|string");
  591. }
  592. return col;
  593. }
  594. static SQRESULT sq_sqlite3_stmt_col(HSQUIRRELVM v)
  595. {
  596. SQ_FUNC_VARS_NO_TOP(v);
  597. GET_sqlite3_stmt_INSTANCE();
  598. int col = get_col_index(v, self);
  599. if(col < 0) return col;
  600. sqlite3_stmt_push_value(v, self, col, 0);
  601. return 1;
  602. }
  603. static SQRESULT sq_sqlite3_stmt_asBool(HSQUIRRELVM v)
  604. {
  605. SQ_FUNC_VARS_NO_TOP(v);
  606. GET_sqlite3_stmt_INSTANCE();
  607. int col = get_col_index(v, self);
  608. if(col < 0) return col;
  609. const unsigned char *b = sqlite3_column_text(self, col);
  610. sq_pushbool(v, b && *b == '1');
  611. return 1;
  612. }
  613. static SQRESULT sq_sqlite3_stmt_asInteger(HSQUIRRELVM v)
  614. {
  615. SQ_FUNC_VARS_NO_TOP(v);
  616. GET_sqlite3_stmt_INSTANCE();
  617. int col = get_col_index(v, self);
  618. if(col < 0) return col;
  619. sq_pushinteger(v, sqlite3_column_int64(self, col));
  620. return 1;
  621. }
  622. static SQRESULT sq_sqlite3_stmt_asFloat(HSQUIRRELVM v)
  623. {
  624. SQ_FUNC_VARS_NO_TOP(v);
  625. GET_sqlite3_stmt_INSTANCE();
  626. int col = get_col_index(v, self);
  627. if(col < 0) return col;
  628. sq_pushfloat(v, sqlite3_column_double(self, col));
  629. return 1;
  630. }
  631. static SQRESULT sq_sqlite3_stmt_StringOrNull(HSQUIRRELVM v, int withNull)
  632. {
  633. SQ_FUNC_VARS_NO_TOP(v);
  634. GET_sqlite3_stmt_INSTANCE();
  635. int col = get_col_index(v, self);
  636. if(col < 0) return col;
  637. sqlite3_stmt_push_string(v, self, col, withNull ? 0 : NULL_AS_EMPTY_STR);
  638. return 1;
  639. }
  640. static SQRESULT sq_sqlite3_stmt_asString(HSQUIRRELVM v)
  641. {
  642. return sq_sqlite3_stmt_StringOrNull(v, 0);
  643. }
  644. static SQRESULT sq_sqlite3_stmt_asStringOrNull(HSQUIRRELVM v)
  645. {
  646. return sq_sqlite3_stmt_StringOrNull(v, 1);
  647. }
  648. static SQRESULT sq_sqlite3_stmt_asTable(HSQUIRRELVM v)
  649. {
  650. SQ_FUNC_VARS(v);
  651. GET_sqlite3_stmt_INSTANCE();
  652. SQ_OPT_INTEGER(v, 2, flags, 0);
  653. sqlite3_stmt_row_asTable(v, self, flags);
  654. return 1;
  655. }
  656. static SQRESULT sq_sqlite3_stmt_asArray(HSQUIRRELVM v)
  657. {
  658. SQ_FUNC_VARS(v);
  659. GET_sqlite3_stmt_INSTANCE();
  660. SQ_OPT_INTEGER(v, 2, flags, 0);
  661. sqlite3_stmt_row_asArray(v, self, flags);
  662. return 1;
  663. }
  664. static SQRESULT sq_sqlite3_stmt_asArrayOfArrays(HSQUIRRELVM v)
  665. {
  666. SQ_FUNC_VARS(v);
  667. GET_sqlite3_stmt_INSTANCE();
  668. SQ_OPT_INTEGER(v, 2, flags, 0);
  669. sqlite3_stmt_asArrayOfArrays(v, self, flags);
  670. sqlite3_reset(self);
  671. return 1;
  672. }
  673. static SQRESULT sq_sqlite3_stmt_asArrayOfTables(HSQUIRRELVM v)
  674. {
  675. SQ_FUNC_VARS(v);
  676. GET_sqlite3_stmt_INSTANCE();
  677. SQ_OPT_INTEGER(v, 2, flags, 0);
  678. sqlite3_stmt_asArrayOfTables(v, self, flags);
  679. sqlite3_reset(self);
  680. return 1;
  681. }
  682. /*utility functions*/
  683. static void append_escaping_json(SQBlob &json, const char *sz)
  684. {
  685. if(sz) //escape string
  686. {
  687. int last_idx, idx;
  688. idx = last_idx = 0;
  689. for(; sz[idx]; ++idx)
  690. {
  691. char c = sz[idx];
  692. switch(c)
  693. {
  694. case '"':
  695. case '\n':
  696. case '\r':
  697. case '\t':
  698. case '\b':
  699. case '\f':
  700. case '\\':
  701. {
  702. json.Write(sz+last_idx, idx-last_idx);
  703. last_idx = idx;
  704. if(c == '\n')
  705. {
  706. json.Write("\\n", 2);
  707. ++last_idx;
  708. }
  709. else if(c == '\t')
  710. {
  711. json.Write("\\t", 2);
  712. ++last_idx;
  713. }
  714. else if(c == '\b')
  715. {
  716. json.Write("\\b", 2);
  717. ++last_idx;
  718. }
  719. else if(c == '\f')
  720. {
  721. json.Write("\\f", 2);
  722. ++last_idx;
  723. }
  724. else if(c == '\r')
  725. {
  726. json.Write("\\r", 2);
  727. ++last_idx;
  728. }
  729. else
  730. {
  731. json.Write("\\", 1);
  732. }
  733. }
  734. }
  735. }
  736. //last part
  737. json.Write(sz+last_idx, idx-last_idx);
  738. }
  739. }
  740. static SQRESULT sq_sqlite3_stmt_asJsonArray(HSQUIRRELVM v)
  741. {
  742. SQ_FUNC_VARS(v);
  743. GET_sqlite3_stmt_INSTANCE();
  744. SQ_OPT_BOOL(v, 2, withMetadata, 0);
  745. int col_count = sqlite3_column_count(self);
  746. int i, value_type;
  747. const char* value;
  748. SQBlob *json = NULL;
  749. int has_blob = getOptionalBlob(v, 3, &json);
  750. if(has_blob == SQ_ERROR) return SQ_ERROR;
  751. if(withMetadata)
  752. {
  753. json->WriteZstr("{\n\"columns\":[\n");
  754. for(i=0; i < col_count; ++i)
  755. {
  756. json->WriteZstr((i == 0 ? "\"" : ",\""));
  757. const char *column_name = sqlite3_column_name(self, i);
  758. json->WriteZstr(column_name ? column_name : "unknown");
  759. json->WriteZstr("\"");
  760. }
  761. json->WriteZstr("\n],\n\"column_types\":[\n");
  762. for(i=0; i < col_count; ++i)
  763. {
  764. json->WriteZstr((i == 0 ? "\"" : ",\""));
  765. json->WriteZstr(get_column_dcltype(self, i));
  766. json->WriteZstr("\"");
  767. }
  768. json->WriteZstr("\n],\n\"rows\":[\n");
  769. }
  770. else
  771. {
  772. json->WriteZstr("[\n");
  773. }
  774. int row_count = 0;
  775. while(sqlite3_step(self) == SQLITE_ROW)
  776. {
  777. json->WriteZstr((row_count++ == 0 ? "[" : ",["));
  778. for(i=0; i < col_count; ++i)
  779. {
  780. json->WriteZstr((i == 0 ? "\"" : ",\""));
  781. //if get the type after sqlite3_column_text it always returns SQLITE_TEXT
  782. value_type = sqlite3_column_type(self, i);
  783. value = (const char*)sqlite3_column_text(self, i);
  784. if(value)
  785. {
  786. switch(value_type)
  787. {
  788. case SQLITE_BLOB:
  789. break; //no blobs in json
  790. case SQLITE_TEXT:
  791. {
  792. append_escaping_json(*json, value);
  793. }
  794. break;
  795. default:
  796. json->WriteZstr(value);
  797. }
  798. }
  799. json->WriteZstr("\"");
  800. }
  801. json->WriteZstr("]\n");
  802. }
  803. json->WriteZstr("]");
  804. if(withMetadata) json->WriteZstr("\n}");
  805. if(has_blob) return 0;
  806. sq_pushstring(v, (const SQChar*)json->GetBuf(), json->Len());
  807. delete json;
  808. return 1;
  809. }
  810. static SQRESULT sq_sqlite3_stmt_asJsonObject(HSQUIRRELVM v)
  811. {
  812. SQ_FUNC_VARS_NO_TOP(v);
  813. GET_sqlite3_stmt_INSTANCE();
  814. int col_count = sqlite3_column_count(self);
  815. int i, value_type, record_count = 0;
  816. const char* value;
  817. SQBlob *json = NULL;
  818. int has_blob = getOptionalBlob(v, 2, &json);
  819. if(has_blob == SQ_ERROR) return SQ_ERROR;
  820. json->WriteZstr("{");
  821. if(sqlite3_step(self) == SQLITE_ROW)
  822. {
  823. ++record_count;
  824. for(i=0; i < col_count; ++i)
  825. {
  826. json->WriteZstr((i == 0 ? "\"" : "\",\""));
  827. append_escaping_json(*json, (const char*)sqlite3_column_name(self, i));
  828. json->WriteZstr("\":\"");
  829. //if get the type after sqlite3_column_text it always returns SQLITE_TEXT
  830. value_type = sqlite3_column_type(self, i);
  831. value = (const char*)sqlite3_column_text(self, i);
  832. if(value)
  833. {
  834. switch(value_type)
  835. {
  836. case SQLITE_BLOB:
  837. break; //no blobs in json
  838. case SQLITE_TEXT:
  839. {
  840. append_escaping_json(*json, value);
  841. }
  842. break;
  843. default:
  844. json->WriteZstr(value);
  845. }
  846. }
  847. }
  848. json->WriteZstr("\"");
  849. }
  850. json->WriteZstr("}");
  851. if(has_blob) return 0;
  852. if(record_count) sq_pushstring(v, (const SQChar*)json->GetBuf(), json->Len());
  853. else sq_pushnull(v);
  854. delete json;
  855. return 1;
  856. }
  857. #define UNSIGNED(n) n##U
  858. #define IBYTE1 UNSIGNED(255)
  859. #define IBYTE2 UNSIGNED(255*255)
  860. #define IBYTE3 UNSIGNED(255*255*255)
  861. #define IBYTE4 UNSIGNED(255*255*255*255)
  862. #define SIZE1BYTE 250
  863. #define SIZE2BYTE 251
  864. #define SIZE3BYTE 252
  865. #define SIZE4BYTE 253
  866. #define SLEMARK 254
  867. #define SLEEND 255
  868. static SQRESULT sle2array(HSQUIRRELVM v, const unsigned char *p, size_t sle_size, const unsigned char **next)
  869. {
  870. size_t size, data_len = 0;
  871. if(sle_size == 0)
  872. {
  873. *next = 0;
  874. return 0;
  875. }
  876. while(*p != SLEEND) //data finished now follow digest
  877. {
  878. size = *p++;
  879. if(size >= SIZE1BYTE)
  880. {
  881. if(size == SIZE1BYTE)
  882. {
  883. //data bigger than 250 and less 500 next byte has more info
  884. size += *p++;
  885. }
  886. else if(size == SIZE2BYTE)
  887. {
  888. //data bigger than 250 next two bytes has more info
  889. size = (*p++ * IBYTE1);
  890. size += *p++;
  891. }
  892. else if(size == SIZE3BYTE)
  893. {
  894. //data bigger than 250 next three bytes has more info
  895. size = (*p++ * IBYTE2);
  896. size += (*p++ * IBYTE1);
  897. size += *p++;
  898. }
  899. else if(size == SIZE4BYTE)
  900. {
  901. //data bigger than 250 next four bytes has more info
  902. size = (*p++ * IBYTE3);
  903. size += (*p++ * IBYTE2);
  904. size += (*p++ * IBYTE1);
  905. size += *p++;
  906. }
  907. else if(size == SLEMARK)
  908. {
  909. //reserved can be used for multi part data, metadata, digest, ...
  910. break;
  911. }
  912. }
  913. sq_pushstring(v, (const char*)p, size);
  914. sq_arrayappend(v, -2);
  915. p += size;
  916. data_len += size;
  917. if(data_len > sle_size)
  918. {
  919. //something went wrong here
  920. return sq_throwerror(v, "We got more data than expected !");
  921. }
  922. }
  923. *next = ++p;
  924. return 0;
  925. }
  926. static SQRESULT sle2vec(HSQUIRRELVM v, const unsigned char *sle,
  927. size_t sle_size,
  928. const unsigned char **next)
  929. {
  930. int rc;
  931. sq_newarray(v, 0);
  932. if(sle[0] != '[')
  933. {
  934. return sq_throwerror(v, "Invalid encoded vector !");
  935. }
  936. if(sle[1] == ']')
  937. {
  938. *next = sle+2; //empty array
  939. return 0;
  940. }
  941. if((rc = sle2array(v, sle+1, sle_size-1, next)) < 0) return rc;
  942. if(!*next || *next[0] != ']')
  943. {
  944. return sq_throwerror(v, "Invalid end of vector !");
  945. }
  946. (*next)++;
  947. return 0;
  948. }
  949. static SQRESULT sq_sle2vecOfvec(HSQUIRRELVM v)
  950. {
  951. SQ_FUNC_VARS(v);
  952. SQBlob *blob = NULL;
  953. const SQChar *sle, *sle_start;
  954. SQInteger sle_size;
  955. SQObjectType ptype = sq_gettype(v, 2);
  956. switch(ptype)
  957. {
  958. case OT_STRING:
  959. sq_getstr_and_size(v, 2, &sle, &sle_size);
  960. break;
  961. case OT_INSTANCE:
  962. if(SQ_FAILED(sq_getinstanceup(v,2,(SQUserPointer*)&blob,(SQUserPointer)SQBlob::SQBlob_TAG)))
  963. return sq_throwerror(v,_SC("invalid type tag"));
  964. if(!blob || !blob->IsValid())
  965. return sq_throwerror(v,_SC("the blob is invalid"));
  966. sle = (const SQChar*)blob->GetBuf();
  967. sle_size = blob->Len();
  968. break;
  969. default:
  970. return sq_throwerror(v,_SC("invalid parameter 1 of type %s"), sq_gettypename(v, 2));
  971. }
  972. if(sq_gettype(v, 3) != OT_ARRAY)
  973. return sq_throwerror(v,_SC("invalid parameter 2 of type %s"), sq_gettypename(v, 3));
  974. SQ_OPT_INTEGER(v, 4, start, 0);
  975. if(start < 0) return sq_throwerror(v, _SC("invalid start position (%d)"), start);
  976. sq_push(v, 3);
  977. int rc, data_count = 1;
  978. const unsigned char *next;
  979. sle_start = sle + start;
  980. sle_size -= start;
  981. if(sle_start[0] != '[')
  982. {
  983. return sq_throwerror(v, "Invalid encoded vector !");
  984. }
  985. if(sle_start[1] == ']')
  986. {
  987. //sq_pushinteger(v, start+2);
  988. return 1; //empty array
  989. }
  990. int saved_top = sq_gettop(v);
  991. if((rc=sle2vec(v, (const unsigned char *)sle_start+1, sle_size-1, &next)) < 0) return rc;
  992. while(next && *next == '[')
  993. {
  994. sq_arrayappend(v, -2);
  995. data_count++;
  996. if((rc=sle2vec(v, next, sle_size - (next - (const unsigned char *)sle_start), &next)) < 0) return rc;
  997. }
  998. if(sq_gettop(v) != saved_top)
  999. {
  1000. //last added table left
  1001. sq_arrayappend(v, -2);
  1002. data_count++;
  1003. }
  1004. if(!next || *next != ']')
  1005. {
  1006. return sq_throwerror(v, "Invalid end of vector !");
  1007. }
  1008. sq_pushinteger(v, ((const SQChar*)(++next)) - sle);
  1009. return 1;
  1010. }
  1011. typedef unsigned char slebuf_t[8];
  1012. static int sleSize2buf(slebuf_t sle, size_t size)
  1013. {
  1014. size_t next_size, tmp_size;
  1015. if(size < SIZE1BYTE)
  1016. {
  1017. sle[0] = size;
  1018. return 1;
  1019. }
  1020. else if(size < (SIZE1BYTE*2))
  1021. {
  1022. sle[0] = SIZE1BYTE;
  1023. next_size = size - 250;
  1024. sle[1] = next_size;
  1025. return 2;
  1026. }
  1027. else if(size < IBYTE2)
  1028. {
  1029. sle[0] = SIZE2BYTE;
  1030. next_size = size/IBYTE1;
  1031. sle[1] = next_size;
  1032. next_size = size%IBYTE1;
  1033. sle[2] = next_size;
  1034. return 3;
  1035. }
  1036. else if(size < IBYTE3)
  1037. {
  1038. sle[0] = SIZE3BYTE;
  1039. next_size = size/IBYTE2;
  1040. sle[1] = next_size;
  1041. tmp_size = size%IBYTE2;
  1042. next_size = tmp_size/IBYTE1;
  1043. sle[2] = next_size;
  1044. next_size = tmp_size%IBYTE1;
  1045. sle[3] = next_size;
  1046. return 4;
  1047. }
  1048. else if(size < IBYTE4)
  1049. {
  1050. sle[0] = SIZE4BYTE;
  1051. next_size = size/IBYTE3;
  1052. sle[1] = next_size;
  1053. tmp_size = size%IBYTE3;
  1054. next_size = tmp_size/IBYTE2;
  1055. sle[2] = next_size;
  1056. tmp_size = tmp_size%IBYTE2;
  1057. next_size = tmp_size/IBYTE1;
  1058. sle[3] = next_size;
  1059. next_size = tmp_size%IBYTE1;
  1060. sle[5] = next_size;
  1061. return 5;
  1062. }
  1063. return 0;
  1064. }
  1065. static SQRESULT sq_get_sle_size(HSQUIRRELVM v)
  1066. {
  1067. SQ_FUNC_VARS_NO_TOP(v);
  1068. slebuf_t slebuf;
  1069. SQ_GET_INTEGER(v, 2, size);
  1070. int slesize = sleSize2buf(slebuf, size);
  1071. if(slesize)
  1072. {
  1073. sq_pushstring(v, (const char *)slebuf, slesize);
  1074. return 1;
  1075. }
  1076. return 0;
  1077. }
  1078. static int add2sle(SQBlob &sle, const char *str, size_t size)
  1079. {
  1080. slebuf_t slebuf;
  1081. int slesize = sleSize2buf(slebuf, size);
  1082. if(slesize) sle.Write((const char *)slebuf, slesize);
  1083. if(size) sle.Write(str, size);
  1084. return size;
  1085. }
  1086. static SQRESULT sq_add2sle(HSQUIRRELVM v)
  1087. {
  1088. SQ_FUNC_VARS(v);
  1089. SQ_GET_INSTANCE_VAR(v, 2, SQBlob, blob, SQBlob::SQBlob_TAG);
  1090. SQ_GET_STRING(v, 3, str);
  1091. SQ_OPT_INTEGER(v, 4, size, str_size);
  1092. if(size < 0) return sq_throwerror(v, _SC("invalid size value (%d)"), size);
  1093. sq_pushinteger(v, add2sle(*blob, str, size));
  1094. return 1;
  1095. }
  1096. static SQRESULT sq_sqlite3_stmt_asSleArray(HSQUIRRELVM v)
  1097. {
  1098. SQ_FUNC_VARS_NO_TOP(v);
  1099. GET_sqlite3_stmt_INSTANCE();
  1100. int col_count = sqlite3_column_count(self);
  1101. int i;
  1102. const char *value;
  1103. SQBlob *sle = NULL;
  1104. int has_blob = getOptionalBlob(v, 2, &sle);
  1105. if(has_blob == SQ_ERROR) return SQ_ERROR;
  1106. sle->WriteZstr("[[");
  1107. for(i=0; i < col_count; ++i)
  1108. {
  1109. value = sqlite3_column_name(self, i);
  1110. add2sle(*sle, value, strlen(value));
  1111. }
  1112. sle->WriteChar(SLEEND);
  1113. sle->WriteChar(']');
  1114. while(sqlite3_step(self) == SQLITE_ROW)
  1115. {
  1116. sle->WriteChar('[');
  1117. for(i=0; i < col_count; ++i)
  1118. {
  1119. switch(sqlite3_column_type(self, i))
  1120. {
  1121. case SQLITE_BLOB:
  1122. {
  1123. add2sle(*sle, (const char*)sqlite3_column_blob(self, i),
  1124. sqlite3_column_bytes(self, i));
  1125. }
  1126. break;
  1127. default:
  1128. add2sle(*sle, (const char*)sqlite3_column_text(self, i),
  1129. sqlite3_column_bytes(self, i));
  1130. }
  1131. }
  1132. sle->WriteChar(SLEEND);
  1133. sle->WriteChar(']');
  1134. }
  1135. sle->WriteChar(']');
  1136. if(has_blob) return 0;
  1137. sq_pushstring(v, (const SQChar*)sle->GetBuf(), sle->Len());
  1138. delete sle;
  1139. return 1;
  1140. }
  1141. static SQRESULT sq_sqlite3_stmt_all_blobs_size(HSQUIRRELVM v)
  1142. {
  1143. SQ_FUNC_VARS(v);
  1144. GET_sqlite3_stmt_INSTANCE();
  1145. int total_size = 0, col_count = sqlite3_column_count(self);
  1146. for(int i=0; i < col_count; ++i)
  1147. {
  1148. if(sqlite3_column_type(self, i) == SQLITE_BLOB)
  1149. {
  1150. total_size += sqlite3_column_bytes(self, i);
  1151. }
  1152. }
  1153. sq_pushinteger(v, total_size);
  1154. return 1;
  1155. }
  1156. static SQRESULT sq_sqlite3_stmt_colsSizeAsArray(HSQUIRRELVM v)
  1157. {
  1158. SQ_FUNC_VARS_NO_TOP(v);
  1159. GET_sqlite3_stmt_INSTANCE();
  1160. int col_count = sqlite3_column_count(self);
  1161. sq_newarray(v, col_count);
  1162. for(int i=0; i<col_count; ++i)
  1163. {
  1164. sq_pushinteger(v, sqlite3_column_bytes(self, i));
  1165. sq_arrayset(v, -2, i);
  1166. }
  1167. return 1;
  1168. }
  1169. #define _DECL_FUNC(name,nparams,tycheck, isStatic) {_SC(#name), sq_sqlite3_stmt_##name,nparams,tycheck, isStatic}
  1170. static SQRegFunction sq_sqlite3_stmt_methods[] =
  1171. {
  1172. _DECL_FUNC(constructor, -2, _SC("xxs s|n|b|o"), SQFalse),
  1173. _DECL_FUNC(stmt_ptr, 1, _SC("x"), SQFalse),
  1174. _DECL_FUNC(get_db, 1, _SC("x"), SQFalse),
  1175. _DECL_FUNC(finalize, 1, _SC("x"), SQFalse),
  1176. _DECL_FUNC(prepare, -2, _SC("xs s|n|b|o"), SQFalse),
  1177. _DECL_FUNC(get_sql, 1, _SC("x"), SQFalse),
  1178. _DECL_FUNC(bind, 3, _SC("xi s|n|b|o"), SQFalse),
  1179. _DECL_FUNC(bind_empty_null, 3, _SC("xi s|n|b|o"), SQFalse),
  1180. _DECL_FUNC(bind_blob, 3, _SC("xis"), SQFalse),
  1181. _DECL_FUNC(bind_values, -2, _SC("x s|n|b|o"), SQFalse),
  1182. _DECL_FUNC(bind_names, 2, _SC("x t|a"), SQFalse),
  1183. _DECL_FUNC(bind_parameter_index, 2, _SC("xs"), SQFalse),
  1184. _DECL_FUNC(bind_parameter_count, 1, _SC("x"), SQFalse),
  1185. _DECL_FUNC(step, 1, _SC("x"), SQFalse),
  1186. _DECL_FUNC(reset, 1, _SC("x"), SQFalse),
  1187. _DECL_FUNC(next_row, 1, _SC("x"), SQFalse),
  1188. _DECL_FUNC(colsAsArray, 1, _SC("x"), SQFalse),
  1189. _DECL_FUNC(colsAsTable, 1, _SC("x"), SQFalse),
  1190. _DECL_FUNC(colsTypeAsArray, 1, _SC("x"), SQFalse),
  1191. _DECL_FUNC(colsDeclTypeAsArray, 1, _SC("x"), SQFalse),
  1192. _DECL_FUNC(col_count, 1, _SC("x"), SQFalse),
  1193. _DECL_FUNC(col_name, 2, _SC("xi"), SQFalse),
  1194. _DECL_FUNC(colsNameAsArray, 1, _SC("x"), SQFalse),
  1195. _DECL_FUNC(col_type, 2, _SC("xi"), SQFalse),
  1196. _DECL_FUNC(col_declared_type, 2, _SC("xi"), SQFalse),
  1197. _DECL_FUNC(asArray, -1, _SC("xi"), SQFalse),
  1198. _DECL_FUNC(asTable, -1, _SC("xi"), SQFalse),
  1199. _DECL_FUNC(asArrayOfArrays, -1, _SC("xi"), SQFalse),
  1200. _DECL_FUNC(asArrayOfTables, -1, _SC("xi"), SQFalse),
  1201. _DECL_FUNC(asSleArray, -1, _SC("xx"), SQFalse),
  1202. //todo manage/skip blobs for json
  1203. _DECL_FUNC(asJsonArray, -1, _SC("xbx"), SQFalse),
  1204. _DECL_FUNC(asJsonObject, -1, _SC("xx"), SQFalse),
  1205. _DECL_FUNC(col, 2, _SC("x i|s"), SQFalse),
  1206. _DECL_FUNC(asString, 2, _SC("x i|s"), SQFalse),
  1207. _DECL_FUNC(asStringOrNull, 2, _SC("x i|s"), SQFalse),
  1208. _DECL_FUNC(asInteger, 2, _SC("x i|s"), SQFalse),
  1209. _DECL_FUNC(asBool, 2, _SC("x i|s"), SQFalse),
  1210. _DECL_FUNC(asFloat, 2, _SC("x i|s"), SQFalse),
  1211. _DECL_FUNC(all_blobs_size, 1, _SC("x"), SQFalse),
  1212. _DECL_FUNC(colsSizeAsArray, 1, _SC("x"), SQFalse),
  1213. {0,0}
  1214. };
  1215. #undef _DECL_FUNC
  1216. static SQRESULT sqlite3_exec_fmt(HSQUIRRELVM v, e_type_result type_result, int null_as_empty_str=1)
  1217. {
  1218. SQ_FUNC_VARS_NO_TOP(v);
  1219. GET_sqlite3_INSTANCE();
  1220. //SQ_GET_STRING(v, 2, szSQL);
  1221. sqlite3_stmt *stmt = 0;
  1222. _rc_ = sq_sqlite3_stmt_prepare_aux(v, self, &stmt, 2);
  1223. if(_rc_ < 0)
  1224. {
  1225. if(stmt) sqlite3_finalize(stmt);
  1226. return _rc_;
  1227. }
  1228. int rc = sqlite3_step(stmt);
  1229. if(type_result == tr_ddml)
  1230. {
  1231. if(rc != SQLITE_DONE)
  1232. {
  1233. sqlite3_finalize(stmt);
  1234. return sq_throwerror(v, "SQL is not a DDML %d %s", rc, sqlite3_errmsg(self));
  1235. }
  1236. sq_pushinteger(v, sqlite3_changes(sqlite3_db_handle(stmt)));
  1237. }
  1238. else
  1239. {
  1240. if(rc != SQLITE_ROW)
  1241. {
  1242. sqlite3_finalize(stmt);
  1243. return sq_throwerror(v, "%d %s", rc, sqlite3_errmsg(self));
  1244. }
  1245. switch(type_result)
  1246. {
  1247. case tr_first_row_first_col:
  1248. sqlite3_stmt_push_value(v, stmt, 0, 0);
  1249. break;
  1250. case tr_first_row:
  1251. sqlite3_stmt_row_asArray(v, stmt, NULL_AS_EMPTY_STR|AS_STRING_ALWAYS);
  1252. break;
  1253. case tr_all_rows:
  1254. sqlite3_stmt_asArrayOfArrays(v, stmt, NULL_AS_EMPTY_STR|AS_STRING_ALWAYS);
  1255. break;
  1256. default:
  1257. sqlite3_finalize(stmt);
  1258. return sq_throwerror(v, "Unknown requested return type %d", type_result);
  1259. }
  1260. }
  1261. sqlite3_finalize(stmt);
  1262. return 1;
  1263. }
  1264. static SQRESULT sq_sqlite3_close_release(HSQUIRRELVM v, sq_sqlite3_sdb *sdb)
  1265. {
  1266. SQRESULT rc = SQ_ERROR;
  1267. //printf("sq_sqlite3_close_release:%p\n", sdb);
  1268. if(sdb && sdb->db)
  1269. {
  1270. sqlite3 *db = sdb->db;
  1271. /*
  1272. sqlite3_stmt* statement = NULL;
  1273. int count = 0;
  1274. while ((statement = sqlite3_next_stmt(db, NULL)))
  1275. {
  1276. printf("sq_sqlite3_close_release:stmt: %p : %s\n", statement, sqlite3_sql(statement));
  1277. sqlite3_finalize(statement);
  1278. statement = c;
  1279. count++;
  1280. }
  1281. if (count) return sq_throwerror(v, _SC("closing database with %d statements not closed."), count);
  1282. */
  1283. if(sqlite3_close_v2(db) == SQLITE_OK)
  1284. {
  1285. rc = SQ_OK;
  1286. //remove waekref from registrytable
  1287. sq_pushregistrytable(sdb->v);
  1288. sq_pushuserpointer(sdb->v, db);
  1289. sq_deleteslot(sdb->v, -2, SQFalse);
  1290. sq_poptop(sdb->v);
  1291. if(sdb->func)
  1292. {
  1293. sq_sqlite3_sdb_func *func, *func_next;
  1294. func = sdb->func;
  1295. while (func)
  1296. {
  1297. func_next = func->next;
  1298. sq_release(sdb->v, &func->fn_step);
  1299. sq_release(sdb->v, &func->fn_finalize);
  1300. sq_release(sdb->v, &func->udata);
  1301. sq_free(func, sizeof(sq_sqlite3_sdb_func));
  1302. func = func_next;
  1303. }
  1304. sdb->func = NULL;
  1305. }
  1306. /* 'free' all references */
  1307. sq_release(sdb->v, &sdb->busy_cb);
  1308. sq_release(sdb->v, &sdb->busy_udata);
  1309. sq_release(sdb->v, &sdb->progress_cb);
  1310. sq_release(sdb->v, &sdb->progress_udata);
  1311. sq_release(sdb->v, &sdb->trace_cb);
  1312. sq_release(sdb->v, &sdb->trace_udata);
  1313. sq_release(sdb->v, &sdb->update_hook_cb);
  1314. sq_release(sdb->v, &sdb->update_hook_udata);
  1315. sq_release(sdb->v, &sdb->authorizer_hook_cb);
  1316. sq_release(sdb->v, &sdb->authorizer_hook_udata);
  1317. sq_release(sdb->v, &sdb->null_value);
  1318. sq_free(sdb, sizeof(sq_sqlite3_sdb));
  1319. }
  1320. else return sq_throwerror(v, sqlite3_errmsg(db));
  1321. }
  1322. return rc;
  1323. }
  1324. static SQRESULT sq_sqlite3_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  1325. {
  1326. sq_sqlite3_sdb *sdb = ((sq_sqlite3_sdb *)p);
  1327. sq_sqlite3_close_release(v, sdb);
  1328. return 0;
  1329. }
  1330. static SQRESULT sq_sqlite3_constructor(HSQUIRRELVM v)
  1331. {
  1332. SQ_FUNC_VARS(v);
  1333. SQ_GET_STRING(v, 2, dbname);
  1334. SQ_OPT_INTEGER(v, 3, flags, SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_SHAREDCACHE | SQLITE_OPEN_SUBLATIN_NA_LIKE);
  1335. sqlite3 *db;
  1336. int rc = sqlite3_open_v2(dbname, &db, flags, 0);
  1337. if(rc != SQLITE_OK) return sq_throwerror(v, "Failed to open database ! %d", rc);
  1338. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb *)sq_malloc(sizeof(sq_sqlite3_sdb));
  1339. memset(sdb, 0, sizeof(sq_sqlite3_sdb));
  1340. sdb->db = db;
  1341. sdb->v = v;
  1342. sq_resetobject(&sdb->busy_cb);
  1343. sq_resetobject(&sdb->busy_udata);
  1344. sq_resetobject(&sdb->progress_cb);
  1345. sq_resetobject(&sdb->progress_udata);
  1346. sq_resetobject(&sdb->trace_cb);
  1347. sq_resetobject(&sdb->trace_udata);
  1348. sq_resetobject(&sdb->update_hook_cb);
  1349. sq_resetobject(&sdb->update_hook_udata);
  1350. sq_resetobject(&sdb->authorizer_hook_cb);
  1351. sq_resetobject(&sdb->authorizer_hook_udata);
  1352. sq_resetobject(&sdb->null_value);
  1353. sq_setinstanceup(v, 1, sdb);
  1354. sq_setreleasehook(v,1, sq_sqlite3_releasehook);
  1355. //save a weakref to allow statement return it's db
  1356. sq_pushuserpointer(v, sdb->db);
  1357. sq_weakref(v, 1);
  1358. sq_setonregistrytable(v);
  1359. return 1;
  1360. }
  1361. static SQRESULT sq_sqlite3_close(HSQUIRRELVM v)
  1362. {
  1363. SQ_FUNC_VARS_NO_TOP(v);
  1364. GET_sqlite3_INSTANCE();
  1365. if(sq_sqlite3_close_release(v, sdb) != SQ_OK) return SQ_ERROR;
  1366. sq_setinstanceup(v, 1, 0); //next calls will fail with "database is closed"
  1367. return 0;
  1368. }
  1369. static SQRESULT sq_sqlite3_db_ptr(HSQUIRRELVM v)
  1370. {
  1371. SQ_FUNC_VARS_NO_TOP(v);
  1372. GET_sqlite3_INSTANCE();
  1373. sq_pushuserpointer(v, self);
  1374. return 1;
  1375. }
  1376. /* bool IsAutoCommitOn( ) */
  1377. static SQRESULT sq_sqlite3_IsAutoCommitOn(HSQUIRRELVM v)
  1378. {
  1379. SQ_FUNC_VARS_NO_TOP(v);
  1380. GET_sqlite3_INSTANCE();
  1381. sq_pushbool(v, sqlite3_get_autocommit(self) ? SQTrue : SQFalse);
  1382. return 1;
  1383. }
  1384. /* int changes( ) */
  1385. static SQRESULT sq_sqlite3_changes(HSQUIRRELVM v)
  1386. {
  1387. SQ_FUNC_VARS_NO_TOP(v);
  1388. GET_sqlite3_INSTANCE();
  1389. sq_pushinteger(v, sqlite3_changes(self));
  1390. return 1;
  1391. }
  1392. static SQRESULT sq_sqlite3_exec(HSQUIRRELVM v)
  1393. {
  1394. return sqlite3_exec_fmt(v, tr_all_rows);
  1395. }
  1396. /* int exec_dml( const char * szSQL ) */
  1397. static SQRESULT sq_sqlite3_exec_dml(HSQUIRRELVM v)
  1398. {
  1399. SQ_FUNC_VARS_NO_TOP(v);
  1400. GET_sqlite3_INSTANCE();
  1401. SQ_GET_STRING(v, 2, szSQL);
  1402. char *errmsg;
  1403. if(sqlite3_exec(self, szSQL, NULL, NULL, &errmsg) != SQLITE_OK){
  1404. sq_throwerror(v, errmsg);
  1405. sqlite3_free(errmsg);
  1406. return SQ_ERROR;
  1407. }
  1408. sq_pushinteger(v, sqlite3_changes(self));
  1409. return 1;
  1410. }
  1411. /* bool exec_get_one( std::string & result , const char * szSQL ) */
  1412. static SQRESULT sq_sqlite3_exec_get_one(HSQUIRRELVM v)
  1413. {
  1414. return sqlite3_exec_fmt(v, tr_first_row_first_col);
  1415. }
  1416. static SQRESULT sq_sqlite3_exec_get_first_row(HSQUIRRELVM v)
  1417. {
  1418. return sqlite3_exec_fmt(v, tr_first_row);
  1419. }
  1420. /* const char * get_db_name( ) */
  1421. static SQRESULT sq_sqlite3_get_db_name(HSQUIRRELVM v)
  1422. {
  1423. SQ_FUNC_VARS_NO_TOP(v);
  1424. GET_sqlite3_INSTANCE();
  1425. sq_pushstring(v, sqlite3_db_filename(self, "main"), -1);
  1426. return 1;
  1427. }
  1428. /* sqlite3_int64 last_row_id( ) */
  1429. static SQRESULT sq_sqlite3_last_row_id(HSQUIRRELVM v)
  1430. {
  1431. SQ_FUNC_VARS_NO_TOP(v);
  1432. GET_sqlite3_INSTANCE();
  1433. sq_pushinteger(v, sqlite3_last_insert_rowid(self));
  1434. return 1;
  1435. }
  1436. /* stmt * prepare( const char * sql ) */
  1437. static SQRESULT sq_sqlite3_prepare(HSQUIRRELVM v)
  1438. {
  1439. SQ_FUNC_VARS_NO_TOP(v);
  1440. //GET_sqlite3_INSTANCE();
  1441. SQ_GET_STRING(v, 2, sql);
  1442. sq_pushstring(v, SQLite3_Stmt_TAG, -1);
  1443. if(sq_getonroottable(v) == SQ_ERROR) return SQ_ERROR;
  1444. sq_pushroottable(v);
  1445. sq_push(v, 1);
  1446. sq_push(v, 2);
  1447. if(sq_call(v, 3, SQTrue, SQFalse) != SQ_OK) return SQ_ERROR;
  1448. return 1;
  1449. }
  1450. /* void set_busy_timeout( int nMillisecs ) */
  1451. static SQRESULT sq_sqlite3_set_busy_timeout(HSQUIRRELVM v)
  1452. {
  1453. SQ_FUNC_VARS_NO_TOP(v);
  1454. //GET_sqlite3_INSTANCE();
  1455. SQ_GET_INTEGER(v, 2, nMillisecs);
  1456. //self->set_busy_timeout(nMillisecs);
  1457. return 0;
  1458. }
  1459. /* int total_changes( ) */
  1460. static SQRESULT sq_sqlite3_total_changes(HSQUIRRELVM v)
  1461. {
  1462. SQ_FUNC_VARS_NO_TOP(v);
  1463. GET_sqlite3_INSTANCE();
  1464. sq_pushinteger(v, sqlite3_total_changes(self));
  1465. return 1;
  1466. }
  1467. static SQRESULT sq_sqlite3_enable_shared_cache(HSQUIRRELVM v)
  1468. {
  1469. SQ_FUNC_VARS_NO_TOP(v);
  1470. SQ_GET_BOOL(v, 2, bhow);
  1471. sq_pushbool(v, sqlite3_enable_shared_cache(bhow) == SQLITE_OK);
  1472. return 1;
  1473. }
  1474. static SQRESULT sq_sqlite3_sleep(HSQUIRRELVM v)
  1475. {
  1476. SQ_FUNC_VARS_NO_TOP(v);
  1477. SQ_GET_INTEGER(v, 2, n);
  1478. sqlite3_sleep(n);
  1479. return 0;
  1480. }
  1481. static SQRESULT sq_sqlite3_version(HSQUIRRELVM v)
  1482. {
  1483. sq_pushstring(v, sqlite3_libversion(), -1);
  1484. return 1;
  1485. }
  1486. static SQRESULT sq_sqlite3_errcode(HSQUIRRELVM v)
  1487. {
  1488. SQ_FUNC_VARS_NO_TOP(v);
  1489. GET_sqlite3_INSTANCE();
  1490. sq_pushinteger(v, sqlite3_errcode(self));
  1491. return 1;
  1492. }
  1493. static SQRESULT sq_sqlite3_errmsg(HSQUIRRELVM v)
  1494. {
  1495. SQ_FUNC_VARS_NO_TOP(v);
  1496. GET_sqlite3_INSTANCE();
  1497. sq_pushstring(v, sqlite3_errmsg(self), -1);
  1498. return 1;
  1499. }
  1500. #ifndef WIN32
  1501. static SQRESULT sq_sqlite3_temp_directory(HSQUIRRELVM v)
  1502. {
  1503. SQ_FUNC_VARS(v);
  1504. const char *oldtemp = sqlite3_temp_directory;
  1505. if (_top_ > 1)
  1506. {
  1507. SQ_GET_STRING(v, 2, temp);
  1508. if (sqlite3_temp_directory)
  1509. {
  1510. sqlite3_free((char*)sqlite3_temp_directory);
  1511. }
  1512. if (temp && temp_size)
  1513. {
  1514. sqlite3_temp_directory = sqlite3_mprintf("%s", temp);
  1515. }
  1516. else
  1517. {
  1518. sqlite3_temp_directory = NULL;
  1519. }
  1520. }
  1521. sq_pushstring(v, oldtemp, -1);
  1522. return 1;
  1523. }
  1524. #endif
  1525. #ifdef SQLITE_HAS_CODEC
  1526. //#include "codecext.h"
  1527. /*
  1528. ** Params: db, sql
  1529. ** returns: code, compiled length or error message
  1530. */
  1531. static SQRESULT sq_sqlite3_key(HSQUIRRELVM v)
  1532. {
  1533. SQ_FUNC_VARS_NO_TOP(v);
  1534. GET_sqlite3_INSTANCE();
  1535. SQ_GET_STRING(v, 2, key);
  1536. sq_pushinteger(v, sqlite3_key_v2(self, 0, key, key_size));
  1537. return 1;
  1538. }
  1539. /*
  1540. ** Params: db, sql
  1541. ** returns: code, compiled length or error message
  1542. */
  1543. static SQRESULT sq_sqlite3_rekey(HSQUIRRELVM v)
  1544. {
  1545. SQ_FUNC_VARS_NO_TOP(v);
  1546. GET_sqlite3_INSTANCE();
  1547. SQ_GET_STRING(v, 2, key);
  1548. sq_pushinteger(v, sqlite3_rekey_v2(self, 0, key, key_size));
  1549. return 1;
  1550. }
  1551. #endif
  1552. #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK
  1553. /*
  1554. ** progress handler:
  1555. ** Params: database, number of opcodes, callback function, userdata
  1556. **
  1557. ** callback function:
  1558. ** Params: userdata
  1559. ** returns: 0 to return immediatly and return SQLITE_ABORT, non-zero to continue
  1560. */
  1561. static int db_progress_callback(void *udata)
  1562. {
  1563. SQInteger result = 1; /* abort by default */
  1564. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)udata;
  1565. HSQUIRRELVM v = sdb->v;
  1566. int top = sq_gettop(v);
  1567. sq_pushobject(v, sdb->progress_cb);
  1568. sq_pushroottable(v); //this
  1569. sq_pushobject(v, sdb->progress_udata);
  1570. /* call lua function */
  1571. if (sq_call(v, 2, SQTrue, SQFalse) == SQ_OK)
  1572. sq_getinteger(v, -1, &result);
  1573. sq_settop(v, top);
  1574. return result;
  1575. }
  1576. static SQRESULT sq_sqlite3_progress_handler(HSQUIRRELVM v)
  1577. {
  1578. SQ_FUNC_VARS(v);
  1579. GET_sqlite3_INSTANCE();
  1580. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL)
  1581. {
  1582. sq_release(v, &sdb->progress_cb);
  1583. sq_release(v, &sdb->progress_udata);
  1584. sq_resetobject(&sdb->progress_cb);
  1585. sq_resetobject(&sdb->progress_udata);
  1586. /* clear busy handler */
  1587. sqlite3_progress_handler(self, 0, NULL, NULL);
  1588. }
  1589. else
  1590. {
  1591. SQ_GET_INTEGER(v, 2, nop);
  1592. if(sq_gettype(v, 3) != OT_CLOSURE)
  1593. return sq_throwerror(v, _SC("invalid second parameter expected closure"));
  1594. sq_getstackobj(v, 3, &sdb->progress_cb);
  1595. sq_addref(v, &sdb->progress_cb);
  1596. if(_top_ > 3)
  1597. {
  1598. sq_getstackobj(v, 4, &sdb->progress_udata);
  1599. sq_addref(v, &sdb->progress_udata);
  1600. }
  1601. /* set progress callback */
  1602. sqlite3_progress_handler(self, nop, db_progress_callback, sdb);
  1603. }
  1604. return 0;
  1605. }
  1606. #else /* #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK */
  1607. static SQRESULT sq_sqlite3_progress_handler(HSQUIRRELVM v)
  1608. {
  1609. return sq_throwerror(v, _SC("progress callback support disabled at compile time"));
  1610. return 0;
  1611. }
  1612. #endif /* #if !defined(SQLITE_OMIT_PROGRESS_CALLBACK) || !SQLITE_OMIT_PROGRESS_CALLBACK */
  1613. /*
  1614. ** trace callback:
  1615. ** Params: database, callback function, userdata
  1616. **
  1617. ** callback function:
  1618. ** Params: userdata, sql
  1619. */
  1620. static void db_trace_callback(void *udata, const char *sql)
  1621. {
  1622. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)udata;
  1623. HSQUIRRELVM v = sdb->v;
  1624. int top = sq_gettop(v);
  1625. /* setup squirrel callback call */
  1626. sq_pushobject(v, sdb->trace_cb);
  1627. sq_pushroottable(v);
  1628. sq_pushobject(v, sdb->trace_udata);
  1629. sq_pushstring(v, sql, -1); /* traced sql statement */
  1630. /* call squirrel function */
  1631. sq_call(v, 3, SQFalse, SQFalse);
  1632. /* ignore any error generated by this function */
  1633. sq_settop(v, top);
  1634. }
  1635. static SQRESULT sq_sqlite3_trace(HSQUIRRELVM v)
  1636. {
  1637. SQ_FUNC_VARS(v);
  1638. GET_sqlite3_INSTANCE();
  1639. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL)
  1640. {
  1641. sq_release(v, &sdb->trace_cb);
  1642. sq_release(v, &sdb->trace_udata);
  1643. sq_resetobject(&sdb->trace_cb);
  1644. sq_resetobject(&sdb->trace_udata);
  1645. /* clear trace handler */
  1646. sqlite3_trace(self, NULL, NULL);
  1647. }
  1648. else
  1649. {
  1650. if(sq_gettype(v, 2) != OT_CLOSURE)
  1651. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1652. sq_getstackobj(v, 2, &sdb->trace_cb);
  1653. sq_addref(v, &sdb->trace_cb);
  1654. if(_top_ > 2)
  1655. {
  1656. sq_getstackobj(v, 3, &sdb->trace_udata);
  1657. sq_addref(v, &sdb->trace_udata);
  1658. }
  1659. /* set trace callback */
  1660. if(_top_ > 3)
  1661. {
  1662. SQBool b;
  1663. sq_getbool(v, 4, &b);
  1664. sqlite3_trace_v2(self, db_trace_callback, sdb, b == SQTrue);
  1665. }
  1666. else sqlite3_trace(self, db_trace_callback, sdb);
  1667. }
  1668. return 0;
  1669. }
  1670. /*
  1671. ** update hook callback:
  1672. ** Params: database, callback function, userdata
  1673. **
  1674. ** callback function:
  1675. ** Params: userdata, sql
  1676. */
  1677. static void db_update_hook_callback(void *udata, int update_type,
  1678. char const *db_name, char const *table_name, sqlite3_int64 rowid)
  1679. {
  1680. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)udata;
  1681. HSQUIRRELVM v = sdb->v;
  1682. int top = sq_gettop(v);
  1683. /* setup squirrel callback call */
  1684. sq_pushobject(v, sdb->update_hook_cb);
  1685. sq_pushroottable(v);
  1686. sq_pushobject(v, sdb->update_hook_udata);
  1687. sq_pushinteger(v, update_type);
  1688. sq_pushstring(v, db_name, -1);
  1689. sq_pushstring(v, table_name, -1);
  1690. sq_pushinteger(v, rowid);
  1691. /* call squirrel function */
  1692. sq_call(v, 6, SQFalse, SQFalse);
  1693. /* ignore any error generated by this function */
  1694. sq_settop(v, top);
  1695. }
  1696. static SQRESULT sq_sqlite3_update_hook(HSQUIRRELVM v)
  1697. {
  1698. SQ_FUNC_VARS(v);
  1699. GET_sqlite3_INSTANCE();
  1700. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL)
  1701. {
  1702. sq_release(v, &sdb->update_hook_cb);
  1703. sq_release(v, &sdb->update_hook_udata);
  1704. sq_resetobject(&sdb->update_hook_cb);
  1705. sq_resetobject(&sdb->update_hook_udata);
  1706. /* clear trace handler */
  1707. sqlite3_update_hook(self, NULL, NULL);
  1708. }
  1709. else
  1710. {
  1711. if(sq_gettype(v, 2) != OT_CLOSURE)
  1712. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1713. sq_getstackobj(v, 2, &sdb->update_hook_cb);
  1714. sq_addref(v, &sdb->update_hook_cb);
  1715. if(_top_ > 2)
  1716. {
  1717. sq_getstackobj(v, 3, &sdb->update_hook_udata);
  1718. sq_addref(v, &sdb->update_hook_udata);
  1719. }
  1720. /* set update_hook callback */
  1721. sqlite3_update_hook(self, db_update_hook_callback, sdb);
  1722. }
  1723. return 0;
  1724. }
  1725. /*
  1726. ** authorizer hook callback:
  1727. ** Params: database, callback function, userdata
  1728. **
  1729. ** callback function:
  1730. ** Params: userdata, sql
  1731. */
  1732. #if 0
  1733. /******************************************* 3rd ************ 4th ***********/
  1734. #define SQLITE_CREATE_INDEX 1 /* Index Name Table Name */
  1735. #define SQLITE_CREATE_TABLE 2 /* Table Name NULL */
  1736. #define SQLITE_CREATE_TEMP_INDEX 3 /* Index Name Table Name */
  1737. #define SQLITE_CREATE_TEMP_TABLE 4 /* Table Name NULL */
  1738. #define SQLITE_CREATE_TEMP_TRIGGER 5 /* Trigger Name Table Name */
  1739. #define SQLITE_CREATE_TEMP_VIEW 6 /* View Name NULL */
  1740. #define SQLITE_CREATE_TRIGGER 7 /* Trigger Name Table Name */
  1741. #define SQLITE_CREATE_VIEW 8 /* View Name NULL */
  1742. #define SQLITE_DELETE 9 /* Table Name NULL */
  1743. #define SQLITE_DROP_INDEX 10 /* Index Name Table Name */
  1744. #define SQLITE_DROP_TABLE 11 /* Table Name NULL */
  1745. #define SQLITE_DROP_TEMP_INDEX 12 /* Index Name Table Name */
  1746. #define SQLITE_DROP_TEMP_TABLE 13 /* Table Name NULL */
  1747. #define SQLITE_DROP_TEMP_TRIGGER 14 /* Trigger Name Table Name */
  1748. #define SQLITE_DROP_TEMP_VIEW 15 /* View Name NULL */
  1749. #define SQLITE_DROP_TRIGGER 16 /* Trigger Name Table Name */
  1750. #define SQLITE_DROP_VIEW 17 /* View Name NULL */
  1751. #define SQLITE_INSERT 18 /* Table Name NULL */
  1752. #define SQLITE_PRAGMA 19 /* Pragma Name 1st arg or NULL */
  1753. #define SQLITE_READ 20 /* Table Name Column Name */
  1754. #define SQLITE_SELECT 21 /* NULL NULL */
  1755. #define SQLITE_TRANSACTION 22 /* Operation NULL */
  1756. #define SQLITE_UPDATE 23 /* Table Name Column Name */
  1757. #define SQLITE_ATTACH 24 /* Filename NULL */
  1758. #define SQLITE_DETACH 25 /* Database Name NULL */
  1759. #define SQLITE_ALTER_TABLE 26 /* Database Name Table Name */
  1760. #define SQLITE_REINDEX 27 /* Index Name NULL */
  1761. #define SQLITE_ANALYZE 28 /* Table Name NULL */
  1762. #define SQLITE_CREATE_VTABLE 29 /* Table Name Module Name */
  1763. #define SQLITE_DROP_VTABLE 30 /* Table Name Module Name */
  1764. #define SQLITE_FUNCTION 31 /* NULL Function Name */
  1765. #define SQLITE_SAVEPOINT 32 /* Operation Savepoint Name */
  1766. #define SQLITE_COPY 0 /* No longer used */
  1767. #define SQLITE_RECURSIVE 33 /* NULL NULL */
  1768. #endif
  1769. static int db_authorizer_hook_callback(void *udata, int action_code,
  1770. char const *param3, char const *param4,
  1771. char const *param5, char const *param6)
  1772. {
  1773. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)udata;
  1774. HSQUIRRELVM v = sdb->v;
  1775. int top = sq_gettop(v);
  1776. SQInteger result = SQLITE_OK;
  1777. /* setup squirrel callback call */
  1778. sq_pushobject(v, sdb->authorizer_hook_cb);
  1779. sq_pushroottable(v);
  1780. sq_pushobject(v, sdb->authorizer_hook_udata);
  1781. sq_pushinteger(v, action_code);
  1782. sq_pushstring(v, param3, -1);
  1783. sq_pushstring(v, param4, -1);
  1784. sq_pushstring(v, param5, -1);
  1785. sq_pushstring(v, param6, -1);
  1786. /* call lua function */
  1787. /* ignore any error generated by this function */
  1788. if (sq_call(v, 7, SQTrue, SQFalse) == SQ_OK)
  1789. sq_getinteger(v, -1, &result);
  1790. sq_settop(v, top);
  1791. return result;
  1792. }
  1793. static SQRESULT sq_sqlite3_set_authorizer(HSQUIRRELVM v)
  1794. {
  1795. SQ_FUNC_VARS(v);
  1796. GET_sqlite3_INSTANCE();
  1797. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL)
  1798. {
  1799. sq_release(v, &sdb->authorizer_hook_cb);
  1800. sq_release(v, &sdb->authorizer_hook_udata);
  1801. sq_resetobject(&sdb->authorizer_hook_cb);
  1802. sq_resetobject(&sdb->authorizer_hook_udata);
  1803. /* clear trace handler */
  1804. sqlite3_set_authorizer(self, NULL, NULL);
  1805. }
  1806. else
  1807. {
  1808. if(sq_gettype(v, 2) != OT_CLOSURE)
  1809. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1810. sq_getstackobj(v, 2, &sdb->authorizer_hook_cb);
  1811. sq_addref(v, &sdb->authorizer_hook_cb);
  1812. if(_top_ > 2)
  1813. {
  1814. sq_getstackobj(v, 3, &sdb->authorizer_hook_udata);
  1815. sq_addref(v, &sdb->authorizer_hook_udata);
  1816. }
  1817. /* set authorizer_hook callback */
  1818. sqlite3_set_authorizer(self, db_authorizer_hook_callback, sdb);
  1819. }
  1820. return 0;
  1821. }
  1822. /*
  1823. ** busy handler:
  1824. ** Params: database, callback function, userdata
  1825. **
  1826. ** callback function:
  1827. ** Params: userdata, number of tries
  1828. ** returns: 0 to return immediatly and return SQLITE_BUSY, non-zero to try again
  1829. */
  1830. static int db_busy_callback(void *udata, int tries)
  1831. {
  1832. SQBool retry = SQFalse; /* abort by default */
  1833. sq_sqlite3_sdb *sdb = (sq_sqlite3_sdb*)udata;
  1834. HSQUIRRELVM v = sdb->v;
  1835. int top = sq_gettop(v);
  1836. sq_pushobject(v, sdb->busy_cb);
  1837. sq_pushroottable(v);
  1838. sq_pushobject(v, sdb->busy_udata);
  1839. sq_pushinteger(v, tries);
  1840. /* call lua function */
  1841. if (sq_call(v, 3, SQTrue, SQFalse) == SQ_OK)
  1842. sq_getbool(v, -1, &retry);
  1843. sq_settop(v, top);
  1844. return retry == SQTrue;
  1845. }
  1846. static SQRESULT sq_sqlite3_busy_handler(HSQUIRRELVM v)
  1847. {
  1848. SQ_FUNC_VARS(v);
  1849. GET_sqlite3_INSTANCE();
  1850. if (_top_ < 2 || sq_gettype(v, 2) == OT_NULL)
  1851. {
  1852. sq_release(v, &sdb->busy_cb);
  1853. sq_release(v, &sdb->busy_udata);
  1854. sq_resetobject(&sdb->busy_cb);
  1855. sq_resetobject(&sdb->busy_udata);
  1856. /* clear busy handler */
  1857. sqlite3_busy_handler(self, NULL, NULL);
  1858. }
  1859. else
  1860. {
  1861. if(sq_gettype(v, 2) != OT_CLOSURE)
  1862. return sq_throwerror(v, _SC("invalid fisrt parameter expected closure"));
  1863. sq_getstackobj(v, 2, &sdb->busy_cb);
  1864. sq_addref(v, &sdb->busy_cb);
  1865. if(_top_ > 2)
  1866. {
  1867. sq_getstackobj(v, 3, &sdb->busy_udata);
  1868. sq_addref(v, &sdb->busy_udata);
  1869. }
  1870. /* set busy callback */
  1871. sqlite3_busy_handler(self, db_busy_callback, sdb);
  1872. }
  1873. return 0;
  1874. }
  1875. static SQRESULT sq_sqlite3_busy_timeout(HSQUIRRELVM v)
  1876. {
  1877. SQ_FUNC_VARS_NO_TOP(v);
  1878. GET_sqlite3_INSTANCE();
  1879. SQ_GET_INTEGER(v, 2, timeout);
  1880. sqlite3_busy_timeout(self, timeout);
  1881. /* if there was a timeout callback registered, it is now
  1882. ** invalid/useless. free any references we may have */
  1883. sq_release(v, &sdb->busy_cb);
  1884. sq_resetobject(&sdb->busy_cb);
  1885. sq_release(v, &sdb->busy_udata);
  1886. sq_resetobject(&sdb->busy_udata);
  1887. return 0;
  1888. }
  1889. static SQRESULT sq_sqlite3_interrupt(HSQUIRRELVM v)
  1890. {
  1891. SQ_FUNC_VARS_NO_TOP(v);
  1892. GET_sqlite3_INSTANCE();
  1893. sqlite3_interrupt(self);
  1894. return 0;
  1895. }
  1896. /*
  1897. ** =======================================================
  1898. ** User Defined Functions - Context Methods
  1899. ** =======================================================
  1900. */
  1901. typedef struct
  1902. {
  1903. sqlite3_context *ctx;
  1904. HSQOBJECT udata;
  1905. } sq_sqlite3_context_st;
  1906. static const SQChar sq_sqlite3_context_TAG[] = _SC(":sqlite3:ctx");
  1907. static SQRESULT sq_sqlite3_context_releasehook(SQUserPointer p, SQInteger size, HSQUIRRELVM v)
  1908. {
  1909. sq_sqlite3_context_st *ctx = ((sq_sqlite3_context_st *)p);
  1910. /* 'free' all references */
  1911. sq_free(ctx, sizeof(sq_sqlite3_context_st));
  1912. return 0;
  1913. }
  1914. static SQRESULT sq_sqlite3_context_constructor(HSQUIRRELVM v)
  1915. {
  1916. sq_sqlite3_context_st *ctx = (sq_sqlite3_context_st*)sq_malloc(sizeof(sq_sqlite3_context_st));
  1917. ctx->ctx = NULL;
  1918. sq_resetobject(&ctx->udata);
  1919. sq_setinstanceup(v, 1, ctx);
  1920. sq_setreleasehook(v,1, sq_sqlite3_context_releasehook);
  1921. return 1;
  1922. }
  1923. #define SQ_SQLITE3_GETCONTEXT(v, idx) \
  1924. sq_sqlite3_context_st *self;\
  1925. if((_rc_ = sq_getinstanceup(v, idx, (void**)&self, (void*)sq_sqlite3_context_TAG)) < 0) return _rc_;
  1926. #define GET_sqlite3_context_INSTANCE() SQ_SQLITE3_GETCONTEXT(v,1)
  1927. static SQRESULT sq_sqlite3_context__tostring(HSQUIRRELVM v)
  1928. {
  1929. SQ_FUNC_VARS_NO_TOP(v);
  1930. GET_sqlite3_context_INSTANCE();
  1931. char buff[64];
  1932. snprintf(buff, sizeof(buff), "sqlite function context (%p)", self);
  1933. sq_pushstring(v, buff, -1);
  1934. return 1;
  1935. }
  1936. static SQRESULT sq_sqlite3_context_check_aggregate(HSQUIRRELVM v, sq_sqlite3_context_st *ctx)
  1937. {
  1938. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(ctx->ctx);
  1939. if (sq_isclosure(func->fn_finalize))
  1940. {
  1941. return sq_throwerror(v, "attempt to call aggregate method from scalar function");
  1942. }
  1943. return 1;
  1944. }
  1945. static SQRESULT sq_sqlite3_context_user_data(HSQUIRRELVM v)
  1946. {
  1947. SQ_FUNC_VARS_NO_TOP(v);
  1948. GET_sqlite3_context_INSTANCE();
  1949. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(self->ctx);
  1950. sq_pushobject(v, func->udata);
  1951. return 1;
  1952. }
  1953. static SQRESULT sq_sqlite3_context_aggregate_data(HSQUIRRELVM v)
  1954. {
  1955. SQ_FUNC_VARS(v);
  1956. GET_sqlite3_context_INSTANCE();
  1957. sq_sqlite3_context_check_aggregate(v, self);
  1958. if(_top_ < 2)
  1959. {
  1960. sq_pushobject(v, self->udata);
  1961. }
  1962. else
  1963. {
  1964. sq_release(v, &self->udata);
  1965. sq_getstackobj(v, 2, &self->udata);
  1966. sq_addref(v, &self->udata);
  1967. }
  1968. return 0;
  1969. }
  1970. static SQRESULT sq_sqlite3_context_aggregate_count(HSQUIRRELVM v)
  1971. {
  1972. SQ_FUNC_VARS_NO_TOP(v);
  1973. GET_sqlite3_context_INSTANCE();
  1974. sq_sqlite3_context_check_aggregate(v, self);
  1975. sq_pushinteger(v, sqlite3_aggregate_count(self->ctx));
  1976. return 1;
  1977. }
  1978. #if 0
  1979. void *sqlite3_get_auxdata(sqlite3_context*, int);
  1980. void sqlite3_set_auxdata(sqlite3_context*, int, void*, void (*)(void*));
  1981. #endif
  1982. static SQRESULT sq_sqlite3_context_result_blob(HSQUIRRELVM v)
  1983. {
  1984. SQ_FUNC_VARS_NO_TOP(v);
  1985. GET_sqlite3_context_INSTANCE();
  1986. SQ_GET_STRING(v, 2, blob);
  1987. sqlite3_result_blob(self->ctx, (const void*)blob, blob_size, SQLITE_TRANSIENT);
  1988. return 0;
  1989. }
  1990. static SQRESULT sq_sqlite3_context_result_double(HSQUIRRELVM v)
  1991. {
  1992. SQ_FUNC_VARS_NO_TOP(v);
  1993. GET_sqlite3_context_INSTANCE();
  1994. SQ_GET_FLOAT(v, 2, d);
  1995. sqlite3_result_double(self->ctx, d);
  1996. return 0;
  1997. }
  1998. static SQRESULT sq_sqlite3_context_result_error(HSQUIRRELVM v)
  1999. {
  2000. SQ_FUNC_VARS_NO_TOP(v);
  2001. GET_sqlite3_context_INSTANCE();
  2002. SQ_GET_STRING(v,2, err);
  2003. sqlite3_result_error(self->ctx, err, err_size);
  2004. return 0;
  2005. }
  2006. static SQRESULT sq_sqlite3_context_result_int(HSQUIRRELVM v)
  2007. {
  2008. SQ_FUNC_VARS_NO_TOP(v);
  2009. GET_sqlite3_context_INSTANCE();
  2010. SQ_GET_INTEGER(v, 2, i);
  2011. sqlite3_result_int(self->ctx, i);
  2012. return 0;
  2013. }
  2014. static SQRESULT sq_sqlite3_context_result_null(HSQUIRRELVM v)
  2015. {
  2016. SQ_FUNC_VARS_NO_TOP(v);
  2017. GET_sqlite3_context_INSTANCE();
  2018. sqlite3_result_null(self->ctx);
  2019. return 0;
  2020. }
  2021. static SQRESULT sq_sqlite3_context_result_text(HSQUIRRELVM v)
  2022. {
  2023. SQ_FUNC_VARS_NO_TOP(v);
  2024. GET_sqlite3_context_INSTANCE();
  2025. SQ_GET_STRING(v, 2, text);
  2026. sqlite3_result_text(self->ctx, text, text_size, SQLITE_TRANSIENT);
  2027. return 0;
  2028. }
  2029. static SQRESULT sq_sqlite3_context_result_subtype(HSQUIRRELVM v)
  2030. {
  2031. SQ_FUNC_VARS_NO_TOP(v);
  2032. GET_sqlite3_context_INSTANCE();
  2033. SQ_GET_INTEGER(v, 2, subtype);
  2034. sqlite3_result_subtype(self->ctx, subtype);
  2035. return 0;
  2036. }
  2037. /* no way to recover parameter value after function call
  2038. static SQRESULT sq_sqlite3_context_value_subtype(HSQUIRRELVM v)
  2039. {
  2040. SQ_FUNC_VARS_NO_TOP(v);
  2041. GET_sqlite3_context_INSTANCE();
  2042. SQ_GET_INTEGER(v, 2, param_idx);
  2043. sq_pushinteger(v, sqlite3_value_subtype(self->ctx, subtype));
  2044. return 1;
  2045. }
  2046. */
  2047. #define _DECL_FUNC(name,nparams,tycheck) {_SC(#name), sq_sqlite3_context_##name,nparams,tycheck}
  2048. static SQRegFunction sq_sqlite3_context_methods[] =
  2049. {
  2050. _DECL_FUNC(constructor, 1, _SC("x")),
  2051. _DECL_FUNC(user_data, 1, _SC("x")),
  2052. _DECL_FUNC(aggregate_data, -1, _SC("x.")),
  2053. _DECL_FUNC(aggregate_count, 1, _SC("x")),
  2054. _DECL_FUNC(result_null, 1, _SC("x")),
  2055. _DECL_FUNC(result_double, 2, _SC("xn")),
  2056. _DECL_FUNC(result_int, 2, _SC("xi")),
  2057. _DECL_FUNC(result_text, 2, _SC("xs")),
  2058. _DECL_FUNC(result_blob, 2, _SC("xs")),
  2059. _DECL_FUNC(result_error, 2, _SC("xs")),
  2060. _DECL_FUNC(result_subtype, 2, _SC("xi")),
  2061. //_DECL_FUNC(value_subtype, 2, _SC("xi")),
  2062. _DECL_FUNC(_tostring, -1, _SC("x")),
  2063. {0,0}
  2064. };
  2065. #undef _DECL_FUNC
  2066. /*
  2067. ** callback functions used when calling registered sql functions
  2068. */
  2069. static void sqlite3_push_value(HSQUIRRELVM v, sqlite3_value *value)
  2070. {
  2071. const char *tmp_value;
  2072. switch (sqlite3_value_type(value))
  2073. {
  2074. case SQLITE_TEXT:
  2075. tmp_value = (const char*) sqlite3_value_text(value);
  2076. if(tmp_value) sq_pushstring(v, tmp_value, sqlite3_value_bytes(value));
  2077. else push_sqlite3_null(v);
  2078. break;
  2079. case SQLITE_INTEGER:
  2080. {
  2081. sqlite_int64 i64 = sqlite3_value_int64(value);
  2082. SQInteger n = (SQInteger)i64;
  2083. if (n == i64)
  2084. sq_pushinteger(v, n);
  2085. else
  2086. sq_pushstring(v, (const char*) sqlite3_value_text(value), sqlite3_value_bytes(value));
  2087. }
  2088. break;
  2089. case SQLITE_FLOAT:
  2090. sq_pushfloat(v, sqlite3_value_double(value));
  2091. break;
  2092. case SQLITE_BLOB:
  2093. tmp_value = (const char*) sqlite3_value_blob(value);
  2094. if(tmp_value) sq_pushstring(v, tmp_value, sqlite3_value_bytes(value));
  2095. else push_sqlite3_null(v);
  2096. break;
  2097. case SQLITE_NULL:
  2098. push_sqlite3_null(v);
  2099. break;
  2100. default:
  2101. /* things done properly (SQLite + Lua SQLite)
  2102. ** this should never happen */
  2103. push_sqlite3_null(v);
  2104. break;
  2105. }
  2106. }
  2107. //#if 0
  2108. static SQRESULT new_context_instance(HSQUIRRELVM v, sq_sqlite3_context_st **ctx)
  2109. {
  2110. sq_pushregistrytable(v);
  2111. sq_pushstring(v,_SC("sqite3_context"),-1);
  2112. int rc = sq_rawget(v, -2);
  2113. sq_remove(v, -2); //remove registrytable
  2114. sq_pushroottable(v);
  2115. rc = sq_call(v, 1, SQTrue, SQFalse);
  2116. sq_remove(v, -2); //class
  2117. rc = sq_getinstanceup(v, -1, (void**)ctx, (void*)sq_sqlite3_context_TAG);
  2118. return rc;
  2119. }
  2120. /* scalar function to be called
  2121. ** callback params: context, values... */
  2122. static void db_sql_normal_function(sqlite3_context *context, int argc, sqlite3_value **argv)
  2123. {
  2124. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(context);
  2125. HSQUIRRELVM v = func->sdb->v;
  2126. int n;
  2127. sq_sqlite3_context_st *ctx;
  2128. int top = sq_gettop(v);
  2129. /* ensure there is enough space in the stack */
  2130. sq_reservestack(v, argc + 5);
  2131. sq_pushobject(v, func->fn_step);
  2132. sq_pushroottable(v);
  2133. if (!sq_isclosure(func->fn_finalize))
  2134. {
  2135. new_context_instance(v, &ctx);
  2136. }
  2137. else
  2138. {
  2139. /* reuse context userdata value */
  2140. void *p = sqlite3_aggregate_context(context, 1);
  2141. /* i think it is OK to use assume that using a light user data
  2142. ** as an entry on LUA REGISTRY table will be unique */
  2143. sq_pushregistrytable(v);
  2144. sq_pushuserpointer(v, p);
  2145. /* context table */
  2146. if(sq_rawget(v, -2) != SQ_OK)
  2147. {
  2148. /* not yet created? */
  2149. sq_poptop(v); //remove null
  2150. new_context_instance(v, &ctx);
  2151. sq_pushuserpointer(v, p);
  2152. sq_push(v, -2);
  2153. sq_rawset(v, -4); //insert into registrytable
  2154. }
  2155. sq_remove(v, -2); //remove registrytable
  2156. }
  2157. /* push params */
  2158. for (n = 0; n < argc; ++n)
  2159. {
  2160. sqlite3_push_value(v, argv[n]);
  2161. }
  2162. /* set context */
  2163. ctx->ctx = context;
  2164. if (sq_call(v, argc + 2, SQFalse, SQFalse) != SQ_OK) //2 = roottable + ctx
  2165. {
  2166. sqlite3_result_error(context, sq_getlasterror_str(v), -1);
  2167. }
  2168. /* invalidate context */
  2169. ctx->ctx = NULL;
  2170. if (!sq_isclosure(func->fn_finalize))
  2171. {
  2172. sq_release(v, &ctx->udata);
  2173. sq_resetobject(&ctx->udata);
  2174. }
  2175. sq_settop(v, top);
  2176. }
  2177. static void db_sql_finalize_function(sqlite3_context *context)
  2178. {
  2179. sq_sqlite3_sdb_func *func = (sq_sqlite3_sdb_func*)sqlite3_user_data(context);
  2180. HSQUIRRELVM v = func->sdb->v;
  2181. void *p = sqlite3_aggregate_context(context, 1); /* minimal mem usage */
  2182. sq_sqlite3_context_st *ctx;
  2183. int top = sq_gettop(v);
  2184. sq_pushobject(v, func->fn_finalize);
  2185. sq_pushroottable(v);
  2186. /* i think it is OK to use assume that using a light user data
  2187. ** as an entry on LUA REGISTRY table will be unique */
  2188. sq_pushregistrytable(v);
  2189. sq_pushuserpointer(v, p);
  2190. /* remove it from registry but we'll use it last time here */
  2191. /* context table */
  2192. if(sq_deleteslot(v, -2, SQTrue) != SQ_OK)
  2193. {
  2194. /* not yet created? - shouldn't happen in finalize function */
  2195. sq_pop(v, 1);
  2196. new_context_instance(v, &ctx);
  2197. sq_pushuserpointer(v, p);
  2198. sq_push(v, -2);
  2199. sq_rawset(v, -4);
  2200. }
  2201. sq_remove(v, -2); //registrytable
  2202. /* set context */
  2203. ctx->ctx = context;
  2204. if (sq_call(v, 1, SQFalse, SQFalse) != SQ_OK)
  2205. {
  2206. sqlite3_result_error(context, sq_getlasterror_str(v), -1);
  2207. }
  2208. /* invalidate context */
  2209. ctx->ctx = NULL;
  2210. /* cleanup context */
  2211. sq_release(v, &ctx->udata);
  2212. sq_resetobject(&ctx->udata);
  2213. sq_settop(v, top);
  2214. }
  2215. /*
  2216. ** Register a normal function
  2217. ** Params: db, function name, number arguments, [ callback | step, finalize], user data
  2218. ** Returns: true on sucess
  2219. **
  2220. ** Normal function:
  2221. ** Params: context, params
  2222. **
  2223. ** Aggregate function:
  2224. ** Params of step: context, params
  2225. ** Params of finalize: context
  2226. */
  2227. static SQRESULT db_register_function(HSQUIRRELVM v, int aggregate)
  2228. {
  2229. SQ_FUNC_VARS(v);
  2230. SQInteger ftype = 0;
  2231. GET_sqlite3_INSTANCE();
  2232. SQ_GET_STRING(v, 2, name);
  2233. SQ_GET_INTEGER(v, 3, nargs);
  2234. if(sq_gettype(v, 4) != OT_CLOSURE)
  2235. return sq_throwerror(v, "invalid parameter 3 expected closure");
  2236. if (aggregate)
  2237. {
  2238. if(sq_gettype(v,5) != OT_CLOSURE)
  2239. return sq_throwerror(v, "invalid parameter 4 expected closure");
  2240. } else {
  2241. sq_optinteger(v, 5, &ftype, 0);
  2242. }
  2243. sq_sqlite3_sdb_func *func;
  2244. /* maybe an alternative way to allocate memory should be used/avoided */
  2245. func = (sq_sqlite3_sdb_func*)sq_malloc(sizeof(sq_sqlite3_sdb_func));
  2246. memset(func, 0, sizeof(sq_sqlite3_sdb_func));
  2247. _rc_ = sqlite3_create_function(
  2248. self, name, nargs, SQLITE_UTF8 | (ftype == SQLITE_DETERMINISTIC ? ftype : 0),
  2249. func,
  2250. aggregate ? NULL : db_sql_normal_function,
  2251. aggregate ? db_sql_normal_function : NULL,
  2252. aggregate ? db_sql_finalize_function : NULL
  2253. );
  2254. if (_rc_ == SQLITE_OK)
  2255. {
  2256. /* save registered function in db function list */
  2257. func->sdb = sdb;
  2258. func->next = sdb->func;
  2259. sdb->func = func;
  2260. /* save the setp/normal function callback */
  2261. sq_resetobject(&func->fn_step);
  2262. sq_getstackobj(v, 4, &func->fn_step);
  2263. sq_addref(v, &func->fn_step);
  2264. /* save the finalize function callback */
  2265. sq_resetobject(&func->fn_finalize);
  2266. if (aggregate)
  2267. {
  2268. sq_getstackobj(v, 5, &func->fn_finalize);
  2269. sq_addref(v, &func->fn_finalize);
  2270. }
  2271. /* save user data */
  2272. sq_resetobject(&func->udata);
  2273. int udata_idx = aggregate ? 6 : 5;
  2274. if(_top_ >= udata_idx)
  2275. {
  2276. sq_getstackobj(v, udata_idx, &func->udata);
  2277. sq_addref(v, &func->udata);
  2278. }
  2279. }
  2280. else
  2281. {
  2282. /* free allocated memory */
  2283. sq_free(func, sizeof(sq_sqlite3_sdb_func));
  2284. }
  2285. sq_pushbool(v, _rc_ == SQLITE_OK ? 1 : 0);
  2286. return 1;
  2287. }
  2288. //#endif
  2289. static SQRESULT sq_sqlite3_create_function(HSQUIRRELVM v)
  2290. {
  2291. return db_register_function(v, 0);
  2292. }
  2293. static SQRESULT sq_sqlite3_create_aggregate(HSQUIRRELVM v)
  2294. {
  2295. return db_register_function(v, 1);
  2296. }
  2297. static SQRESULT sq_sqlite3_backup(HSQUIRRELVM v)
  2298. {
  2299. SQ_FUNC_VARS(v);
  2300. GET_sqlite3_INSTANCE();
  2301. SQ_GET_STRING(v, 2, fname);
  2302. SQ_OPT_STRING(v, 3, dbname, _SC("main"));
  2303. sqlite3 *pDest;
  2304. sqlite3_backup *pBackup;
  2305. int rc = sqlite3_open(fname, &pDest);
  2306. if(rc!=SQLITE_OK)
  2307. {
  2308. sqlite3_close(pDest);
  2309. return sq_throwerror(v, _SC("SQLite can't open %s"), fname);
  2310. }
  2311. pBackup = sqlite3_backup_init(pDest, "main", self, dbname);
  2312. if( pBackup==0 ){
  2313. rc = sq_throwerror(v, _SC("Error: %s\n"), sqlite3_errmsg(pDest));
  2314. sqlite3_close(pDest);
  2315. }
  2316. while( (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK ){}
  2317. sqlite3_backup_finish(pBackup);
  2318. if( rc==SQLITE_DONE ){
  2319. rc = SQ_OK;
  2320. }else{
  2321. rc = sq_throwerror(v, _SC("Error: %s\n"), sqlite3_errmsg(pDest));
  2322. }
  2323. sqlite3_close(pDest);
  2324. return rc;
  2325. }
  2326. static SQRESULT sq_sqlite3_restore(HSQUIRRELVM v)
  2327. {
  2328. SQ_FUNC_VARS(v);
  2329. GET_sqlite3_INSTANCE();
  2330. SQ_GET_STRING(v, 2, fname);
  2331. SQ_OPT_STRING(v, 3, dbname, _SC("main"));
  2332. sqlite3 *pSrc;
  2333. sqlite3_backup *pBackup;
  2334. int nTimeout = 0;
  2335. int rc = sqlite3_open(fname, &pSrc);
  2336. if(rc!=SQLITE_OK)
  2337. {
  2338. sqlite3_close(pSrc);
  2339. return sq_throwerror(v, _SC("SQLite can't open %s"), fname);
  2340. }
  2341. pBackup = sqlite3_backup_init(self, "main", pSrc, dbname);
  2342. if( pBackup==0 ){
  2343. sqlite3_close(pSrc);
  2344. return sq_throwerror(v, _SC("Error: %s\n"), sqlite3_errmsg(self));
  2345. }
  2346. while( (rc = sqlite3_backup_step(pBackup,100))==SQLITE_OK
  2347. || rc==SQLITE_BUSY ){
  2348. if( rc==SQLITE_BUSY ){
  2349. if( nTimeout++ >= 3 ) break;
  2350. sqlite3_sleep(100);
  2351. }
  2352. }
  2353. sqlite3_backup_finish(pBackup);
  2354. if( rc==SQLITE_DONE ){
  2355. rc = SQ_OK;
  2356. }else if( rc==SQLITE_BUSY || rc==SQLITE_LOCKED ){
  2357. rc = sq_throwerror(v, _SC("Error: source database is busy\n"));
  2358. }else{
  2359. rc = sq_throwerror(v, _SC("Error: %s\n"), sqlite3_errmsg(self));
  2360. }
  2361. sqlite3_close(pSrc);
  2362. return rc;
  2363. }
  2364. #define _DECL_FUNC(name,nparams,tycheck) {_SC(#name), sq_sqlite3_##name,nparams,tycheck}
  2365. static SQRegFunction sq_sqlite3_methods[] =
  2366. {
  2367. _DECL_FUNC(constructor, -2, _SC("xsi")),
  2368. _DECL_FUNC(close, 1, _SC("x")),
  2369. _DECL_FUNC(db_ptr, 1, _SC("x")),
  2370. _DECL_FUNC(IsAutoCommitOn, 1, _SC("x")),
  2371. _DECL_FUNC(version, 1, _SC("x")),
  2372. _DECL_FUNC(errcode, 1, _SC("x")),
  2373. _DECL_FUNC(errmsg, 1, _SC("x")),
  2374. _DECL_FUNC(sleep, 1, _SC("x")),
  2375. _DECL_FUNC(interrupt, 1, _SC("x")),
  2376. _DECL_FUNC(progress_handler, -2, _SC("x i|o c .")),
  2377. _DECL_FUNC(trace, -2, _SC("x c|o .")),
  2378. _DECL_FUNC(update_hook, -2, _SC("x c|o .")),
  2379. _DECL_FUNC(set_authorizer, -2, _SC("x c|o .")),
  2380. _DECL_FUNC(busy_handler, -2, _SC("x c|o .")),
  2381. _DECL_FUNC(busy_timeout, 2, _SC("xi")),
  2382. _DECL_FUNC(create_function, -4, _SC("xsic.")),
  2383. _DECL_FUNC(create_aggregate, -5, _SC("xsicc.")),
  2384. #ifndef WIN32
  2385. _DECL_FUNC(temp_directory, 2, _SC("xs")),
  2386. #endif
  2387. _DECL_FUNC(enable_shared_cache, 2, _SC("xb")),
  2388. _DECL_FUNC(changes, 1, _SC("x")),
  2389. _DECL_FUNC(exec, -2, _SC("xs")),
  2390. _DECL_FUNC(exec_dml, 2, _SC("xs")),
  2391. _DECL_FUNC(exec_get_first_row, 2, _SC("xs")),
  2392. _DECL_FUNC(exec_get_one, 2, _SC("xs")),
  2393. _DECL_FUNC(get_db_name, 1, _SC("x")),
  2394. _DECL_FUNC(last_row_id, 1, _SC("x")),
  2395. _DECL_FUNC(prepare, 2, _SC("xs")),
  2396. _DECL_FUNC(set_busy_timeout, -1, _SC("xi")),
  2397. _DECL_FUNC(total_changes, 1, _SC("x")),
  2398. _DECL_FUNC(backup, -2, _SC("xss")),
  2399. _DECL_FUNC(restore, -2, _SC("xss")),
  2400. #ifdef SQLITE_HAS_CODEC
  2401. _DECL_FUNC(key, 2, _SC("xs")),
  2402. _DECL_FUNC(rekey, 2, _SC("xs")),
  2403. #endif
  2404. {0,0}
  2405. };
  2406. #undef _DECL_FUNC
  2407. #define INT_CONST(v,num) sq_pushstring(v,_SC(#num),-1);sq_pushinteger(v,num);sq_newslot(v,-3,SQTrue);
  2408. #ifdef __cplusplus
  2409. extern "C" {
  2410. #endif
  2411. SQRESULT sqext_register_SQLite3(HSQUIRRELVM v)
  2412. {
  2413. sq_insertfunc(v, _SC("sle2vecOfvec"), sq_sle2vecOfvec, -2, _SC(". s|x a i"), SQTrue);
  2414. sq_insertfunc(v, _SC("get_sle_size"), sq_get_sle_size, -2, _SC(".i"), SQTrue);
  2415. sq_insertfunc(v, _SC("add2sle"), sq_add2sle, -3, _SC(".xsi"), SQTrue);
  2416. sq_pushconsttable(v);
  2417. #define INT_SLE_CONST(num) sq_pushstring(v,_SC("SLE_" #num),-1);sq_pushinteger(v,num);sq_newslot(v,-3,SQTrue);
  2418. INT_SLE_CONST(IBYTE1);
  2419. INT_SLE_CONST(IBYTE2);
  2420. INT_SLE_CONST(IBYTE3);
  2421. INT_SLE_CONST(IBYTE4);
  2422. INT_SLE_CONST(SIZE1BYTE);
  2423. INT_SLE_CONST(SIZE2BYTE);
  2424. INT_SLE_CONST(SIZE3BYTE);
  2425. INT_SLE_CONST(SIZE4BYTE);
  2426. INT_SLE_CONST(SLEMARK);
  2427. INT_SLE_CONST(SLEEND);
  2428. sq_poptop(v); //remove const table
  2429. HSQOBJECT sqlite3_NULL;
  2430. sq_pushregistrytable(v);
  2431. sq_pushstring(v, sqlite3_NULL_Name,-1);
  2432. sq_newuserdata(v, sizeof(void*));
  2433. sq_resetobject(&sqlite3_NULL);
  2434. sq_getstackobj(v, -1, &sqlite3_NULL);
  2435. sq_newtable(v);
  2436. sq_insert_reg_funcs(v, sqlite3_NULL_methods);
  2437. sq_setdelegate(v, -2);
  2438. sq_newslot(v,-3,SQTrue);
  2439. sq_pushstring(v,_SC("sqite3_context"),-1);
  2440. sq_newclass(v,SQFalse);
  2441. sq_settypetag(v,-1,(void*)sq_sqlite3_context_TAG);
  2442. sq_insert_reg_funcs(v, sq_sqlite3_context_methods);
  2443. sq_newslot(v,-3,SQTrue);
  2444. sq_poptop(v); //remove registrytable
  2445. sq_pushstring(v,SQLite3_TAG,-1);
  2446. sq_newclass(v,SQFalse);
  2447. sq_settypetag(v,-1,(void*)SQLite3_TAG);
  2448. sq_insert_reg_funcs(v, sq_sqlite3_methods);
  2449. INT_CONST(v,SQLITE_OPEN_CREATE);
  2450. INT_CONST(v,SQLITE_OPEN_READWRITE);
  2451. INT_CONST(v,SQLITE_OPEN_SHAREDCACHE);
  2452. INT_CONST(v,SQLITE_OPEN_SUBLATIN_NA_LIKE);
  2453. INT_CONST(v,SQLITE_OK);
  2454. INT_CONST(v,SQLITE_BUSY);
  2455. INT_CONST(v,SQLITE_DONE);
  2456. INT_CONST(v,SQLITE_DETERMINISTIC);
  2457. INT_CONST(v,SQLITE_ERROR);
  2458. INT_CONST(v,SQLITE_INTERRUPT);
  2459. INT_CONST(v,SQLITE_MISUSE);
  2460. INT_CONST(v,SQLITE_ROW);
  2461. INT_CONST(v,SQLITE_LOCKED_SHAREDCACHE);
  2462. INT_CONST(v,SQLITE_BUSY_RECOVERY);
  2463. INT_CONST(v,SQLITE_BUSY_SNAPSHOT);
  2464. INT_CONST(v,SQLITE_CANTOPEN_NOTEMPDIR);
  2465. INT_CONST(v,SQLITE_CANTOPEN_ISDIR);
  2466. INT_CONST(v,SQLITE_CANTOPEN_FULLPATH);
  2467. INT_CONST(v,SQLITE_CANTOPEN_CONVPATH);
  2468. INT_CONST(v,SQLITE_CORRUPT_VTAB);
  2469. INT_CONST(v,SQLITE_READONLY_RECOVERY);
  2470. INT_CONST(v,SQLITE_READONLY_CANTLOCK);
  2471. INT_CONST(v,SQLITE_READONLY_ROLLBACK);
  2472. INT_CONST(v,SQLITE_READONLY_DBMOVED);
  2473. INT_CONST(v,SQLITE_ABORT_ROLLBACK);
  2474. INT_CONST(v,SQLITE_CONSTRAINT_CHECK);
  2475. INT_CONST(v,SQLITE_CONSTRAINT_COMMITHOOK);
  2476. INT_CONST(v,SQLITE_CONSTRAINT_FOREIGNKEY);
  2477. INT_CONST(v,SQLITE_CONSTRAINT_FUNCTION);
  2478. INT_CONST(v,SQLITE_CONSTRAINT_NOTNULL);
  2479. INT_CONST(v,SQLITE_CONSTRAINT_PRIMARYKEY);
  2480. INT_CONST(v,SQLITE_CONSTRAINT_TRIGGER);
  2481. INT_CONST(v,SQLITE_CONSTRAINT_UNIQUE);
  2482. INT_CONST(v,SQLITE_CONSTRAINT_VTAB);
  2483. INT_CONST(v,SQLITE_CONSTRAINT_ROWID);
  2484. INT_CONST(v,SQLITE_NOTICE_RECOVER_WAL);
  2485. INT_CONST(v,SQLITE_NOTICE_RECOVER_ROLLBACK);
  2486. INT_CONST(v,SQLITE_WARNING_AUTOINDEX);
  2487. /*Authorizer codes*/
  2488. INT_CONST(v, SQLITE_IGNORE);
  2489. INT_CONST(v, SQLITE_DENY);
  2490. INT_CONST(v, SQLITE_CREATE_INDEX);
  2491. INT_CONST(v, SQLITE_CREATE_TABLE);
  2492. INT_CONST(v, SQLITE_CREATE_TEMP_INDEX);
  2493. INT_CONST(v, SQLITE_CREATE_TEMP_TABLE);
  2494. INT_CONST(v, SQLITE_CREATE_TEMP_TRIGGER);
  2495. INT_CONST(v, SQLITE_CREATE_TEMP_VIEW);
  2496. INT_CONST(v, SQLITE_CREATE_TRIGGER);
  2497. INT_CONST(v, SQLITE_CREATE_VIEW);
  2498. INT_CONST(v, SQLITE_DELETE);
  2499. INT_CONST(v, SQLITE_DROP_INDEX);
  2500. INT_CONST(v, SQLITE_DROP_TABLE);
  2501. INT_CONST(v, SQLITE_DROP_TEMP_INDEX);
  2502. INT_CONST(v, SQLITE_DROP_TEMP_TABLE);
  2503. INT_CONST(v, SQLITE_DROP_TEMP_TRIGGER);
  2504. INT_CONST(v, SQLITE_DROP_TEMP_VIEW);
  2505. INT_CONST(v, SQLITE_DROP_TRIGGER);
  2506. INT_CONST(v, SQLITE_DROP_VIEW);
  2507. INT_CONST(v, SQLITE_INSERT);
  2508. INT_CONST(v, SQLITE_PRAGMA);
  2509. INT_CONST(v, SQLITE_READ);
  2510. INT_CONST(v, SQLITE_SELECT);
  2511. INT_CONST(v, SQLITE_TRANSACTION);
  2512. INT_CONST(v, SQLITE_UPDATE);
  2513. INT_CONST(v, SQLITE_ATTACH);
  2514. INT_CONST(v, SQLITE_DETACH);
  2515. INT_CONST(v, SQLITE_ALTER_TABLE);
  2516. INT_CONST(v, SQLITE_REINDEX);
  2517. INT_CONST(v, SQLITE_ANALYZE);
  2518. INT_CONST(v, SQLITE_CREATE_VTABLE);
  2519. INT_CONST(v, SQLITE_DROP_VTABLE);
  2520. INT_CONST(v, SQLITE_FUNCTION);
  2521. INT_CONST(v, SQLITE_SAVEPOINT);
  2522. INT_CONST(v, SQLITE_COPY);
  2523. INT_CONST(v, SQLITE_RECURSIVE);
  2524. //push sqlite3_NULL as a member
  2525. sq_pushstring(v, nullName,-1);
  2526. sq_pushobject(v, sqlite3_NULL);
  2527. sq_newslot(v,-3,SQTrue);
  2528. sq_newslot(v,-3,SQTrue);
  2529. sq_pushstring(v, SQLite3_Stmt_TAG,-1);
  2530. sq_newclass(v,SQFalse);
  2531. sq_settypetag(v,-1,(void*)SQLite3_Stmt_TAG);
  2532. sq_insert_reg_funcs(v, sq_sqlite3_stmt_methods);
  2533. INT_CONST(v,SQLITE_INTEGER);
  2534. INT_CONST(v,SQLITE_FLOAT);
  2535. INT_CONST(v,SQLITE_NULL);
  2536. INT_CONST(v,SQLITE_TEXT);
  2537. INT_CONST(v,SQLITE_BLOB);
  2538. INT_CONST(v,SQLITE_OK);
  2539. INT_CONST(v,SQLITE_DONE);
  2540. INT_CONST(v,SQLITE_ROW);
  2541. INT_CONST(v,AS_STRING_ALWAYS);
  2542. INT_CONST(v,NULL_AS_EMPTY_STR);
  2543. INT_CONST(v,WITH_COL_NAMES);
  2544. INT_CONST(v,WITH_BLOB_AS_NULL);
  2545. INT_CONST(v,WITH_SQ_NULL);
  2546. //push sqlite3_NULL as a member
  2547. sq_pushstring(v, nullName,-1);
  2548. sq_pushobject(v, sqlite3_NULL);
  2549. sq_newslot(v,-3,SQTrue);
  2550. sq_newslot(v,-3,SQTrue);
  2551. return 1;
  2552. }
  2553. #ifdef __cplusplus
  2554. }
  2555. #endif