mirrors/cosmopolitan
1
0
Fork 0
mirror of https://github.com/jart/cosmopolitan.git synced 2025-08-08 19:00:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add iterator support to SQLite Lua API

Browse source
This commit is contained in:
Paul Kulchenko 2022-10-26 22:01:29 -07:00
parent 4a96ebd04e
commit 90f8180c4c
1 changed files with 51 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

52
tool/net/lsqlite3.c
View file

@ -126,8 +126,10 @@ static int sqlite_ctx_meta_ref;
#ifdef SQLITE_ENABLE_SESSION #ifdef SQLITE_ENABLE_SESSION
static const char *const sqlite_ses_meta = ":sqlite3:ses"; static const char *const sqlite_ses_meta = ":sqlite3:ses";
static const char *const sqlite_reb_meta = ":sqlite3:reb"; static const char *const sqlite_reb_meta = ":sqlite3:reb";
static const char *const sqlite_itr_meta = ":sqlite3:itr";
static int sqlite_ses_meta_ref; static int sqlite_ses_meta_ref;
static int sqlite_reb_meta_ref; static int sqlite_reb_meta_ref;
static int sqlite_itr_meta_ref;
#endif #endif
/* /*
@ -1814,6 +1816,45 @@ static int db_deserialize(lua_State *L) {
#ifdef SQLITE_ENABLE_SESSION #ifdef SQLITE_ENABLE_SESSION
/*
** =======================================================
** Iterator functions (for session support)
** =======================================================
*/
typedef struct {
sqlite3_changeset_iter *itr;
} liter;
static liter *lsqlite_makeiter(lua_State *L, sqlite3_changeset_iter *iter) {
liter *litr = (liter*)lua_newuserdata(L, sizeof(liter));
lua_rawgeti(L, LUA_REGISTRYINDEX, sqlite_itr_meta_ref);
lua_setmetatable(L, -2);
litr->itr = iter;
return litr;
}
static liter *lsqlite_getiter(lua_State *L, int index) {
return (liter *)luaL_checkudata(L, index, sqlite_itr_meta);
}
static liter *lsqlite_checkiter(lua_State *L, int index) {
liter *litr = lsqlite_getiter(L, index);
if (litr->itr == NULL) luaL_argerror(L, index, "invalid sqlite iterator");
return litr;
}
static int liter_tostring(lua_State *L) {
char buff[32];
liter *litr = lsqlite_getiter(L, 1);
if (litr->itr == NULL)
strcpy(buff, "closed");
else
sprintf(buff, "%p", litr->itr);
lua_pushfstring(L, "sqlite iterator (%s)", buff);
return 1;
}
/* /*
** ======================================================= ** =======================================================
** Rebaser functions (for session support) ** Rebaser functions (for session support)
@ -1958,8 +1999,8 @@ static int db_filter_callback(
int result, isint; int result, isint;
lua_rawgeti(L, LUA_REGISTRYINDEX, filter_cb); /* get callback */ lua_rawgeti(L, LUA_REGISTRYINDEX, filter_cb); /* get callback */
lua_rawgeti(L, LUA_REGISTRYINDEX, filter_udata); /* get callback user data */
lua_pushstring(L, zTab); lua_pushstring(L, zTab);
lua_rawgeti(L, LUA_REGISTRYINDEX, filter_udata); /* get callback user data */
if (lua_pcall(L, 2, 1, 0) != LUA_OK) return lua_error(L); if (lua_pcall(L, 2, 1, 0) != LUA_OK) return lua_error(L);
@ -2566,6 +2607,11 @@ static const luaL_Reg reblib[] = {
{NULL, NULL} {NULL, NULL}
}; };
static const luaL_Reg itrlib[] = {
{"__tostring", liter_tostring },
{NULL, NULL}
};
#endif #endif
static const luaL_Reg sqlitelib[] = { static const luaL_Reg sqlitelib[] = {
@ -2604,12 +2650,16 @@ LUALIB_API int luaopen_lsqlite3(lua_State *L) {
#ifdef SQLITE_ENABLE_SESSION #ifdef SQLITE_ENABLE_SESSION
create_meta(L, sqlite_ses_meta, seslib); create_meta(L, sqlite_ses_meta, seslib);
create_meta(L, sqlite_reb_meta, reblib); create_meta(L, sqlite_reb_meta, reblib);
create_meta(L, sqlite_itr_meta, itrlib);
luaL_getmetatable(L, sqlite_ses_meta); luaL_getmetatable(L, sqlite_ses_meta);
sqlite_ses_meta_ref = luaL_ref(L, LUA_REGISTRYINDEX); sqlite_ses_meta_ref = luaL_ref(L, LUA_REGISTRYINDEX);
luaL_getmetatable(L, sqlite_reb_meta); luaL_getmetatable(L, sqlite_reb_meta);
sqlite_reb_meta_ref = luaL_ref(L, LUA_REGISTRYINDEX); sqlite_reb_meta_ref = luaL_ref(L, LUA_REGISTRYINDEX);
luaL_getmetatable(L, sqlite_itr_meta);
sqlite_itr_meta_ref = luaL_ref(L, LUA_REGISTRYINDEX);
#endif #endif
/* register (local) sqlite metatable */ /* register (local) sqlite metatable */