From 1ab78f9d2905a1a036a03bf56d2d0422f9af27fb Mon Sep 17 00:00:00 2001 From: thai-canada <93546914+thai-canada@users.noreply.github.com> Date: Mon, 8 Jun 2026 12:19:56 -0400 Subject: [PATCH 1/4] Create SQLite Plugin Signed-off-by: thai-canada <93546914+thai-canada@users.noreply.github.com> --- SQLite Plugin | 1 + 1 file changed, 1 insertion(+) create mode 100644 SQLite Plugin diff --git a/SQLite Plugin b/SQLite Plugin new file mode 100644 index 0000000..8b13789 --- /dev/null +++ b/SQLite Plugin @@ -0,0 +1 @@ + From e409d197bd71b7dc9fb14d30d03c01a94220e0f2 Mon Sep 17 00:00:00 2001 From: thai-canada <93546914+thai-canada@users.noreply.github.com> Date: Mon, 8 Jun 2026 12:24:41 -0400 Subject: [PATCH 2/4] Add README for BrightSign SQLite Plugin This README provides detailed information about the BrightSign SQLite Plugin, including its functionality, configuration options, access URLs, REST API endpoints, UDP commands, and troubleshooting tips. Signed-off-by: thai-canada <93546914+thai-canada@users.noreply.github.com> --- sqlite-plugin/README.md | 136 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 136 insertions(+) create mode 100644 sqlite-plugin/README.md diff --git a/sqlite-plugin/README.md b/sqlite-plugin/README.md new file mode 100644 index 0000000..bd38151 --- /dev/null +++ b/sqlite-plugin/README.md @@ -0,0 +1,136 @@ +# BrightSign SQLite Plugin (`sql.brs`) + +This plugin runs a local SQLite-backed API server on a BrightSign player and also accepts UDP commands for common table/row operations. + +- Plugin file: `sql.brs` +- Default DB file: `sd:/userData.db` +- Default table: `UserInfo` +- Default HTTP port: `8009` +- Created by: Thai Nguyen + +## What It Does + +- Creates/opens a SQLite database on player storage. +- Ensures a default table exists at startup. +- Exposes REST endpoints for CRUD + schema/table utilities. +- Supports UDP commands for quick insert/update/delete/table operations. +- Serves a built-in UI/help page at `/` and `/help`. + +## Configuration (in `sql.brs`) + +Inside `sql_Initialize`, you can adjust: + +- `h.dbFile` (database location) +- `h.defaultTable` (default table name) +- `h.webPort` (REST API port) +- `h.columnArray` (default schema for table creation) + +Notes: +- `rowID` is always auto-managed as `INTEGER PRIMARY KEY AUTOINCREMENT`. +- `rowID` is reserved and should not be changed. + +## Access URLs + +From your network: + +- `http://:8009/` +- `http://:8009/help` +- Or mDNS style: `http://brightsign-.local:8009` + +## REST API + +### GET Endpoints + +- `GET /` : Home UI page +- `GET /help` : Interactive API help page +- `GET /readAll?tableName=UserInfo` +- `GET /readRecord?tableName=UserInfo&rowID=1` +- `GET /readColumn?tableName=UserInfo&columnName=column1` +- `GET /search?tableName=UserInfo&columnName=column1&value=Alice` +- `GET /tableCount` +- `GET /schema` +- `GET /rowCount?tableName=UserInfo` + +### POST Endpoints (`application/x-www-form-urlencoded`) + +- `POST /createTable` + - Required: `tableName` + - Optional: `columnsJson` (JSON array, e.g. `[{"name":"orderNo"},{"name":"amount"}]`) +- `POST /insert` + - Required: `tableName` + - Then send column/value pairs for that table +- `POST /bulkInsert` + - Required: `tableName`, `rowsJson` (JSON array of row objects) +- `POST /update` + - Required: `tableName`, `rowID` + - Then send updated column/value pairs +- `POST /delete` + - Required: `tableName`, `rowID` (single-row delete) +- `POST /deleteWhere` + - Required: `tableName`, `columnName`, `value` +- `POST /emptyTable` + - Required: `tableName` (removes all rows) + +## curl Examples + +```bash +# Read all rows +curl "http://:8009/readAll?tableName=UserInfo" + +# Create table with default columnArray +curl -X POST "http://:8009/createTable" \ + -H "Content-Type: application/x-www-form-urlencoded" \ + --data "tableName=Orders" + +# Create table with custom schema +curl -X POST "http://:8009/createTable" \ + -H "Content-Type: application/x-www-form-urlencoded" \ + --data-urlencode "tableName=Orders" \ + --data-urlencode 'columnsJson=[{"name":"orderNo"},{"name":"amount"}]' + +# Insert one row +curl -X POST "http://:8009/insert" \ + -H "Content-Type: application/x-www-form-urlencoded" \ + --data "tableName=UserInfo&column1=Alice&column2=Engineer&column3=Mississauga" + +# Update row 1 +curl -X POST "http://:8009/update" \ + -H "Content-Type: application/x-www-form-urlencoded" \ + --data "tableName=UserInfo&rowID=1&column1=AliceUpdated" + +# Delete row 1 +curl -X POST "http://:8009/delete" \ + -H "Content-Type: application/x-www-form-urlencoded" \ + --data "tableName=UserInfo&rowID=1" +``` + +## UDP Commands + +The plugin parses underscore-delimited commands. + +- `Insert____` +- `UpdateRow_____` +- `UpdateColumn____` +- `Delete__` +- `CreateTable_` +- `EmptyTable_` + +Example: + +```text +CreateTable_UserTest +Insert_UserInfo_Alice_Engineer_Mississauga +UpdateColumn_UserInfo_1_column2_Manager +Delete_UserInfo_1 +``` + +## Included Files + +- `sql.brs` : Main SQLite plugin and API server + +## Troubleshooting + +- If API is unreachable, verify player IP and port `8009`. +- If table/column actions fail, validate table/column names and request body fields. +- If DB operations fail, confirm writable storage path (`sd:/`). +- Open `/help` on the player for a quick interactive endpoint tester. From b43d0c46f83b09e214bb655e6c101af5331db7a4 Mon Sep 17 00:00:00 2001 From: thai-canada <93546914+thai-canada@users.noreply.github.com> Date: Mon, 8 Jun 2026 12:24:59 -0400 Subject: [PATCH 3/4] Add files via upload Signed-off-by: thai-canada <93546914+thai-canada@users.noreply.github.com> --- sqlite-plugin/sql.brs | 3019 +++++++++++++++++++++++++++++++++++++++++ 1 file changed, 3019 insertions(+) create mode 100644 sqlite-plugin/sql.brs diff --git a/sqlite-plugin/sql.brs b/sqlite-plugin/sql.brs new file mode 100644 index 0000000..7ea152f --- /dev/null +++ b/sqlite-plugin/sql.brs @@ -0,0 +1,3019 @@ +' plugin name: sql +' Open http://brightsign_IP:8009 to get started +' Or http://brightsign-.local:8009 +' created by: Thai Nguyen 2026-06-08 + +Function sql_Initialize(msgPort As Object, userVariables As Object, bsp as Object) + + h = {} + h.version = "1.00.00" + h.msgPort = msgPort + h.userVariables = userVariables + h.bsp = bsp + h.SystemLog = CreateObject("roSystemLog") + h.ProcessEvent = sql_ProcessEvent + h.userData = {} + h.tableNames = [] + h.isReady = false ' Set to true when initialization is complete + + '----------------------------------------------------------------------------------------------------------- + h.dbFile = "sd:/userData.db" + h.defaultTable = "UserInfo" + h.defaultRowID = "rowID" ' DO NOT CHANGE THIS + h.webPort = 8009 ' port of REST API. + ' the column structure. ------------------------------------------------------------------------------------ + h.columnArray = [ + { name: "column1" }, + { name: "column2" }, + { name: "column3" } + ] + ' This creates the UserInfo table during startup using the default column array above. + ' You can edit the column names and number of columns in this columnArray. + ' It will be used to create the new table when columnsJson is not provided in the + ' POST /createTable request. + + ' rowID is added automatically as INTEGER PRIMARY KEY AUTOINCREMENT. + ' All other column values are TEXT. + ' ----------------------------------------------------------------------------------------------------------- + + h.SqlHomeAA = { HandleEvent: sql_GetHomePage, mVar: h } + h.SqlHelpAA = { HandleEvent: sql_GetHelpPage, mVar: h } + h.SqlReadSelectedAA = { HandleEvent: sql_PostReadRecordsRest, mVar: h } + h.SqlReadRowAA = { HandleEvent: sql_GetReadRowRest, mVar: h } + h.SqlReadColumnAA = { HandleEvent: sql_GetReadColumnRest, mVar: h } + h.SqlSearchAA = { HandleEvent: sql_GetSearchRowsRest, mVar: h } + h.SqlTablesAA = { HandleEvent: sql_GetTablesRest, mVar: h } + h.SqlSchemaAA = { HandleEvent: sql_GetSchemaRest, mVar: h } + h.SqlCreateAA = { HandleEvent: sql_CreateTableRest, mVar: h } + h.SqlInsertAA = { HandleEvent: sql_InsertRecordRest, mVar: h } + h.SqlUpdateAA = { HandleEvent: sql_UpdateRecordRest, mVar: h } + h.SqlDeleteAA = { HandleEvent: sql_DeleteRecordRest, mVar: h } + h.SqlDeleteTableAA = { HandleEvent: sql_DeleteTableRest, mVar: h } + h.SqlCountAA = { HandleEvent: sql_GetCountRest, mVar: h } + h.SqlDeleteWhereAA = { HandleEvent: sql_DeleteWhereRest, mVar: h } + h.SqlBulkInsertAA = { HandleEvent: sql_BulkInsertRest, mVar: h } + + h.localServer = CreateObject("roHttpServer", { port: h.webPort }) + if type(h.localServer) = "roHttpServer" then + h.localServer.SetPort(msgPort) + h.localServer.AddGetFromEvent({ url_path: "/", user_data: h.SqlHomeAA }) + h.localServer.AddGetFromEvent({ url_path: "/help", user_data: h.SqlHelpAA }) + h.localServer.AddGetFromEvent({ url_path: "/readAll", user_data: h.SqlReadSelectedAA }) + h.localServer.AddGetFromEvent({ url_path: "/readRecord", user_data: h.SqlReadRowAA }) + h.localServer.AddGetFromEvent({ url_path: "/readColumn", user_data: h.SqlReadColumnAA }) + h.localServer.AddGetFromEvent({ url_path: "/search", user_data: h.SqlSearchAA }) + h.localServer.AddGetFromEvent({ url_path: "/tableCount", user_data: h.SqlTablesAA }) + h.localServer.AddGetFromEvent({ url_path: "/schema", user_data: h.SqlSchemaAA }) + h.localServer.AddGetFromEvent({ url_path: "/rowCount", user_data: h.SqlCountAA }) + h.localServer.AddPostToFormData({ url_path: "/createTable", user_data: h.SqlCreateAA }) + h.localServer.AddPostToFormData({ url_path: "/insert", user_data: h.SqlInsertAA }) + h.localServer.AddPostToFormData({ url_path: "/update", user_data: h.SqlUpdateAA }) + h.localServer.AddPostToFormData({ url_path: "/delete", user_data: h.SqlDeleteAA }) + h.localServer.AddPostToFormData({ url_path: "/emptyTable", user_data: h.SqlDeleteTableAA }) + h.localServer.AddPostToFormData({ url_path: "/deleteWhere", user_data: h.SqlDeleteWhereAA }) + h.localServer.AddPostToFormData({ url_path: "/bulkInsert", user_data: h.SqlBulkInsertAA }) + h.SystemLog.SendLine("---------------------- SQLite web server running at port:" + h.webPort.ToStr()) + else + h.SystemLog.SendLine("Failed to create SQLite web server") + end if + + + ' normalize the default columnArray to ensure it is in the correct format and has valid column names. ------ + normalizedDefaultColumns = sql_NormalizeCreateColumnArray(h.columnArray, h.defaultRowID) + if type(normalizedDefaultColumns) = "roArray" and normalizedDefaultColumns.Count() > 0 then + h.columnArray = normalizedDefaultColumns + end if + + ' Make sure the database file exists and is initialized before accepting any commands or API calls. --------- + sql_EnsureDatabaseFile(h) + ' ----------------------------------------------------------------------------------------------------------- + + + h.tableNames = sql_GetTableNames(h.dbFile) + sql_SyncDefaultTable(h) + + return h + +End Function + +Function sql_ProcessEvent(event As Object) as boolean + retval = false + + if m.isReady = false then + if m.bsp <> invalid and m.bsp.udpReceivePort <> invalid then + m.isReady = true + EnableUDPNotifications(m) + end if + end if + + if type(event) = "roAssociativeArray" then ' Receive a message from BA + else if type(event) = "roHtmlWidgetEvent" then + ' HTML widget messages are intentionally ignored in this plugin build. + + eventData = event.GetData() + if type(eventData) = "roAssociativeArray" and type(eventData.reason) = "roString" then + + ' Example of sending message from HTML5 zone to BrightScript: + ' var bsMessage = new BSMessagePort(); + ' bsMessage.PostBSMessage({complete: true, result: "Insert____"}); + + if eventData.reason = "message" then + if eventData.message.result = valid then + + msg$ = eventData.message.result + + regex = CreateObject("roRegEx", "_", "i") + parts = sql_CommandPartsToArray(regex.Split(msg$)) + 'm.SystemLog.SendLine("------------------ Received roHtmlWidgetEvent message: " + msg$) + retval = sql_HandleCommand(m, msg$, parts) + end if + end if + end if + + else if type(event) = "roDatagramEvent" then + + msg$ = event.GetString() + + regex = CreateObject("roRegEx", "_", "i") + parts = sql_CommandPartsToArray(regex.Split(msg$)) + 'm.SystemLog.SendLine("------------------ Received UDP message: " + msg$) + retval = sql_HandleCommand(m, msg$, parts) + + end if + return retval +End Function + +Function sql_HandleCommand(m as Object, msg$ as String, parts as Object) as Boolean + if left(msg$, 7) = "Insert_" then + ' Example: Insert____ + sql_HandleInsert(m, parts) + return true + else if left(msg$, 10) = "UpdateRow_" then + ' Example: UpdateRow_____ + sql_HandleUpdateRow(m, parts) + return true + else if left(msg$, 13) = "UpdateColumn_" then + ' Example: UpdateColumn____ + sql_HandleUpdateColumn(m, parts) + return true + else if left(msg$, 7) = "Delete_" then + ' Example: Delete__ + sql_HandleDelete(m, parts) + return true + else if left(msg$, 12) = "CreateTable_" then + ' Example: CreateTable_ + sql_HandleCreateTable(m, parts) + return true + else if left(msg$, 11) = "EmptyTable_" then + ' Example: EmptyTable_ + sql_HandleEmptyTable(m, parts) + return true + end if + + return false +End Function + +Function sql_CommandPartsToArray(parts as Object) as Object + if type(parts) = "roArray" then + return parts + end if + + arr = [] + if parts = invalid then + return arr + end if + + for each item in parts + arr.Push(item) + next + + return arr +End Function + +Sub sql_HandleInsert(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() < 2 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + if not sql_IsValidTableName(tableName$) then + return + end if + + columns = sql_GetInsertableColumnsForTable(m, m.dbFile, tableName$) + values = sql_BuildValuesFromParts(parts, 2, columns.Count()) + sql_InsertUserData(m, m.dbFile, tableName$, columns, values) +End Sub + +Sub sql_HandleUpdateRow(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() < 3 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + rowID$ = sql_TrimString(parts[2]) + rowIdNum = sql_ParsePositiveIntStrict(rowID$) + if not sql_IsValidTableName(tableName$) or rowIdNum <= 0 then + return + end if + + columns = sql_GetInsertableColumnsForTable(m, m.dbFile, tableName$) + values = sql_BuildValuesFromParts(parts, 3, columns.Count()) + sql_UpdateRecord(m, m.dbFile, tableName$, rowIdNum, columns, values) +End Sub + +Sub sql_HandleUpdateColumn(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() < 5 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + rowID$ = sql_TrimString(parts[2]) + columnName$ = sql_TrimString(parts[3]) + rowIdNum = sql_ParsePositiveIntStrict(rowID$) + if not sql_IsValidTableName(tableName$) or rowIdNum <= 0 or not sql_IsValidTableName(columnName$) then + return + end if + + if not sql_ColumnExists(m.dbFile, tableName$, columnName$) then + return + end if + + newValue$ = sql_JoinPartsWithUnderscore(parts, 4) + columns = [columnName$] + values = [newValue$] + sql_UpdateRecord(m, m.dbFile, tableName$, rowIdNum, columns, values) +End Sub + +Sub sql_HandleDelete(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() <> 3 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + rowID$ = sql_TrimString(parts[2]) + rowIdNum = sql_ParsePositiveIntStrict(rowID$) + if not sql_IsValidTableName(tableName$) or rowIdNum <= 0 then + return + end if + + sql_DeleteRecord(m, m.dbFile, tableName$, rowIdNum) +End Sub + +Sub sql_HandleCreateTable(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() < 2 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + if not sql_IsValidTableName(tableName$) then + return + end if + + createTableSQL$ = sql_BuildCreateTableSQL(tableName$, m.columnArray) + if createTableSQL$ = "" then + return + end if + + if sql_CreateAndInitializeCustomDB(m, m.dbFile, createTableSQL$) then + m.tableNames = sql_GetTableNames(m.dbFile) + end if +End Sub + +Sub sql_HandleEmptyTable(m as Object, parts as Object) + if type(parts) <> "roArray" or parts.Count() < 2 then + return + end if + + tableName$ = sql_TrimString(parts[1]) + if not sql_IsValidTableName(tableName$) then + return + end if + + sql_DeleteTableRows(m, m.dbFile, tableName$) +End Sub + + + + +Function sql_CreateAndInitializeCustomDB(m as Object, dbName$ as String, createTableSQL$ as String) as Boolean + myDB = CreateObject("roSqliteDatabase") + success = false + resolvedDbName$ = sql_ResolveDbPath(dbName$) + + if myDB.Create(resolvedDbName$) = invalid then + if myDB.Open(resolvedDbName$) = invalid then + m.SystemLog.SendLine("---------------------- Failed to create/open custom database file: " + resolvedDbName$) + return false + end if + end if + + createStatement = myDB.CreateStatement(createTableSQL$) + if type(createStatement) = "roSqliteStatement" then + SQLITE_COMPLETE = 100 + result = createStatement.Run() + if result = SQLITE_COMPLETE or result = 101 then + m.SystemLog.SendLine("---------------------- Custom table created successfully.") + success = true + else + m.SystemLog.SendLine("---------------------- Error creating table. Error code: " + result.ToStr()) + end if + createStatement.Finalise() + else + ' Some firmware builds return invalid statement on first handle. Re-open and retry once. + myDB.Close() + myDB = CreateObject("roSqliteDatabase") + if myDB.Open(resolvedDbName$) = invalid then + m.SystemLog.SendLine("---------------------- Failed to re-open database for statement retry: " + resolvedDbName$) + return false + end if + + createStatement = myDB.CreateStatement(createTableSQL$) + if type(createStatement) <> "roSqliteStatement" then + m.SystemLog.SendLine("---------------------- Failed to create SQL statement for table creation (retry).") + myDB.Close() + return false + end if + + SQLITE_COMPLETE = 100 + result = createStatement.Run() + if result = SQLITE_COMPLETE or result = 101 then + m.SystemLog.SendLine("---------------------- Custom table created successfully (retry).") + success = true + else + m.SystemLog.SendLine("---------------------- Error creating table on retry. Error code: " + result.ToStr()) + end if + createStatement.Finalise() + end if + + myDB.Close() + return success +End Function + + +' ===== HTML Pages ===== +Sub sql_GetHelpPage(userData as Object, e as Object) + mVar = userData.mVar + portText$ = mVar.webPort.ToStr() + columnsJsonPlaceholder$ = "[{" + Chr(34) + "name" + Chr(34) + ":" + Chr(34) + "orderNo" + Chr(34) + "},{" + Chr(34) + "name" + Chr(34) + ":" + Chr(34) + "amount" + Chr(34) + "}]" + html$ = "" + html$ = html$ + "" + html$ = html$ + "SQLite API Help" + html$ = html$ + "" + html$ = html$ + "" + html$ = html$ + "" + html$ = html$ + "

