replace sqlite3 with better-sqlite3 closes #143

Author: lroal

dist/index.mjs

@@ -18102,27 +18102,42 @@ var hasRequiredWrapQuery$4;
 function requireWrapQuery$4 () {
 	if (hasRequiredWrapQuery$4) return wrapQuery_1$4;
 	hasRequiredWrapQuery$4 = 1;
-	var log = requireLog();
+	const log = requireLog();
+	const connectionCache  = new WeakMap();
 
 	function wrapQuery(_context, connection) {
-		var runOriginalQuery = connection.all;
+		let statementCache = connectionCache.get(connection);
+		if (!statementCache) {
+			statementCache = new Map();
+			connectionCache.set(connection, statementCache);
+		}
+
 		return runQuery;
 
 		function runQuery(query, onCompleted) {
-			var params = query.parameters;
-			var sql = query.sql();
-			log.emitQuery({sql, parameters: params});
+			try {
+				var params = query.parameters;
+				var sql = query.sql();
+				log.emitQuery({ sql, parameters: params });
 
-			runOriginalQuery.call(connection, sql, params, onInnerCompleted);
+				let statement = statementCache.get(sql);
+				if (!statement) {
+					statement = connection.prepare(sql);
+					statementCache.set(sql, statement);
+				}
 
-			function onInnerCompleted(err, rows) {
-				if (err)
-					onCompleted(err);
-				else
+				if (statement.reader) {
+					const rows = statement.all.apply(statement, params);
 					onCompleted(null, rows);
+				} else {
+					statement.run.apply(statement, params);
+					onCompleted(null, []);
+				}
+			}
+			catch (e) {
+				onCompleted(e);
 			}
 		}
-
 	}
 
 	wrapQuery_1$4 = wrapQuery;
@@ -18136,24 +18151,38 @@ function requireWrapCommand$4 () {
 	if (hasRequiredWrapCommand$4) return wrapCommand_1$4;
 	hasRequiredWrapCommand$4 = 1;
 	var log = requireLog();
+	var connectionCache = new WeakMap();
 
 	function wrapCommand(_context, connection) {
-		var runOriginalQuery = connection.run;
+		var statementCache = connectionCache.get(connection);
+		if (!statementCache) {
+			statementCache = new Map();
+			connectionCache.set(connection, statementCache);
+		}
 		return runQuery;
 
 		function runQuery(query, onCompleted) {
 			var params = query.parameters;
 			var sql = query.sql();
 			log.emitQuery({ sql, parameters: params });
 
-			runOriginalQuery.call(connection, sql, params, function onInnerCompleted(err) {
-				if (err) {
-					onCompleted(err);
-				} else {
-					var affectedRows = typeof this.changes === 'number' ? this.changes : 0;
-					onCompleted(null, { rowsAffected: affectedRows });
+			try {
+				var statement = statementCache.get(sql);
+				if (!statement) {
+					statement = connection.prepare(sql);
+					statementCache.set(sql, statement);
 				}
-			});
+				var info = statement.run.apply(statement, params);
+				var affected = info && typeof info.changes === 'number' ? info.changes : 0;
+				var insertId = info && typeof info.lastInsertRowid !== 'undefined' ? info.lastInsertRowid : undefined;
+				if (typeof insertId !== 'undefined')
+					onCompleted(null, { rowsAffected: affected, lastInsertRowid: insertId });
+				else
+					onCompleted(null, { rowsAffected: affected });
+			}
+			catch (e) {
+				onCompleted(e);
+			}
 		}
 	}
 
@@ -18320,20 +18349,20 @@ function requireNewGenericPool$4 () {
 			create: async function(cb) {
 				try {
 					if (!sqlite)
-						sqlite = await import('sqlite3');
+						sqlite = await import('better-sqlite3');
 					sqlite = sqlite.default || sqlite;
 				}
 				catch (err) {
 					return cb(err, null);
 				}
-				var client = new sqlite.Database(connectionString, onConnected);
-
-				function onConnected(err) {
-					if(err)
-						return cb(err, null);
+				try {
+					var client = new sqlite(connectionString);
 					client.poolCount = 0;
 					return cb(null, client);
 				}
+				catch (err) {
+					return cb(err, null);
+				}
 			},
 
 			destroy: function(client) {

docs/changelog.md

@@ -1,4 +1,7 @@
 ## Changelog
+__4.9.0__  
+Node.js 22.5+: Continues using built-in `node:sqlite` (no action needed)  
+Node.js 18-22.4: Now requires `better-sqlite3` instead of `sqlite3`  
 __4.8.2__  
 Slight performance gain on updates and removed accidental console.dir  
 __4.8.1__