sq_sqlite3.cpp 97 KB

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