SQLite API Help

" + html$ = html$ + "

Server IP: at port: " + portText$ + "

" + 'html$ = html$ + "

Default table use in this page is: UserInfo

" + html$ = html$ + "

GET /

curl http://window.location.hostname:8009
Returns the UI with all records in the table.
" + html$ = html$ + "

GET /readAll

curl http://window.location.hostname:8009/readAll (no parameter uses default table)
curl http://window.location.hostname:8009/readAll?tableName=UserInfo
{"rows":[{"rowID":1,"column1":"Alice","column2":"Engineer","column3":"Mississauga"}]}
" + html$ = html$ + "

GET /readRecord

curl http://window.location.hostname:8009/readRecord?tableName=UserInfo&rowID=1
{"status":"success","table":"UserInfo","row":{"rowID":1,"column1":"Alice","column2":"Engineer","column3":"Mississauga"}}
" + html$ = html$ + "

GET /readColumn

curl http://window.location.hostname:8009/readColumn?tableName=UserInfo&columnName=column1
{"status":"success","table":"UserInfo","column":"column1","values":["Alice","Bob"]}
" + html$ = html$ + "

GET /search

curl http://window.location.hostname:8009/search?tableName=UserInfo&columnName=column1&value=Alice
{"status":"success","dbFile":"sd:/userData.db","table":"UserInfo","column":"column1","value":"Alice","count":1,"rows":[{"rowID":1,"column1":"Alice","column2":"Engineer","column3":"Mississauga"}]}
" + html$ = html$ + "

GET /tableCount

curl http://window.location.hostname:8009/tableCount (returns an array of existing tables)
{"status":"success","count":2,"tables":["UserInfo","UserTest"]}
" + html$ = html$ + "

GET /rowCount

curl http://window.location.hostname:8009/rowCount (no parameter uses default table)
curl http://window.location.hostname:8009/rowCount?tableName=UserInfo
{"status":"success","table":"UserInfo","count":5}
" + html$ = html$ + "

GET /schema

curl http://window.location.hostname:8009/schema
{"status":"success","countTable":2,"schema":[{"table":"UserInfo","columnCount":3,"columns":["column1","column2","column3"]},{"table":"UserTest","columnCount":2,"columns":["name","email"]}]}
" + html$ = html$ + "

POST /insert

curl.exe -X POST http://window.location.hostname:8009/insert -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + "--data tableName=UserInfo&column1=Alice&column2=Engineer&column3=Mississauga
{"status":"success","table":"UserInfo","message":"Record inserted"}
" + html$ = html$ + "

POST /bulkInsert

curl.exe -X POST http://window.location.hostname:8009/bulkInsert -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data-urlencode tableName=UserInfo" + Chr(10) + " --data-urlencode rowsJson=[{"column1":"Alice","column2":"Engineer","column3":"Mississauga"},{"column1":"Bob","column2":"Manager","column3":"LA"}]
{"status":"success","table":"UserInfo","requestedCount":2,"insertedCount":2,"failedCount":0}
rowsJson must be in JSON format
" + html$ = html$ + "

POST /update

curl.exe -X POST http://window.location.hostname:8009/update -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data tableName=UserInfo&rowID=1&column1=AliceUpdated&column2=Lead&column3=LA
{"status":"success","table":"UserInfo","rowID":"1","message":"Record updated"}
" + html$ = html$ + "

POST /delete

curl.exe -X POST http://window.location.hostname:8009/delete -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data tableName=UserInfo&rowID=1
{"status":"success","table":"UserInfo","rowID":"1","message":"Record deleted"}
" + html$ = html$ + "

POST /deleteWhere

curl.exe -X POST http://window.location.hostname:8009/deleteWhere -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data tableName=UserInfo&columnName=column1&value=Alice
{"status":"success","table":"UserInfo","columnName":"column1","deletedCount":1,"message":"Rows deleted"}
" + html$ = html$ + "

POST /createTable

curl.exe -X POST http://window.location.hostname:8009/createTable -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data tableName=UserInfo
This request uses the default columnArray defined in plugin file.
{"status":"success","table":"Orders","message":"Table is ready"}
curl.exe -X POST http://window.location.hostname:8009/createTable -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + " --data-urlencode tableName=Orders" + Chr(10) + " --data-urlencode columnsJson=[{"name":"orderNo"},{"name":"amount"}]
{"status":"success","table":"Orders","message":"Table is ready"}
columnsJson must be a JSON array of {name} with unique valid names.
" + html$ = html$ + "

POST /emptyTable

curl.exe -X POST http://window.location.hostname:8009/emptyTable -H Content-Type:application/x-www-form-urlencoded" + Chr(10) + "--data tableName=UserInfo
{"status":"success","table":"UserInfo","message":"All rows deleted"}
" + html$ = html$ + "

Try POST Endpoint

Input fields: 0

Select endpoint and fill body fields.
" + html$ = html$ + "

UDP Command Help

" + html$ = html$ + "
Insert_<tableName>_<newValue1>_<newValue2>_<newValue3>
UpdateRow_<tableName>_<rowID>_<newValue1>_<newValue2>_<newValue3>
UpdateColumn_<tableName>_<rowID>_<columnName>_<newValue>
Delete_<tableName>_<rowID>
CreateTable_<tableName> (UDP create uses current default schema, no columnsJson in UDP format)
EmptyTable_<tableName>

Send UDP to

Waiting for command...
" + html$ = html$ + "" + html$ = html$ + "" + e.AddResponseHeader("Content-type", "text/html; charset=utf-8") + e.SetResponseBodyString(html$) + e.SendResponse(200) +End Sub + +Sub sql_GetHomePage(userData as Object, e as Object) + + if type(userData) <> "roAssociativeArray" or type(userData.mVar) <> "roAssociativeArray" then + e.AddResponseHeader("Content-type", "text/plain; charset=utf-8") + e.SetResponseBodyString("SQL handler context is invalid") + e.SendResponse(500) + return + end if + + mVar = userData.mVar + mVar.tableNames = sql_GetTableNames(mVar.dbFile) + requestedTable$ = sql_GetRequestedTableName(e) + showTableWarning = false + tableWarningTitle$ = "" + tableWarningMessage$ = "" + if requestedTable$ <> "" and sql_IsValidTableName(requestedTable$) and sql_ArrayContainsStringExact(mVar.tableNames, requestedTable$) then + mVar.defaultTable = requestedTable$ + else if requestedTable$ <> "" then + showTableWarning = true + tableWarningTitle$ = "Table not found" + tableWarningMessage$ = "The table: " + requestedTable$ + " does not exist. Showing the default table instead." + else if sql_ArrayContainsStringExact(mVar.tableNames, "UserInfo") then + mVar.defaultTable = "UserInfo" + else + sql_SyncDefaultTable(mVar) + end if + tableSelectOptions$ = "" + if type(mVar.tableNames) = "roArray" then + for each tableItem in mVar.tableNames + tableItemName$ = sql_TrimString(sql_FormValueToString(tableItem)) + if tableItemName$ <> "" then + selectedAttr$ = "" + if tableItemName$ = mVar.defaultTable then + selectedAttr$ = " selected" + end if + tableSelectOptions$ = tableSelectOptions$ + "" + end if + next + end if + + html$ = "" + html$ = html$ + "" + html$ = html$ + "SQLite" + html$ = html$ + "" + html$ = html$ + "" + html$ = html$ + "" + html$ = html$ + "

SQLite

" + html$ = html$ + "Database file: " + mVar.dbFile + " - Active table: " + mVar.defaultTable + "" + html$ = html$ + "

Open Help Page

" + + if tableSelectOptions$ <> "" then + html$ = html$ + "


" + else + html$ = html$ + "

No tables found.

" + end if + html$ = html$ + "

" + sql_HtmlEscape(tableWarningTitle$) + "

"
+
+	columns = sql_GetInsertableColumnsForTable(mVar, mVar.dbFile, mVar.defaultTable)
+	rows = sql_ReadAllRows(mVar.dbFile, mVar.defaultTable)
+	isSqlEmpty = sql_IsTableEffectivelyEmpty(rows, columns)
+	if isSqlEmpty then
+		html$ = html$ + "
" + mVar.defaultTable + " is empty. Fill up all rows and click UPDATE ALL.
"
+	end if
+	if type(columns) = "roArray" and columns.Count() > 0 and type(rows) = "roArray" and rows.Count() > 0 then
+		html$ = html$ + "
"
+		html$ = html$ + ""
+		html$ = html$ + ""
+		rowIdsCsv$ = ""
+		for each row in rows
+			if type(row) = "roAssociativeArray" then
+				rowIdRaw$ = sql_TrimString(sql_GetRowIdValue(row, mVar.defaultRowID))
+				rowIdDisplay$ = sql_HtmlEscape(rowIdRaw$)
+				if rowIdRaw$ <> "" then
+					if rowIdsCsv$ <> "" then
+						rowIdsCsv$ = rowIdsCsv$ + ","
+					end if
+					rowIdsCsv$ = rowIdsCsv$ + rowIdRaw$
+				end if
+				html$ = html$ + "
"
+				if rowIdDisplay$ <> "" then
+					html$ = html$ + "
" + mVar.defaultRowID + ": " + rowIdDisplay$ + "
"
+				end if
+				for each columnName in columns
+					fieldName$ = "bulk_" + rowIdRaw$ + "_" + columnName
+					cellValue$ = sql_HtmlEscape(sql_GetRowFieldValue(row, columnName))
+					html$ = html$ + ""
+					html$ = html$ + ""
+				next
+				html$ = html$ + "
"
+			end if
+		next
+		html$ = html$ + ""
+		html$ = html$ + "
"
+		html$ = html$ + "
"
+	else if type(columns) = "roArray" and columns.Count() > 0 then
+		html$ = html$ + "
No records in this table " + mVar.defaultTable + ". Insert new records to update.
"
+	else
+		html$ = html$ + "
No columns available for table " + mVar.defaultTable + ".
"
+	end if
+
+	html$ = html$ + "
"
+	html$ = html$ + "
"
+	html$ = html$ + "
"
+	html$ = html$ + "
UPDATE ALL
"
+	html$ = html$ + ""
+	html$ = html$ + "
"
+	html$ = html$ + "
"
+	html$ = html$ + "
"
+	html$ = html$ + "
"
+	html$ = html$ + ""
+
+	html$ = html$ + ""
+	html$ = html$ + ""
+	e.AddResponseHeader("Content-type", "text/html; charset=utf-8")
+	e.SetResponseBodyString(html$)
+	e.SendResponse(200)
+End Sub
+
+
+' ===== Database Read/Write Helpers =====
+Function sql_ReadAllRows(dbFile$ as String, dbTable$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+	results = []
+	if myDB.Open(dbFile$) <> invalid then
+		selectStatement = myDB.CreateStatement("SELECT * FROM " + dbTable$ + ";")
+		if type(selectStatement) = "roSqliteStatement" then
+			sqlResult = selectStatement.Run()
+			SQLITE_ROWS = 102
+			while sqlResult = SQLITE_ROWS
+				results.Push(selectStatement.GetData())
+				sqlResult = selectStatement.Run()
+			end while
+			selectStatement.Finalise()
+		end if
+		myDB.Close()
+	end if
+	return results
+End Function
+
+Function sql_InsertUserData(m as Object, dbFile$ as String, dbTable$ as String, columns as Object, values as Object) as Boolean
+	myDB = CreateObject("roSqliteDatabase")
+	if type(columns) <> "roArray" or type(values) <> "roArray" then
+		return false
+	end if
+
+	if columns.Count() = 0 or columns.Count() <> values.Count() then
+		return false
+	end if
+
+	columnsSql$ = ""
+	placeholders$ = ""
+	for i = 0 to columns.Count() - 1
+		if i > 0 then
+			columnsSql$ = columnsSql$ + ", "
+			placeholders$ = placeholders$ + ", "
+		end if
+		columnsSql$ = columnsSql$ + columns[i]
+		placeholders$ = placeholders$ + "?"
+	next
+
+	if myDB.Open(dbFile$) <> invalid then
+		sql$ = "INSERT INTO " + dbTable$ + " (" + columnsSql$ + ") VALUES (" + placeholders$ + ");"
+		insertStatement = myDB.CreateStatement(sql$)
+		success = sql_RunWriteStatement(insertStatement, values, m, "------------------ SQL bind error (insert)", "------------------ SQL insert error: ")
+		myDB.Close()
+		return success
+	end if
+
+	return false
+End Function
+
+Sub sql_UpdateRecordRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	rowID$ = sql_GetFormValue(args, mVar.defaultRowID, "")
+	updateAll$ = LCase(sql_TrimString(sql_GetFormValue(args, "updateAll", "")))
+	isUpdateAll = updateAll$ = "1" or updateAll$ = "true" or updateAll$ = "yes"
+	allColumns = sql_GetInsertableColumnsForTable(mVar, mVar.dbFile, tableName$)
+	columns = []
+	values = []
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not isUpdateAll then
+		if rowID$ = "" then
+			sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowID is required" })
+			return
+		end if
+
+		rowIdNum = sql_ParsePositiveIntStrict(rowID$)
+		if rowIdNum <= 0 then
+			sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowID must be a positive integer" })
+			return
+		end if
+	end if
+
+	if type(allColumns) <> "roArray" or allColumns.Count() = 0 then
+		sql_SendJsonResponse(e, 400, { status: "error", message: "No updatable columns in table schema" })
+		return
+	end if
+
+	ok = false
+	if isUpdateAll then
+		ok = sql_UpdateAllRowsFromForm(mVar, mVar.dbFile, tableName$, allColumns, args)
+	else
+		for each columnName in allColumns
+			if type(args) = "roAssociativeArray" and args.DoesExist(columnName) and args[columnName] <> invalid then
+				columns.Push(columnName)
+				values.Push(sql_GetFormValue(args, columnName, ""))
+			end if
+		next
+
+		if columns.Count() = 0 then
+			sql_SendJsonResponse(e, 400, { status: "error", message: "Provide at least one field to update" })
+			return
+		end if
+
+		ok = sql_UpdateRecord(mVar, mVar.dbFile, tableName$, rowIdNum, columns, values)
+	end if
+
+	respBody = {
+		status: "error"
+		dbFile: mVar.dbFile
+		table: tableName$
+		rowID: rowID$
+	}
+	if ok then
+		mVar.defaultTable = tableName$
+		respBody.status = "success"
+		if isUpdateAll then
+			respBody.message = "All records updated"
+		else
+			respBody.message = "Record updated"
+		end if
+		sql_SendJsonResponse(e, 200, respBody)
+	else
+		if isUpdateAll then
+			respBody.message = "Update all failed"
+			sql_SendJsonResponse(e, 500, respBody)
+		else
+			respBody.message = "Update failed"
+			sql_SendJsonResponse(e, 404, respBody)
+		end if
+	end if
+End Sub
+
+Function sql_UpdateAllRowsFromForm(m as Object, dbFile$ as String, dbTable$ as String, allColumns as Object, args as Object) as Boolean
+	if type(allColumns) <> "roArray" or allColumns.Count() = 0 then
+		return false
+	end if
+
+	rowIdsCsv$ = sql_TrimString(sql_GetFormValue(args, "rowIds", ""))
+	if rowIdsCsv$ = "" then
+		return false
+	end if
+
+	rowIds = sql_SplitByDelimiter(rowIdsCsv$, ",")
+	updatedCount = 0
+
+	for each rowIdEntry in rowIds
+		rowIdText$ = sql_TrimString(rowIdEntry)
+		if rowIdText$ <> "" then
+			rowIdNum = sql_ParsePositiveIntStrict(rowIdText$)
+			if rowIdNum > 0 then
+				existingRow = sql_ReadRowById(dbFile$, dbTable$, rowIdNum, sql_GetDefaultRowIdColumnName(m))
+				if type(existingRow) <> "roAssociativeArray" then
+					existingRow = {}
+				end if
+
+				rowValues = []
+				for each columnName in allColumns
+					fieldName$ = "bulk_" + rowIdText$ + "_" + columnName
+					if type(args) = "roAssociativeArray" and args.DoesExist(fieldName$) and args[fieldName$] <> invalid then
+						rowValues.Push(sql_GetFormValue(args, fieldName$, ""))
+					else
+						rowValues.Push(sql_GetRowFieldValue(existingRow, columnName))
+					end if
+				next
+
+				if sql_UpdateRecord(m, dbFile$, dbTable$, rowIdNum, allColumns, rowValues) then
+					updatedCount = updatedCount + 1
+				end if
+			end if
+		end if
+	next
+
+	return updatedCount > 0
+End Function
+
+Function sql_GetRequestedTableName(e as Object) as String
+	if e = invalid then
+		return ""
+	end if
+	args = e.GetFormData()
+	requestedTable$ = sql_GetRequestValue(e, args, "tableName", "")
+	if requestedTable$ = "" then
+		requestedTable$ = sql_GetRequestValue(e, args, "tablaName", "")
+	end if
+	return requestedTable$
+End Function
+
+Function sql_ArrayContainsStringExact(values as Object, target$ as String) as Boolean
+	if type(values) <> "roArray" then
+		return false
+	end if
+
+	if target$ = invalid or target$ = "" then
+		return false
+	end if
+
+	for each item in values
+		if type(item) = "roString" and item = target$ then
+			return true
+		end if
+	next
+
+	return false
+End Function
+
+Function sql_SplitByDelimiter(text$ as String, delimiter$ as String) as Object
+	parts = []
+	if text$ = invalid then
+		return parts
+	end if
+
+	if delimiter$ = invalid or delimiter$ = "" then
+		parts.Push(text$)
+		return parts
+	end if
+
+	current$ = ""
+	delLen = Len(delimiter$)
+	i = 1
+	while i <= Len(text$)
+		if Mid(text$, i, delLen) = delimiter$ then
+			parts.Push(current$)
+			current$ = ""
+			i = i + delLen
+		else
+			current$ = current$ + Mid(text$, i, 1)
+			i = i + 1
+		end if
+	end while
+
+	parts.Push(current$)
+	return parts
+End Function
+
+Function sql_BuildValuesFromParts(parts as Object, startIndex as Integer, expectedCount as Integer) as Object
+	values = []
+	if type(parts) <> "roArray" or expectedCount <= 0 then
+		return values
+	end if
+
+	for i = 0 to expectedCount - 1
+		partIndex = startIndex + i
+		if partIndex >= 0 and partIndex < parts.Count() and parts[partIndex] <> invalid then
+			values.Push(sql_FormValueToString(parts[partIndex]))
+		else
+			values.Push("")
+		end if
+	next
+
+	return values
+End Function
+
+Function sql_JoinPartsWithUnderscore(parts as Object, startIndex as Integer) as String
+	if type(parts) <> "roArray" or startIndex < 0 or startIndex >= parts.Count() then
+		return ""
+	end if
+
+	joined$ = ""
+	for i = startIndex to parts.Count() - 1
+		if i > startIndex then
+			joined$ = joined$ + "_"
+		end if
+		joined$ = joined$ + sql_FormValueToString(parts[i])
+	next
+
+	return joined$
+End Function
+
+' ===== REST Read Handlers =====
+Sub sql_PostReadRecordsRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetRequestValue(e, args, "tableName", mVar.defaultTable)
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+	mVar.defaultTable = tableName$
+	sql_SendReadResponse(mVar, tableName$, e)
+End Sub
+
+Sub sql_GetReadRowRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetRequestValue(e, args, "tableName", mVar.defaultTable)
+	rowID$ = sql_GetRequestValue(e, args, mVar.defaultRowID, "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if rowID$ = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: mVar.defaultRowID + " is required" })
+		return
+	end if
+
+	rowIdNum = sql_ParsePositiveIntStrict(rowID$)
+	if rowIdNum <= 0 then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: mVar.defaultRowID + " must be a positive integer" })
+		return
+	end if
+
+	row = sql_ReadRowById(mVar.dbFile, tableName$, rowIdNum, mVar.defaultRowID)
+	if type(row) <> "roAssociativeArray" then
+		sql_SendJsonResponse(e, 404, {
+			status: "error"
+			dbFile: mVar.dbFile
+			table: tableName$
+			rowID: rowID$
+			message: "Row not found"
+		})
+		return
+	end if
+
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		row: row
+	})
+End Sub
+
+Sub sql_GetReadColumnRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetRequestValue(e, args, "tableName", mVar.defaultTable)
+	columnName$ = sql_GetRequestValue(e, args, "columnName", "")
+	countOnlyRaw$ = LCase(sql_TrimString(sql_GetRequestValue(e, args, "countOnly", "")))
+	isCountOnly = countOnlyRaw$ = "1" or countOnlyRaw$ = "true" or countOnlyRaw$ = "yes"
+	rowID$ = sql_GetRequestValue(e, args, mVar.defaultRowID, "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not sql_IsValidTableName(columnName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid columnName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not sql_ColumnExists(mVar.dbFile, tableName$, columnName$) then
+		sql_SendJsonResponse(e, 404, {
+			status: "error"
+			dbFile: mVar.dbFile
+			table: tableName$
+			column: columnName$
+			message: "Column not found"
+		})
+		return
+	end if
+
+	if isCountOnly then
+		count = sql_CountNonEmptyColumnValues(mVar.dbFile, tableName$, columnName$)
+		if count < 0 then
+			sql_SendJsonResponse(e, 500, {
+				status: "error"
+				dbFile: mVar.dbFile
+				table: tableName$
+				column: columnName$
+				message: "Count failed"
+			})
+			return
+		end if
+
+		mVar.defaultTable = tableName$
+		sql_SendJsonResponse(e, 200, {
+			status: "success"
+			dbFile: mVar.dbFile
+			table: tableName$
+			column: columnName$
+			count: count
+		})
+		return
+	end if
+
+	if rowID$ <> "" then
+		rowIdNum = sql_ParsePositiveIntStrict(rowID$)
+		if rowIdNum <= 0 then
+			sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: mVar.defaultRowID + " must be a positive integer" })
+			return
+		end if
+
+		value = sql_ReadColumnValueByRowId(mVar.dbFile, tableName$, columnName$, rowIdNum, mVar.defaultRowID)
+		if value = invalid then
+			sql_SendJsonResponse(e, 404, {
+				status: "error"
+				dbFile: mVar.dbFile
+				table: tableName$
+				column: columnName$
+				rowID: rowID$
+				message: "Row not found"
+			})
+			return
+		end if
+
+		mVar.defaultTable = tableName$
+		sql_SendJsonResponse(e, 200, {
+			status: "success"
+			dbFile: mVar.dbFile
+			table: tableName$
+			column: columnName$
+			rowID: rowID$
+			value: sql_FormValueToString(value)
+		})
+		return
+	end if
+
+	values = sql_ReadColumnValues(mVar.dbFile, tableName$, columnName$)
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		column: columnName$
+		values: values
+	})
+End Sub
+
+Sub sql_GetSearchRowsRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetRequestValue(e, args, "tableName", mVar.defaultTable)
+	columnName$ = sql_GetRequestValue(e, args, "columnName", "")
+	value$ = sql_GetRequestValue(e, args, "value", "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not sql_IsValidTableName(columnName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid columnName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not sql_ColumnExists(mVar.dbFile, tableName$, columnName$) then
+		sql_SendJsonResponse(e, 404, {
+			status: "error"
+			dbFile: mVar.dbFile
+			table: tableName$
+			column: columnName$
+			message: "Column not found"
+		})
+		return
+	end if
+
+	rows = sql_ReadRowsByColumnExact(mVar.dbFile, tableName$, columnName$, value$)
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		column: columnName$
+		value: value$
+		count: rows.Count()
+		rows: rows
+	})
+End Sub
+
+Sub sql_GetTablesRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	tableNames = sql_GetTableNames(mVar.dbFile)
+	if type(tableNames) <> "roArray" then
+		tableNames = []
+	end if
+
+	mVar.tableNames = tableNames
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		count: tableNames.Count()
+		tables: tableNames
+	})
+End Sub
+
+Sub sql_GetSchemaRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	tableNames = sql_GetTableNames(mVar.dbFile)
+	if type(tableNames) <> "roArray" then
+		tableNames = []
+	end if
+
+	rowIdColumn$ = LCase(sql_GetDefaultRowIdColumnName(mVar))
+
+	schema = []
+	for each tableName in tableNames
+		tableColumnsMeta = sql_GetTableColumnArray(mVar.dbFile, tableName)
+		columnNames = []
+		if type(tableColumnsMeta) = "roArray" then
+			for each colMeta in tableColumnsMeta
+				if type(colMeta) = "roAssociativeArray" and colMeta.DoesExist("name") and colMeta.name <> invalid then
+					columnName$ = sql_TrimString(sql_FormValueToString(colMeta.name))
+					if LCase(columnName$) <> rowIdColumn$ then
+						columnNames.Push(columnName$)
+					end if
+				end if
+			next
+		end if
+
+		columnCount = columnNames.Count()
+		schema.Push({ table: tableName, columnCount: columnCount, columns: columnNames })
+	next
+
+	mVar.tableNames = tableNames
+	schemaJson$ = "["
+	for i = 0 to schema.Count() - 1
+		if i > 0 then
+			schemaJson$ = schemaJson$ + ","
+		end if
+
+		tableObj = schema[i]
+		tableNameOut$ = ""
+		columnCountOut = 0
+		columnsOut = []
+		if type(tableObj) = "roAssociativeArray" then
+			if tableObj.DoesExist("table") and tableObj.table <> invalid then
+				tableNameOut$ = sql_FormValueToString(tableObj.table)
+			end if
+			if tableObj.DoesExist("columnCount") and tableObj.columnCount <> invalid then
+				columnCountOut = int(val(sql_FormValueToString(tableObj.columnCount)))
+			end if
+			if tableObj.DoesExist("columns") and type(tableObj.columns) = "roArray" then
+				columnsOut = tableObj.columns
+			end if
+		end if
+
+		columnsJson$ = "["
+		for j = 0 to columnsOut.Count() - 1
+			if j > 0 then
+				columnsJson$ = columnsJson$ + ","
+			end if
+			columnsJson$ = columnsJson$ + Chr(34) + sql_FormValueToString(columnsOut[j]) + Chr(34)
+		next
+		columnsJson$ = columnsJson$ + "]"
+
+		schemaJson$ = schemaJson$ + "{" + Chr(34) + "table" + Chr(34) + ":" + Chr(34) + tableNameOut$ + Chr(34) + "," + Chr(34) + "columnCount" + Chr(34) + ":" + columnCountOut.ToStr() + "," + Chr(34) + "columns" + Chr(34) + ":" + columnsJson$ + "}"
+	next
+	schemaJson$ = schemaJson$ + "]"
+
+	body$ = "{" + Chr(34) + "status" + Chr(34) + ":" + Chr(34) + "success" + Chr(34) + "," + Chr(34) + "dbFile" + Chr(34) + ":" + Chr(34) + mVar.dbFile + Chr(34) + "," + Chr(34) + "countTable" + Chr(34) + ":" + tableNames.Count().ToStr() + "," + Chr(34) + "schema" + Chr(34) + ":" + schemaJson$ + "}"
+	e.AddResponseHeader("Content-type", "application/json")
+	e.SetResponseBodyString(body$)
+	e.SendResponse(200)
+End Sub
+
+Function sql_ReadRowById(dbFile$ as String, dbTable$ as String, rowID as Integer, rowIdColumn$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+	if rowID <= 0 then
+		return invalid
+	end if
+
+	if not sql_IsValidTableName(rowIdColumn$) then
+		rowIdColumn$ = "rowID"
+	end if
+
+	if myDB.Open(dbFile$) = invalid then
+		return invalid
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT * FROM " + dbTable$ + " WHERE " + rowIdColumn$ + " = ? LIMIT 1;")
+	if type(selectStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return invalid
+	end if
+
+	params = [rowID]
+	if not selectStatement.BindByOffset(params) then
+		selectStatement.Finalise()
+		myDB.Close()
+		return invalid
+	end if
+
+	result = selectStatement.Run()
+	if result = 102 then
+		row = selectStatement.GetData()
+	else
+		row = invalid
+	end if
+
+	selectStatement.Finalise()
+	myDB.Close()
+	return row
+End Function
+
+Function sql_ReadColumnValues(dbFile$ as String, dbTable$ as String, columnName$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+	values = []
+
+	if myDB.Open(dbFile$) = invalid then
+		return values
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT " + columnName$ + " FROM " + dbTable$ + ";")
+	if type(selectStatement) = "roSqliteStatement" then
+		sqlResult = selectStatement.Run()
+		while sqlResult = 102
+			row = selectStatement.GetData()
+			if type(row) = "roAssociativeArray" and row.DoesExist(columnName$) then
+				values.Push(sql_FormValueToString(row[columnName$]))
+			else if type(row) = "roAssociativeArray" then
+				values.Push(sql_GetRowFieldValue(row, columnName$))
+			else
+				values.Push("")
+			end if
+			sqlResult = selectStatement.Run()
+		end while
+		selectStatement.Finalise()
+	end if
+
+	myDB.Close()
+	return values
+End Function
+
+Function sql_ReadRowsByColumnExact(dbFile$ as String, dbTable$ as String, columnName$ as String, value$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+	rows = []
+
+	if myDB.Open(dbFile$) = invalid then
+		return rows
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT * FROM " + dbTable$ + " WHERE " + columnName$ + " = ?;")
+	if type(selectStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return rows
+	end if
+
+	params = [value$]
+	if not selectStatement.BindByOffset(params) then
+		selectStatement.Finalise()
+		myDB.Close()
+		return rows
+	end if
+
+	sqlResult = selectStatement.Run()
+	while sqlResult = 102
+		rows.Push(selectStatement.GetData())
+		sqlResult = selectStatement.Run()
+	end while
+
+	selectStatement.Finalise()
+	myDB.Close()
+	return rows
+End Function
+
+Function sql_ReadColumnValueByRowId(dbFile$ as String, dbTable$ as String, columnName$ as String, rowID as Integer, rowIdColumn$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+
+	if rowID <= 0 then
+		return invalid
+	end if
+
+	if not sql_IsValidTableName(rowIdColumn$) then
+		rowIdColumn$ = "rowID"
+	end if
+
+	if myDB.Open(dbFile$) = invalid then
+		return invalid
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT " + columnName$ + " FROM " + dbTable$ + " WHERE " + rowIdColumn$ + " = ? LIMIT 1;")
+	if type(selectStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return invalid
+	end if
+
+	params = [rowID]
+	if not selectStatement.BindByOffset(params) then
+		selectStatement.Finalise()
+		myDB.Close()
+		return invalid
+	end if
+
+	result = selectStatement.Run()
+	if result = 102 then
+		row = selectStatement.GetData()
+		if type(row) = "roAssociativeArray" and row.DoesExist(columnName$) then
+			value = row[columnName$]
+		else if type(row) = "roAssociativeArray" then
+			value = sql_GetRowFieldValue(row, columnName$)
+		else
+			value = invalid
+		end if
+	else
+		value = invalid
+	end if
+
+	selectStatement.Finalise()
+	myDB.Close()
+	return value
+End Function
+
+Function sql_ColumnExists(dbFile$ as String, dbTable$ as String, columnName$ as String) as Boolean
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return false
+	end if
+
+	selectStatement = myDB.CreateStatement("PRAGMA table_info(" + dbTable$ + ");")
+	if type(selectStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return false
+	end if
+
+	found = false
+	sqlResult = selectStatement.Run()
+	while sqlResult = 102
+		row = selectStatement.GetData()
+		if type(row) = "roAssociativeArray" then
+			name$ = sql_TrimString(sql_GetRowFieldValue(row, "name"))
+			if LCase(name$) = LCase(columnName$) then
+				found = true
+				exit while
+			end if
+		end if
+		sqlResult = selectStatement.Run()
+	end while
+
+	selectStatement.Finalise()
+	myDB.Close()
+	return found
+End Function
+
+Function sql_GetRequestValue(e as Object, args as Object, fieldName$ as String, defaultValue$ as String) as String
+	if e <> invalid then
+		queryValue$ = sql_TrimString(e.GetRequestParam(fieldName$))
+		if queryValue$ <> "" then
+			return queryValue$
+		end if
+	end if
+
+	return sql_GetFormValue(args, fieldName$, defaultValue$)
+End Function
+
+Function sql_IsValidCreateColumnArray(columnArray as Object, requiredRowId$ as String) as Boolean
+	validation = sql_ValidateCreateColumnArray(columnArray, requiredRowId$)
+	if type(validation) = "roAssociativeArray" and validation.DoesExist("ok") and validation.ok = true then
+		return true
+	end if
+
+	return false
+End Function
+
+Function sql_ValidateCreateColumnArray(columnArray as Object, requiredRowId$ as String) as Object
+	result = {
+		ok: false
+		reason: ""
+	}
+
+	if type(columnArray) <> "roArray" or columnArray.Count() = 0 then
+		result.reason = "columnArray must be a non-empty array"
+		return result
+	end if
+
+	if requiredRowId$ = invalid or requiredRowId$ = "" then
+		requiredRowId$ = "rowID"
+	end if
+
+	seenNames = {}
+	for each col in columnArray
+		if type(col) <> "roAssociativeArray" then
+			result.reason = "each column must be an associative array"
+			return result
+		end if
+
+		nameValue = sql_GetAssocValueIgnoreCase(col, "name")
+
+		if nameValue = invalid then
+			result.reason = "each column must include name"
+			return result
+		end if
+
+		colName$ = sql_TrimString(sql_FormValueToString(nameValue))
+		if colName$ = "" then
+			result.reason = "column name cannot be empty"
+			return result
+		end if
+
+		if not sql_IsValidTableName(colName$) then
+			result.reason = "invalid column name: " + colName$
+			return result
+		end if
+
+		nameKey$ = LCase(colName$)
+		if seenNames.DoesExist(nameKey$) then
+			result.reason = "duplicate column name: " + colName$
+			return result
+		end if
+		seenNames[nameKey$] = true
+
+	next
+
+	result.ok = true
+	result.reason = "ok"
+	return result
+End Function
+
+Function sql_NormalizeCreateColumnArray(columnArray as Object, requiredRowId$ as String) as Object
+	if requiredRowId$ = invalid or requiredRowId$ = "" then
+		requiredRowId$ = "rowID"
+	end if
+
+	if not sql_IsValidCreateColumnArray(columnArray, requiredRowId$) then
+		return invalid
+	end if
+
+	normalized = [{ name: requiredRowId$, type: "INTEGER PRIMARY KEY AUTOINCREMENT" }]
+	for each col in columnArray
+		nameValue = sql_GetAssocValueIgnoreCase(col, "name")
+		colName$ = sql_TrimString(sql_FormValueToString(nameValue))
+		if LCase(colName$) <> LCase(requiredRowId$) then
+			normalized.Push({ name: colName$, type: "TEXT" })
+		end if
+	next
+
+	return normalized
+End Function
+
+Function sql_GetAssocValueIgnoreCase(item as Object, keyName$ as String) as Object
+	if type(item) <> "roAssociativeArray" then
+		return invalid
+	end if
+
+	if item.DoesExist(keyName$) then
+		return item[keyName$]
+	end if
+
+	target$ = LCase(sql_TrimString(keyName$))
+	for each k in item
+		if type(k) = "roString" and LCase(k) = target$ then
+			return item[k]
+		end if
+	next
+
+	return invalid
+End Function
+
+Function sql_GetCreateTableColumns(args as Object, defaultColumns as Object, requiredRowId$ as String) as Object
+	normalizedDefault = sql_NormalizeCreateColumnArray(defaultColumns, requiredRowId$)
+	if type(normalizedDefault) <> "roArray" then
+		normalizedDefault = defaultColumns
+	end if
+
+	rawColumns = invalid
+	if type(args) = "roAssociativeArray" and args.DoesExist("columnsJson") then
+		rawColumns = args["columnsJson"]
+	end if
+
+	if rawColumns = invalid then
+		return normalizedDefault
+	end if
+
+	columnsJson$ = ""
+	if type(rawColumns) = "roArray" then
+		if rawColumns.Count() = 0 then
+			return normalizedDefault
+		end if
+
+		if type(rawColumns[0]) = "roAssociativeArray" then
+			if sql_IsValidCreateColumnArray(rawColumns, requiredRowId$) then
+				return sql_NormalizeCreateColumnArray(rawColumns, requiredRowId$)
+			else
+				return invalid
+			end if
+		end if
+
+		columnsJson$ = sql_TrimString(sql_FormValueToString(rawColumns[0]))
+	else
+		columnsJson$ = sql_TrimString(sql_FormValueToString(rawColumns))
+	end if
+
+	if columnsJson$ = "" then
+		return normalizedDefault
+	end if
+
+	parsedColumns = sql_ParseCreateColumnsJson(columnsJson$)
+	if not sql_IsValidCreateColumnArray(parsedColumns, requiredRowId$) then
+		return invalid
+	end if
+
+	return sql_NormalizeCreateColumnArray(parsedColumns, requiredRowId$)
+End Function
+
+Function sql_ParseCreateColumnsJson(columnsJson$ as String) as Object
+	text$ = sql_TrimString(columnsJson$)
+	if text$ = "" then
+		return invalid
+	end if
+
+	parsed = ParseJson(text$)
+	if type(parsed) = "roArray" then
+		return parsed
+	end if
+
+	text$ = sql_ReplaceAll(text$, """, Chr(34))
+	text$ = sql_ReplaceAll(text$, """, Chr(34))
+	parsed = ParseJson(text$)
+	if type(parsed) = "roArray" then
+		return parsed
+	end if
+
+	text$ = sql_ReplaceAll(text$, Chr(92) + Chr(34), Chr(34))
+	parsed = ParseJson(text$)
+	if type(parsed) = "roArray" then
+		return parsed
+	end if
+
+	if Len(text$) >= 2 and Left(text$, 1) = "'" and Right(text$, 1) = "'" then
+		text$ = Mid(text$, 2, Len(text$) - 2)
+		parsed = ParseJson(text$)
+		if type(parsed) = "roArray" then
+			return parsed
+		end if
+	end if
+
+	return invalid
+End Function
+
+Function sql_ReplaceAll(text$ as String, find$ as String, replacement$ as String) as String
+	if text$ = invalid then
+		return ""
+	end if
+
+	if find$ = invalid or find$ = "" then
+		return text$
+	end if
+
+	parts = sql_SplitByDelimiter(text$, find$)
+	if type(parts) <> "roArray" or parts.Count() = 0 then
+		return text$
+	end if
+
+	result$ = ""
+	for i = 0 to parts.Count() - 1
+		if i > 0 then
+			result$ = result$ + replacement$
+		end if
+		result$ = result$ + parts[i]
+	next
+
+	return result$
+End Function
+
+' ===== REST Write Handlers =====
+Sub sql_CreateTableRest(userData as Object, e as Object)
+
+	mVar = userData.mVar
+	args = e.GetFormData()
+
+	tableName$ = sql_GetFormValue(args, "tableName", "")
+	if tableName$ = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "tableName is required" })
+		return
+	end if
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+	columnsForCreate = sql_GetCreateTableColumns(args, mVar.columnArray, mVar.defaultRowID)
+	if columnsForCreate = invalid then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid columnsJson. It must be a JSON array of {name} with unique valid names." })
+		return
+	end if
+
+	createTableSQL$ = sql_BuildCreateTableSQL(tableName$, columnsForCreate)
+	if createTableSQL$ = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid columnArray schema. Check column names." })
+		return
+	end if
+	ok = sql_CreateAndInitializeCustomDB(mVar, mVar.dbFile, createTableSQL$)
+	respBody = {
+		status: "error"
+		dbFile: mVar.dbFile
+		table: tableName$
+	}
+	if ok then
+		mVar.tableNames = sql_GetTableNames(mVar.dbFile)
+		mVar.columnArray = columnsForCreate
+		respBody.status = "success"
+		respBody.message = "Table is ready"
+		sql_SendJsonResponse(e, 200, respBody)
+	else
+		respBody.message = "Unable to create table"
+		sql_SendJsonResponse(e, 500, respBody)
+	end if
+End Sub
+
+Sub sql_InsertRecordRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	columns = sql_GetInsertableColumnsForTable(mVar, mVar.dbFile, tableName$)
+	values = []
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if type(columns) <> "roArray" or columns.Count() = 0 then
+		sql_SendJsonResponse(e, 400, { status: "error", message: "No insertable columns in table schema" })
+		return
+	end if
+
+	for each columnName in columns
+		value$ = sql_GetFormValue(args, columnName, "")
+		values.Push(value$)
+	next
+
+	ok = sql_InsertUserData(mVar, mVar.dbFile, tableName$, columns, values)
+	respBody = {
+		status: "error"
+		dbFile: mVar.dbFile
+		table: tableName$
+	}
+	if ok then
+		mVar.defaultTable = tableName$
+		respBody.status = "success"
+		respBody.message = "Record inserted"
+		sql_SendJsonResponse(e, 200, respBody)
+	else
+		respBody.message = "Insert failed"
+		sql_SendJsonResponse(e, 500, respBody)
+	end if
+End Sub
+
+Sub sql_DeleteRecordRest(userData as Object, e as Object)
+
+	mVar = userData.mVar
+	args = e.GetFormData()
+
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	rowID$ = sql_GetFormValue(args, mVar.defaultRowID, "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if rowID$ = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowID is required" })
+		return
+	end if
+
+	rowIdNum = sql_ParsePositiveIntStrict(rowID$)
+	if rowIdNum <= 0 then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowID must be a positive integer" })
+		return
+	end if
+
+	ok = sql_DeleteRecord(mVar, mVar.dbFile, tableName$, rowIdNum)
+	respBody = {
+		status: "error"
+		dbFile: mVar.dbFile
+		table: tableName$
+		rowID: rowID$
+	}
+	if ok then
+		mVar.defaultTable = tableName$
+		respBody.status = "success"
+		respBody.message = "Record deleted"
+		sql_SendJsonResponse(e, 200, respBody)
+	else
+		respBody.message = "Delete failed"
+		sql_SendJsonResponse(e, 404, respBody)
+	end if
+End Sub
+
+Sub sql_DeleteTableRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	ok = sql_DeleteTableRows(mVar, mVar.dbFile, tableName$)
+	respBody = {
+		status: "error"
+		dbFile: mVar.dbFile
+		table: tableName$
+	}
+
+	if ok then
+		mVar.defaultTable = tableName$
+		respBody.status = "success"
+		respBody.message = "All rows deleted"
+		sql_SendJsonResponse(e, 200, respBody)
+	else
+		respBody.message = "Delete all rows failed"
+		sql_SendJsonResponse(e, 500, respBody)
+	end if
+End Sub
+
+Sub sql_DeleteWhereRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	columnName$ = sql_GetFormValue(args, "columnName", "")
+	value$ = sql_GetFormValue(args, "value", "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if not sql_IsValidTableName(columnName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid columnName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if LCase(columnName$) = LCase(sql_GetDefaultRowIdColumnName(mVar)) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Deleting by rowID is not supported in /deleteWhere. Use /delete." })
+		return
+	end if
+
+	if not sql_ColumnExists(mVar.dbFile, tableName$, columnName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "columnName does not exist in table" })
+		return
+	end if
+
+	if sql_TrimString(value$) = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "value is required and cannot be empty" })
+		return
+	end if
+
+	deletedCount = sql_DeleteWhere(mVar, mVar.dbFile, tableName$, columnName$, value$)
+	if deletedCount < 0 then
+		sql_SendJsonResponse(e, 500, {
+			status: "error"
+			dbFile: mVar.dbFile
+			table: tableName$
+			columnName: columnName$
+			message: "Delete where failed"
+		})
+		return
+	end if
+
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		columnName: columnName$
+		value: value$
+		deletedCount: deletedCount
+		message: "Rows deleted"
+	})
+End Sub
+
+Sub sql_GetCountRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+	requestedTable$ = sql_GetRequestValue(e, args, "tableName", mVar.defaultTable)
+	if sql_IsValidTableName(requestedTable$) then
+		tableName$ = requestedTable$
+	else
+		tableName$ = mVar.defaultTable
+	end if
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid default table name" })
+		return
+	end if
+
+	count = sql_CountRows(mVar.dbFile, tableName$)
+	if count < 0 then
+		sql_SendJsonResponse(e, 500, {
+			status: "error"
+			dbFile: mVar.dbFile
+			table: tableName$
+			message: "Count failed"
+		})
+		return
+	end if
+
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		count: count
+	})
+End Sub
+
+Sub sql_BulkInsertRest(userData as Object, e as Object)
+	mVar = userData.mVar
+	args = e.GetFormData()
+
+	tableName$ = sql_GetFormValue(args, "tableName", mVar.defaultTable)
+	rowsJson$ = sql_GetFormValue(args, "rowsJson", "")
+
+	if not sql_IsValidTableName(tableName$) then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "Invalid tableName. Use letters, numbers or underscore, and do not start with a number." })
+		return
+	end if
+
+	if rowsJson$ = "" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowsJson is required" })
+		return
+	end if
+
+	rows = ParseJson(rowsJson$)
+	if type(rows) <> "roArray" then
+		sql_SendJsonResponse(e, 400, { status: "error", dbFile: mVar.dbFile, message: "rowsJson must be a JSON array" })
+		return
+	end if
+
+	columns = sql_GetInsertableColumnsForTable(mVar, mVar.dbFile, tableName$)
+	if type(columns) <> "roArray" or columns.Count() = 0 then
+		sql_SendJsonResponse(e, 400, { status: "error", message: "No insertable columns in table schema" })
+		return
+	end if
+
+	insertedCount = 0
+	failedCount = 0
+
+	for each row in rows
+		if type(row) <> "roAssociativeArray" then
+			failedCount = failedCount + 1
+		else
+			values = []
+			for each columnName in columns
+				cellValue$ = ""
+				if row.DoesExist(columnName) and row[columnName] <> invalid then
+					cellValue$ = sql_FormValueToString(row[columnName])
+				end if
+				values.Push(cellValue$)
+			next
+
+			if sql_InsertUserData(mVar, mVar.dbFile, tableName$, columns, values) then
+				insertedCount = insertedCount + 1
+			else
+				failedCount = failedCount + 1
+			end if
+		end if
+	next
+
+	mVar.defaultTable = tableName$
+	sql_SendJsonResponse(e, 200, {
+		status: "success"
+		dbFile: mVar.dbFile
+		table: tableName$
+		requestedCount: rows.Count()
+		insertedCount: insertedCount
+		failedCount: failedCount
+	})
+End Sub
+
+
+' ===== Database Mutation and Counting =====
+Function sql_DeleteRecord(m as Object, dbFile$ as String, dbTable$ as String, rowID as Integer) as Boolean
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return false
+	end if
+
+	rowIdColumn$ = sql_GetDefaultRowIdColumnName(m)
+
+	if not sql_RowExistsById(myDB, dbTable$, rowID, rowIdColumn$) then
+		m.SystemLog.SendLine("------------------ Delete failed: rowID " + rowID.ToStr() + " does not exist.")
+		myDB.Close()
+		return false
+	end if
+
+	params = [rowID]
+	deleteStatement = myDB.CreateStatement("DELETE FROM " + dbTable$ + " WHERE " + rowIdColumn$ + " = ?;")
+	success = sql_RunWriteStatement(deleteStatement, params, m, "------------------ SQL bind error (delete)", "------------------ SQL delete error: ")
+
+	if success then
+		success = sql_SyncAutoincrementSequence(m, myDB, dbTable$, rowIdColumn$)
+	end if
+
+	myDB.Close()
+	return success
+End Function
+
+Function sql_DeleteWhere(m as Object, dbFile$ as String, dbTable$ as String, columnName$ as String, value$ as String) as Integer
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return -1
+	end if
+
+	countBefore = sql_CountRowsInOpenDb(myDB, dbTable$)
+	if countBefore < 0 then
+		myDB.Close()
+		return -1
+	end if
+
+	deleteStatement = myDB.CreateStatement("DELETE FROM " + dbTable$ + " WHERE " + columnName$ + " = ?;")
+	success = sql_RunWriteStatement(deleteStatement, [value$], m, "------------------ SQL bind error (deleteWhere)", "------------------ SQL deleteWhere error: ")
+	if not success then
+		myDB.Close()
+		return -1
+	end if
+
+	rowIdColumn$ = sql_GetDefaultRowIdColumnName(m)
+	if not sql_SyncAutoincrementSequence(m, myDB, dbTable$, rowIdColumn$) then
+		myDB.Close()
+		return -1
+	end if
+
+	countAfter = sql_CountRowsInOpenDb(myDB, dbTable$)
+	myDB.Close()
+	if countAfter < 0 then
+		return -1
+	end if
+
+	deletedCount = countBefore - countAfter
+	if deletedCount < 0 then
+		deletedCount = 0
+	end if
+
+	return deletedCount
+End Function
+
+Function sql_CountRows(dbFile$ as String, dbTable$ as String) as Integer
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return -1
+	end if
+
+	count = sql_CountRowsInOpenDb(myDB, dbTable$)
+	myDB.Close()
+	return count
+End Function
+
+Function sql_CountRowsInOpenDb(myDB as Object, dbTable$ as String) as Integer
+	if type(myDB) <> "roSqliteDatabase" then
+		return -1
+	end if
+
+	countStatement = myDB.CreateStatement("SELECT COUNT(*) AS rowCount FROM " + dbTable$ + ";")
+	if type(countStatement) <> "roSqliteStatement" then
+		return -1
+	end if
+
+	countValue = -1
+	result = countStatement.Run()
+	if result = 102 then
+		row = countStatement.GetData()
+		if type(row) = "roAssociativeArray" then
+			countValue = int(val(sql_FormValueToString(sql_GetRowFieldValue(row, "rowCount"))))
+			if countValue < 0 then
+				countValue = 0
+			end if
+		end if
+	end if
+
+	countStatement.Finalise()
+	return countValue
+End Function
+
+Function sql_CountNonEmptyColumnValues(dbFile$ as String, dbTable$ as String, columnName$ as String) as Integer
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return -1
+	end if
+
+	countStatement = myDB.CreateStatement("SELECT COUNT(*) AS valueCount FROM " + dbTable$ + " WHERE " + columnName$ + " IS NOT NULL AND TRIM(" + columnName$ + ") <> '';")
+	if type(countStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return -1
+	end if
+
+	countValue = -1
+	result = countStatement.Run()
+	if result = 102 then
+		row = countStatement.GetData()
+		if type(row) = "roAssociativeArray" then
+			countValue = int(val(sql_FormValueToString(sql_GetRowFieldValue(row, "valueCount"))))
+			if countValue < 0 then
+				countValue = 0
+			end if
+		end if
+	end if
+
+	countStatement.Finalise()
+	myDB.Close()
+	return countValue
+End Function
+
+Function sql_SyncAutoincrementSequence(m as Object, myDB as Object, dbTable$ as String, rowIdColumn$ as String) as Boolean
+	if type(myDB) <> "roSqliteDatabase" then
+		return false
+	end if
+
+	maxId = 0
+	maxIdStatement = myDB.CreateStatement("SELECT MAX(" + rowIdColumn$ + ") AS maxId FROM " + dbTable$ + ";")
+	if type(maxIdStatement) = "roSqliteStatement" then
+		maxResult = maxIdStatement.Run()
+		if maxResult = 102 then
+			maxRow = maxIdStatement.GetData()
+			if type(maxRow) = "roAssociativeArray" and maxRow.maxId <> invalid then
+				maxId = int(val(sql_FormValueToString(maxRow.maxId)))
+				if maxId < 0 then
+					maxId = 0
+				end if
+			end if
+		end if
+		maxIdStatement.Finalise()
+	else
+		return false
+	end if
+
+	if maxId <= 0 then
+		clearSeqStatement = myDB.CreateStatement("DELETE FROM sqlite_sequence WHERE name = ?;")
+		if type(clearSeqStatement) = "roSqliteStatement" then
+			return sql_RunWriteStatement(clearSeqStatement, [dbTable$], m, "------------------ SQL bind error (clear rowID sequence after delete)", "------------------ SQL clear rowID sequence after delete error: ")
+		end if
+		return false
+	end if
+
+	setSeqStatement = myDB.CreateStatement("UPDATE sqlite_sequence SET seq = ? WHERE name = ?;")
+	if type(setSeqStatement) = "roSqliteStatement" then
+		setOk = sql_RunWriteStatement(setSeqStatement, [maxId, dbTable$], m, "------------------ SQL bind error (set rowID sequence after delete)", "------------------ SQL set rowID sequence after delete error: ")
+		if setOk then
+			return true
+		end if
+	end if
+
+	insertSeqStatement = myDB.CreateStatement("INSERT INTO sqlite_sequence(name, seq) VALUES(?, ?);")
+	if type(insertSeqStatement) <> "roSqliteStatement" then
+		return false
+	end if
+
+	return sql_RunWriteStatement(insertSeqStatement, [dbTable$, maxId], m, "------------------ SQL bind error (insert rowID sequence)", "------------------ SQL insert rowID sequence error: ")
+End Function
+
+Function sql_DeleteTableRows(m as Object, dbFile$ as String, dbTable$ as String) as Boolean
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return false
+	end if
+
+	deleteStatement = myDB.CreateStatement("DELETE FROM " + dbTable$ + ";")
+	success = sql_RunWriteStatement(deleteStatement, [], m, "------------------ SQL bind error (delete all rows)", "------------------ SQL delete all rows error: ")
+
+	if success then
+		' Reset AUTOINCREMENT so next insert starts again from rowID 1.
+		resetSeqStatement = myDB.CreateStatement("DELETE FROM sqlite_sequence WHERE name = ?;")
+		if type(resetSeqStatement) = "roSqliteStatement" then
+			resetOk = sql_RunWriteStatement(resetSeqStatement, [dbTable$], m, "------------------ SQL bind error (reset rowID sequence)", "------------------ SQL reset rowID sequence error: ")
+			if not resetOk then
+				success = false
+			end if
+		else
+			success = false
+		end if
+	end if
+
+	myDB.Close()
+	return success
+End Function
+
+Function sql_UpdateRecord(m as Object, dbFile$ as String, dbTable$ as String, rowID as Integer, columns as Object, values as Object) as Boolean
+	myDB = CreateObject("roSqliteDatabase")
+
+	if type(columns) <> "roArray" or type(values) <> "roArray" then
+		return false
+	end if
+
+	if columns.Count() = 0 or columns.Count() <> values.Count() then
+		return false
+	end if
+
+	if rowID <= 0 then
+		return false
+	end if
+
+	if myDB.Open(dbFile$) = invalid then
+		return false
+	end if
+
+	rowIdColumn$ = sql_GetDefaultRowIdColumnName(m)
+
+	if not sql_RowExistsById(myDB, dbTable$, rowID, rowIdColumn$) then
+		myDB.Close()
+		return false
+	end if
+
+	setClause$ = ""
+	for i = 0 to columns.Count() - 1
+		if i > 0 then
+			setClause$ = setClause$ + ", "
+		end if
+		setClause$ = setClause$ + columns[i] + " = ?"
+	next
+
+	sql$ = "UPDATE " + dbTable$ + " SET " + setClause$ + " WHERE " + rowIdColumn$ + " = ?;"
+	updateStatement = myDB.CreateStatement(sql$)
+	bindParams = []
+	for each v in values
+		bindParams.Push(v)
+	next
+	bindParams.Push(rowID)
+
+	success = sql_RunWriteStatement(updateStatement, bindParams, m, "------------------ SQL bind error (update)", "------------------ SQL update error: ")
+	myDB.Close()
+	return success
+End Function
+
+Function sql_RowExistsById(myDB as Object, dbTable$ as String, rowID as Integer, rowIdColumn$ = "rowID" as String) as Boolean
+	if type(myDB) <> "roSqliteDatabase" or rowID <= 0 then
+		return false
+	end if
+
+	if not sql_IsValidTableName(rowIdColumn$) then
+		rowIdColumn$ = "rowID"
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT 1 FROM " + dbTable$ + " WHERE " + rowIdColumn$ + " = ? LIMIT 1;")
+	if type(selectStatement) <> "roSqliteStatement" then
+		return false
+	end if
+
+	params = [rowID]
+	if not selectStatement.BindByOffset(params) then
+		selectStatement.Finalise()
+		return false
+	end if
+
+	result = selectStatement.Run()
+	selectStatement.Finalise()
+	return result = 102
+End Function
+
+Function sql_GetDefaultRowIdColumnName(m as Object) as String
+	rowIdColumn$ = "rowID"
+	if type(m) = "roAssociativeArray" and m.defaultRowID <> invalid and type(m.defaultRowID) = "roString" then
+		candidate$ = sql_TrimString(m.defaultRowID)
+		if sql_IsValidTableName(candidate$) then
+			rowIdColumn$ = candidate$
+		end if
+	end if
+	return rowIdColumn$
+End Function
+
+Function sql_RunWriteStatement(statement as Object, params as Object, m as Object, bindErrorMessage$ as String, runErrorPrefix$ as String) as Boolean
+	if type(statement) <> "roSqliteStatement" then
+		return false
+	end if
+
+	if not statement.BindByOffset(params) then
+		if type(m) = "roAssociativeArray" and type(m.SystemLog) = "roSystemLog" then
+			m.SystemLog.SendLine(bindErrorMessage$)
+		end if
+		statement.Finalise()
+		return false
+	end if
+
+	result = statement.Run()
+	statement.Finalise()
+	if result = 100 then
+		return true
+	end if
+
+	if type(m) = "roAssociativeArray" and type(m.SystemLog) = "roSystemLog" then
+		m.SystemLog.SendLine(runErrorPrefix$ + result.ToStr())
+	end if
+	return false
+End Function
+
+Sub sql_SendReadResponse(mVar as Object, tableName$ as String, e as Object)
+	respBody = {
+		rows: sql_ReadAllRows(mVar.dbFile, tableName$)
+	}
+	e.AddResponseHeader("Content-type", "application/json")
+	e.SetResponseBodyString(sql_PrettyJson(FormatJson(respBody), 2))
+	e.SendResponse(200)
+End Sub
+
+
+Function sql_ResolveDbPath(dbFile$ as String) as String
+	if dbFile$ = invalid or dbFile$ = "" then
+		return "sd:/userData.db"
+	end if
+
+	if InStr(1, LCase(dbFile$), ":/") = 0 then
+		return "sd:/" + dbFile$
+	end if
+
+	return dbFile$
+End Function
+
+
+Sub sql_EnsureDatabaseFile(m as Object)
+
+	resolvedDb$ = sql_ResolveDbPath(m.dbFile)
+	m.dbFile = resolvedDb$
+	myDB = CreateObject("roSqliteDatabase")
+
+	if not sql_CheckIfFileExists(resolvedDb$) then
+		if myDB.Create(resolvedDb$) = invalid then
+			m.SystemLog.SendLine("---------------------- Failed to create database file: " + resolvedDb$)
+			return
+		end if
+		m.SystemLog.SendLine("---------------------- Created database file: " + resolvedDb$)
+
+		createTableSQL$ = sql_BuildCreateTableSQL(m.defaultTable, m.columnArray)
+		if createTableSQL$ = "" then
+			m.SystemLog.SendLine("---------------------- Failed to build default table SQL from defaultTable/columnArray")
+		else
+			myDB.Close()
+
+			if sql_CreateAndInitializeCustomDB(m, m.dbFile, createTableSQL$) then
+				m.SystemLog.SendLine("---------------------- Default table is ready: " + m.defaultTable)
+			else
+				m.SystemLog.SendLine("---------------------- Failed to create default table: " + m.defaultTable)
+			end if
+			
+			myDB = CreateObject("roSqliteDatabase")
+			if myDB.Open(resolvedDb$) = invalid then
+				m.SystemLog.SendLine("---------------------- Failed to reopen database file after table creation: " + resolvedDb$)
+				return
+			end if
+
+		end if
+	else
+		if myDB.Open(resolvedDb$) = invalid then
+			m.SystemLog.SendLine("---------------------- Failed to open database file: " + resolvedDb$)
+			return
+		end if
+		m.SystemLog.SendLine("---------------------- Opened database file: " + resolvedDb$)
+	end if
+
+	myDB.Close()
+
+End Sub
+
+
+' ===== Form/Type Utilities =====
+Function sql_GetFormValue(args as Object, fieldName$ as String, defaultValue$ as String) as String
+	if type(args) = "roAssociativeArray" and args.DoesExist(fieldName$) and args[fieldName$] <> invalid then
+		return sql_FormValueToString(args[fieldName$])
+	end if
+	return defaultValue$
+End Function
+
+Function sql_FormValueToString(value as Object) as String
+	if value = invalid then
+		return ""
+	end if
+
+	vType$ = type(value)
+	if vType$ = "roString" then
+		return value
+	end if
+
+	if vType$ = "Integer" or vType$ = "LongInteger" or vType$ = "Float" or vType$ = "Double" or vType$ = "Boolean" then
+		return value.ToStr()
+	end if
+
+	if vType$ = "roInt" or vType$ = "roInteger" or vType$ = "roLongInteger" or vType$ = "roFloat" or vType$ = "roDouble" or vType$ = "roBoolean" then
+		return value.ToStr()
+	end if
+
+	if vType$ = "roArray" then
+		if value.Count() = 0 or value[0] = invalid then
+			return ""
+		end if
+		return sql_FormValueToString(value[0])
+	end if
+
+	if GetInterface(value, "ifString") <> invalid then
+		return value.ToStr()
+	end if
+
+	if GetInterface(value, "ifInt") <> invalid then
+		return value.ToStr()
+	end if
+
+	if GetInterface(value, "ifFloat") <> invalid then
+		return value.ToStr()
+	end if
+
+	return ""
+End Function
+
+Function sql_HtmlEscape(value$ as String) as String
+	if value$ = invalid or value$ = "" then
+		return ""
+	end if
+
+	encoded$ = ""
+	for i = 1 to Len(value$)
+		ch$ = Mid(value$, i, 1)
+		if ch$ = "&" then
+			encoded$ = encoded$ + "&"
+		else if ch$ = "<" then
+			encoded$ = encoded$ + "<"
+		else if ch$ = ">" then
+			encoded$ = encoded$ + ">"
+		else if ch$ = Chr(34) then
+			encoded$ = encoded$ + """
+		else if ch$ = "'" then
+			encoded$ = encoded$ + "'"
+		else
+			encoded$ = encoded$ + ch$
+		end if
+	next
+
+	return encoded$
+End Function
+
+Function sql_GetRowIdValue(row as Object, rowKey$ as String) as String
+	if type(row) <> "roAssociativeArray" then
+		return ""
+	end if
+
+	if row.DoesExist(rowKey$) and row[rowKey$] <> invalid then
+		return sql_FormValueToString(row[rowKey$])
+	end if
+
+	for each key in row
+		if LCase(key) = LCase(rowKey$) and row[key] <> invalid then
+			return sql_FormValueToString(row[key])
+		end if
+	next
+
+	return ""
+End Function
+
+Function sql_GetRowFieldValue(row as Object, fieldName$ as String) as String
+	if type(row) <> "roAssociativeArray" then
+		return ""
+	end if
+
+	if row.DoesExist(fieldName$) and row[fieldName$] <> invalid then
+		return sql_FormValueToString(row[fieldName$])
+	end if
+
+	for each key in row
+		if LCase(key) = LCase(fieldName$) and row[key] <> invalid then
+			return sql_FormValueToString(row[key])
+		end if
+	next
+
+	return ""
+End Function
+
+Function sql_IsTableEffectivelyEmpty(rows as Object, columns as Object) as Boolean
+	if type(rows) <> "roArray" or type(columns) <> "roArray" then
+		return false
+	end if
+
+	if rows.Count() = 0 or columns.Count() = 0 then
+		return false
+	end if
+
+	for each row in rows
+		if type(row) = "roAssociativeArray" then
+			for each columnName in columns
+				if sql_TrimString(sql_GetRowFieldValue(row, columnName)) <> "" then
+					return false
+				end if
+			next
+		end if
+	next
+
+	return true
+End Function
+
+Function sql_TrimString(value$ as String) as String
+	if value$ = invalid then
+		return ""
+	end if
+
+	startIdx = 1
+	endIdx = Len(value$)
+
+	while startIdx <= endIdx
+		ch$ = Mid(value$, startIdx, 1)
+		if ch$ <> " " and ch$ <> Chr(9) and ch$ <> Chr(10) and ch$ <> Chr(13) then
+			exit while
+		end if
+		startIdx = startIdx + 1
+	end while
+
+	while endIdx >= startIdx
+		ch$ = Mid(value$, endIdx, 1)
+		if ch$ <> " " and ch$ <> Chr(9) and ch$ <> Chr(10) and ch$ <> Chr(13) then
+			exit while
+		end if
+		endIdx = endIdx - 1
+	end while
+
+	if startIdx > endIdx then
+		return ""
+	end if
+
+	return Mid(value$, startIdx, endIdx - startIdx + 1)
+End Function
+
+Function sql_GetTableNames(dbFile$ as String) as Object
+	myDB = CreateObject("roSqliteDatabase")
+	tableNames = []
+	if myDB.Open(dbFile$) = invalid then
+		if myDB.Create(dbFile$) = invalid then
+			return tableNames
+		end if
+		if myDB.Open(dbFile$) = invalid then
+			return tableNames
+		end if
+	end if
+
+	selectStatement = myDB.CreateStatement("SELECT name FROM sqlite_master WHERE type='table' ORDER BY name;")
+	if type(selectStatement) = "roSqliteStatement" then
+		sqlResult = selectStatement.Run()
+		SQLITE_ROWS = 102
+		while sqlResult = SQLITE_ROWS
+			row = selectStatement.GetData()
+			if type(row) = "roAssociativeArray" and row.name <> invalid and not sql_IsInternalTable(row.name) then
+				tableNames.Push(row.name)
+			end if
+			sqlResult = selectStatement.Run()
+		end while
+		selectStatement.Finalise()
+	end if
+	myDB.Close()
+	return tableNames
+End Function
+
+Sub sql_SyncDefaultTable(m as Object)
+	if type(m.tableNames) <> "roArray" then
+		m.tableNames = []
+	end if
+
+	if m.tableNames.Count() = 0 then
+		m.defaultTable = "UserInfo"
+		return
+	end if
+
+	for each tableName in m.tableNames
+		if tableName = m.defaultTable then
+			return
+		end if
+	next
+
+	m.defaultTable = m.tableNames[0]
+End Sub
+
+Function sql_GetInsertableColumns(columnArray as Object) as Object
+	columns = []
+	if type(columnArray) <> "roArray" then
+		return columns
+	end if
+
+	for each col in columnArray
+		if type(col) = "roAssociativeArray" then
+			nameValue = sql_GetAssocValueIgnoreCase(col, "name")
+			typeValue = sql_GetAssocValueIgnoreCase(col, "type")
+			colName$ = sql_TrimString(sql_FormValueToString(nameValue))
+			colType$ = sql_TrimString(sql_FormValueToString(typeValue))
+
+			if colName$ <> "" and colType$ <> "" then
+				colTypeUpper$ = UCase(colType$)
+				if Instr(1, colTypeUpper$, "PRIMARY KEY") = 0 and Instr(1, colTypeUpper$, "AUTOINCREMENT") = 0 then
+					columns.Push(colName$)
+				end if
+			end if
+		end if
+	next
+
+	return columns
+End Function
+
+Function sql_GetTableColumnArray(dbFile$ as String, tableName$ as String) as Object
+	columns = []
+	if not sql_IsValidTableName(tableName$) then
+		return columns
+	end if
+
+	myDB = CreateObject("roSqliteDatabase")
+	if myDB.Open(dbFile$) = invalid then
+		return columns
+	end if
+
+	selectStatement = myDB.CreateStatement("PRAGMA table_info(" + tableName$ + ");")
+	if type(selectStatement) <> "roSqliteStatement" then
+		myDB.Close()
+		return columns
+	end if
+
+	sqlResult = selectStatement.Run()
+	while sqlResult = 102
+		row = selectStatement.GetData()
+		if type(row) = "roAssociativeArray" then
+			colName$ = sql_TrimString(sql_GetRowFieldValue(row, "name"))
+			colType$ = sql_TrimString(sql_GetRowFieldValue(row, "type"))
+			pkValue = int(val(sql_GetRowFieldValue(row, "pk")))
+
+			if colName$ <> "" and sql_IsValidTableName(colName$) then
+				if colType$ = "" then
+					colType$ = "TEXT"
+				end if
+
+				colTypeUpper$ = UCase(colType$)
+				if pkValue > 0 and Instr(1, colTypeUpper$, "PRIMARY KEY") = 0 then
+					colType$ = colType$ + " PRIMARY KEY"
+					if LCase(colName$) = "rowid" and Instr(1, colTypeUpper$, "INT") > 0 and Instr(1, UCase(colType$), "AUTOINCREMENT") = 0 then
+						colType$ = colType$ + " AUTOINCREMENT"
+					end if
+				end if
+
+				columns.Push({ name: colName$, type: colType$ })
+			end if
+		end if
+		sqlResult = selectStatement.Run()
+	end while
+
+	selectStatement.Finalise()
+	myDB.Close()
+	return columns
+End Function
+
+Function sql_GetInsertableColumnsForTable(m as Object, dbFile$ as String, tableName$ as String) as Object
+	tableColumns = sql_GetTableColumnArray(dbFile$, tableName$)
+	columns = sql_GetInsertableColumns(tableColumns)
+	if type(columns) = "roArray" and columns.Count() > 0 then
+		return columns
+	end if
+
+	if type(m) = "roAssociativeArray" and type(m.columnArray) = "roArray" then
+		return sql_GetInsertableColumns(m.columnArray)
+	end if
+
+	return []
+End Function
+
+Function sql_IsInternalTable(tableName$ as String) as Boolean
+	if tableName$ = invalid or tableName$ = "" then
+		return true
+	end if
+	if Left(tableName$, 7) = "sqlite_" then
+		return true
+	end if
+	return false
+End Function
+
+
+Function sql_IsValidTableName(tableName$ as String) as Boolean
+	if tableName$ = invalid or tableName$ = "" then
+		return false
+	end if
+
+	firstChar$ = Mid(tableName$, 1, 1)
+	if not sql_IsLetterOrUnderscore(firstChar$) then
+		return false
+	end if
+
+	for i = 1 to Len(tableName$)
+		ch$ = Mid(tableName$, i, 1)
+		if not sql_IsLetterOrDigitOrUnderscore(ch$) then
+			return false
+		end if
+	next
+
+	return true
+End Function
+
+Function sql_IsLetterOrUnderscore(ch$ as String) as Boolean
+	if ch$ = "_" then
+		return true
+	end if
+	code = Asc(ch$)
+	if (code >= 65 and code <= 90) or (code >= 97 and code <= 122) then
+		return true
+	end if
+	return false
+End Function
+
+Function sql_ParsePositiveIntStrict(value$ as String) as Integer
+	text$ = sql_TrimString(value$)
+	if text$ = "" then
+		return 0
+	end if
+
+	num = int(val(text$))
+	if num <= 0 or num.ToStr() <> text$ then
+		return 0
+	end if
+
+	return num
+End Function
+
+Function sql_IsLetterOrDigitOrUnderscore(ch$ as String) as Boolean
+	if ch$ = "_" then
+		return true
+	end if
+	code = Asc(ch$)
+	if (code >= 65 and code <= 90) or (code >= 97 and code <= 122) or (code >= 48 and code <= 57) then
+		return true
+	end if
+	return false
+End Function
+
+Function sql_BuildCreateTableSQL(tableName$ as String, columnArray as Object) as String
+	if not sql_IsValidTableName(tableName$) then
+		return ""
+	end if
+
+	if type(columnArray) <> "roArray" or columnArray.Count() = 0 then
+		return ""
+	end if
+
+	columnsSql$ = ""
+	for each col in columnArray
+		if type(col) <> "roAssociativeArray" then
+			return ""
+		end if
+
+		nameValue = sql_GetAssocValueIgnoreCase(col, "name")
+		typeValue = sql_GetAssocValueIgnoreCase(col, "type")
+		if nameValue = invalid or typeValue = invalid then
+			return ""
+		end if
+
+		colName$ = sql_TrimString(sql_FormValueToString(nameValue))
+		colType$ = sql_TrimString(sql_FormValueToString(typeValue))
+		if not sql_IsValidTableName(colName$) then
+			return ""
+		end if
+		if colType$ = "" then
+			return ""
+		end if
+
+		if columnsSql$ <> "" then
+			columnsSql$ = columnsSql$ + ", "
+		end if
+		columnsSql$ = columnsSql$ + colName$ + " " + colType$
+	next
+
+	return "CREATE TABLE IF NOT EXISTS " + tableName$ + " (" + columnsSql$ + ");"
+End Function
+
+
+' ===== Error Mapping and JSON Response =====
+Function sql_GetErrorCodeFromMessage(message$ as String, statusCode as Integer) as String
+	msg$ = LCase(sql_TrimString(message$))
+
+	if Instr(1, msg$, "invalid tablename") > 0 then
+		return "INVALID_TABLE_NAME"
+	else if Instr(1, msg$, "invalid columnname") > 0 then
+		return "INVALID_COLUMN_NAME"
+	else if Instr(1, msg$, "rowid is required") > 0 then
+		return "MISSING_ROW_ID"
+	else if Instr(1, msg$, "rowid must be a positive integer") > 0 then
+		return "INVALID_ROW_ID"
+	else if Instr(1, msg$, "row not found") > 0 then
+		return "ROW_NOT_FOUND"
+	else if Instr(1, msg$, "column not found") > 0 then
+		return "COLUMN_NOT_FOUND"
+	else if Instr(1, msg$, "rowsjson is required") > 0 then
+		return "MISSING_ROWS_JSON"
+	else if Instr(1, msg$, "rowsjson must be a json array") > 0 then
+		return "INVALID_ROWS_JSON"
+	else if Instr(1, msg$, "invalid columnsjson") > 0 then
+		return "INVALID_COLUMNS_JSON"
+	else if Instr(1, msg$, "invalid columnarray schema") > 0 then
+		return "INVALID_COLUMN_ARRAY"
+	else if Instr(1, msg$, "provide at least one field to update") > 0 then
+		return "NO_UPDATE_FIELDS"
+	else if Instr(1, msg$, "no insertable columns") > 0 then
+		return "NO_INSERTABLE_COLUMNS"
+	else if Instr(1, msg$, "no updatable columns") > 0 then
+		return "NO_UPDATABLE_COLUMNS"
+	else if Instr(1, msg$, "count failed") > 0 then
+		return "COUNT_FAILED"
+	else if Instr(1, msg$, "update failed") > 0 then
+		return "UPDATE_FAILED"
+	else if Instr(1, msg$, "update all failed") > 0 then
+		return "UPDATE_ALL_FAILED"
+	else if Instr(1, msg$, "insert failed") > 0 then
+		return "INSERT_FAILED"
+	else if Instr(1, msg$, "delete failed") > 0 then
+		return "DELETE_FAILED"
+	else if Instr(1, msg$, "delete where failed") > 0 then
+		return "DELETE_WHERE_FAILED"
+	else if Instr(1, msg$, "delete all rows failed") > 0 then
+		return "DELETE_ALL_ROWS_FAILED"
+	else if Instr(1, msg$, "unable to create table") > 0 then
+		return "CREATE_TABLE_FAILED"
+	end if
+
+	if statusCode = 400 then
+		return "BAD_REQUEST"
+	else if statusCode = 401 then
+		return "UNAUTHORIZED"
+	else if statusCode = 403 then
+		return "FORBIDDEN"
+	else if statusCode = 404 then
+		return "NOT_FOUND"
+	else if statusCode >= 500 then
+		return "INTERNAL_ERROR"
+	end if
+
+	return "UNSPECIFIED_ERROR"
+End Function
+
+Sub sql_EnsureErrorCode(body as Object, statusCode as Integer)
+	if type(body) <> "roAssociativeArray" then
+		return
+	end if
+
+	if not body.DoesExist("status") then
+		return
+	end if
+
+	status$ = LCase(sql_TrimString(sql_FormValueToString(body.status)))
+	if status$ <> "error" then
+		return
+	end if
+
+	if body.DoesExist("code") and sql_TrimString(sql_FormValueToString(body.code)) <> "" then
+		return
+	end if
+
+	message$ = ""
+	if body.DoesExist("message") then
+		message$ = sql_FormValueToString(body.message)
+	end if
+	body.code = sql_GetErrorCodeFromMessage(message$, statusCode)
+End Sub
+
+Sub sql_SendJsonResponse(e as Object, statusCode as Integer, body as Object)
+	sql_EnsureErrorCode(body, statusCode)
+	e.AddResponseHeader("Content-type", "application/json")
+	e.SetResponseBodyString(FormatJson(body))
+	e.SendResponse(statusCode)
+End Sub
+
+Function sql_PrettyJson(json$ as String, indentSize as Integer) as String
+	if json$ = invalid then
+		return ""
+	end if
+
+	if indentSize <= 0 then
+		indentSize = 2
+	end if
+
+	out$ = ""
+	indentLevel = 0
+	inString = false
+	escapeNext = false
+
+	for i = 1 to Len(json$)
+		ch$ = Mid(json$, i, 1)
+
+		if inString then
+			out$ = out$ + ch$
+			if escapeNext then
+				escapeNext = false
+			else if ch$ = "\\" then
+				escapeNext = true
+			else if ch$ = Chr(34) then
+				inString = false
+			end if
+		else
+			if ch$ = Chr(34) then
+				inString = true
+				out$ = out$ + ch$
+			else if ch$ = "{" or ch$ = "[" then
+				indentLevel = indentLevel + 1
+				out$ = out$ + ch$ + Chr(10) + sql_RepeatSpace(indentLevel * indentSize)
+			else if ch$ = "}" or ch$ = "]" then
+				indentLevel = indentLevel - 1
+				if indentLevel < 0 then indentLevel = 0
+				out$ = out$ + Chr(10) + sql_RepeatSpace(indentLevel * indentSize) + ch$
+			else if ch$ = "," then
+				out$ = out$ + ch$ + Chr(10) + sql_RepeatSpace(indentLevel * indentSize)
+			else if ch$ = ":" then
+				out$ = out$ + ": "
+			else if ch$ <> " " and ch$ <> Chr(9) and ch$ <> Chr(10) and ch$ <> Chr(13) then
+				out$ = out$ + ch$
+			end if
+		end if
+	next
+
+	return out$
+End Function
+
+Function sql_RepeatSpace(count as Integer) as String
+	if count <= 0 then
+		return ""
+	end if
+
+	spaces$ = ""
+	for i = 1 to count
+		spaces$ = spaces$ + " "
+	next
+
+	return spaces$
+End Function
+
+
+Function sql_CheckIfFileExists(filePath as String) as Boolean
+	resolvedPath$ = sql_ResolveDbPath(filePath)
+	retval = false
+
+	lastSlashPos = 0
+	for i = 1 to Len(resolvedPath$)
+		if Mid(resolvedPath$, i, 1) = "/" then
+			lastSlashPos = i
+		end if
+	next
+
+	if lastSlashPos <= 0 then
+		return false
+	end if
+
+	dirPath$ = Left(resolvedPath$, lastSlashPos)
+	fileName$ = Mid(resolvedPath$, lastSlashPos + 1)
+	targetFile$ = LCase(fileName$)
+
+	if fileName$ = "" then
+		return false
+	end if
+
+
+	dirList = ListDir(dirPath$)
+	if dirList <> invalid then
+		for each file in dirList
+			if LCase(file) = targetFile$ then
+				retval = true
+				exit for
+			end if
+		next
+	end if
+
+	return retval
+
+End Function
+
+Sub EnableUDPNotifications(m as object)
+	if m.bsp <> invalid and type(m.bsp) = "roAssociativeArray" then
+		if type(m.bsp.CreateDatagramReceiver) = "roFunction" then
+			if m.bsp.udpReceivePort <> invalid then
+				m.bsp.CreateDatagramReceiver(m.bsp.udpReceivePort)
+				m.bsp.diagnostics.PrintDebug("[EnableUDPNotifications] udpReceivePort already set: " + m.bsp.udpReceivePort.ToStr())
+			else
+				m.bsp.CreateDatagramReceiver(m.bsp.udpNotificationPort%)
+				m.bsp.diagnostics.PrintDebug("[EnableUDPNotifications] Creating DatagramReceiver on port: " + m.bsp.udpNotificationPort%.ToStr())
+			end if
+		end if
+	end if
+End Sub

From 5795a72774d01932ff6004ca92472a5f75a47886 Mon Sep 17 00:00:00 2001
From: thai-canada <93546914+thai-canada@users.noreply.github.com>
Date: Mon, 8 Jun 2026 12:26:34 -0400
Subject: [PATCH 4/4] Update README.md

Signed-off-by: thai-canada <93546914+thai-canada@users.noreply.github.com>
---
 sqlite-plugin/README.md | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/sqlite-plugin/README.md b/sqlite-plugin/README.md
index bd38151..1937b18 100644
--- a/sqlite-plugin/README.md
+++ b/sqlite-plugin/README.md
@@ -6,7 +6,7 @@ This plugin runs a local SQLite-backed API server on a BrightSign player and als
 - Default DB file: `sd:/userData.db`
 - Default table: `UserInfo`
 - Default HTTP port: `8009`
-- Created by: Thai Nguyen
+- Add this plugin to BrightAuthor, naming it sql, and open the webpage at default port: `8009`
 
 ## What It Does