add initial benchmarks, renamed apis

Author: amilajack

README.md

@@ -20,6 +20,7 @@ An experimental SQLite library for Node using Neon
 * Target latest node and electron versions
 * Promise based API
 * Blob support
+* ESNext `BigInt` support
 * SQLite extensions support
 * Typescript support
 * Query caching support
@@ -35,7 +36,7 @@ import Sqlite from '@sqlite/sqlite';
 const connector = new Sqlite();
 
 // Creating a regular async connection
-const conn = await connection.create({
+const conn = await connection.open({
   database: '/path/to/database', // ':memory:'
   verbose: true                  // process.env.NODE_ENV !== 'production'
 });
@@ -48,7 +49,26 @@ await Promise.all([
 
 // Statement currying
 const updateTables = await db.statement('UPDATE tbl SET name = ? WHERE email = ?');
-await updateTables('john', 'john@gmail.com');
+const result = await updateTables('john', 'john@gmail.com');
+console.log(result);
+
+// Batching queries
+const updateTables = await db.batch(
+  `
+  ATTACH DATABASE ':memory:' AS my_attached;
+  BEGIN;
+  CREATE TABLE my_attached.foo(x INTEGER);
+  INSERT INTO my_attached.foo VALUES(42);
+  END
+  `;
+);
+const updateTables = await db.batch([
+  'ATTACH DATABASE ':memory:' AS my_attached;',
+  'BEGIN;',
+  'CREATE TABLE my_attached.foo(x INTEGER);',
+  'INSERT INTO my_attached.foo VALUES(42);',
+  'END'
+]);
 ```
 
 ## Local Development

bench/basic.bench.js

@@ -0,0 +1,41 @@
+const sqlite3 = require('sqlite3');
+const Sqlite = require('../');
+
+const t = process.hrtime();
+const db = new sqlite3.Database(':memory:');
+db.serialize(() => {
+  db.run('CREATE TABLE lorem (info TEXT)');
+
+  const stmt = db.prepare('INSERT INTO lorem VALUES (?)');
+  for (let i = 0; i < 10; i++) {
+    stmt.run(`Ipsum ${i}`);
+  }
+  stmt.finalize();
+
+  db.each('SELECT rowid AS id, info FROM lorem', (err, row) => {
+    // console.log(`${row.id}: ${row.info}`);
+  });
+  db.close();
+  console.log('sqlite3', process.hrtime(t)[1]);
+});
+
+const connector = new Sqlite.Sqlite();
+
+(async () => {
+  const s = process.hrtime();
+  // Creating a regular async connection
+  const conn = await connector.open({
+    verbose: true // process.env.NODE_ENV !== 'production'
+  });
+  // conn.prepare('CREATE TABLE lorem (info TEXT)');
+  // conn.close();
+  console.log('neon sqlite', process.hrtime(s)[1]);
+})();
+
+(async () => {
+  const s = process.hrtime();
+  // Creating a regular async connection
+  // Sqlite.example();
+  // conn.close();
+  console.log('example', process.hrtime(s)[1]);
+})();

native/src/lib.rs

@@ -1,3 +1,5 @@
+#![feature(test)]
+extern crate test;
 #[macro_use]
 extern crate neon;
 extern crate rusqlite;
@@ -15,16 +17,6 @@ pub struct Sqlite {
     pub verbose: Option<bool>,
 }
 
-fn map_err_to_js_err<T>(res: Result<T, rusqlite::Error>) -> T {
-    match res {
-        Ok(r) => r,
-        Err(e) => {
-            println!("asdfasfd{}", e);
-            panic!(e);
-        }
-    }
-}
-
 declare_types! {
     pub class JsSqlite for Sqlite {
         init(_cx) {
@@ -35,7 +27,7 @@ declare_types! {
             })
         }
 
-        method create(mut cx) {
+        method open(mut cx) {
             let database_value: String;
             let verbose_value: bool;
 
@@ -107,7 +99,15 @@ declare_types! {
             Ok(js_array.upcast())
         }
 
-        method statement(mut cx) {
+        method prepare(mut cx) {
+            let sql = cx.argument::<JsString>(0)?.value();
+            let this = cx.this();
+
+            let _ = cx.borrow(&this, |sqlite| {
+                let conn = (&sqlite.conn).as_ref().unwrap();
+                let _ = conn.prepare(&sql).unwrap();
+            });
+
             Ok(cx.undefined().upcast())
         }
     }
@@ -118,3 +118,18 @@ register_module!(mut m, {
     m.export_function("version", version)?;
     Ok(())
 });
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+    use test::Bencher;
+
+    #[bench]
+    fn bench_create_table_rusqlite(b: &mut Bencher) {
+        b.iter(|| {
+            let conn = Connection::open_in_memory().unwrap();
+            let stmt = conn.prepare("CREATE TABLE lorem (info TEXT)").unwrap();
+            // conn.close().unwrap();
+        });
+    }
+}

package.json

@@ -15,14 +15,13 @@
     "test": "jest ."
   },
   "devDependencies": {
+    "better-sqlite3": "^5.0.1",
     "eslint": "^5.9.0",
     "eslint-config-bliss": "^3.0.0",
-    "jest": "^23.6.0"
+    "jest": "^23.6.0",
+    "sqlite3": "^4.0.4"
   },
   "eslintConfig": {
-    "extends": "bliss",
-    "rules": {
-      "prettier/prettier": ["error", {"singleQuote": true, "parser": "flow"}]
-    }
+    "extends": "bliss"
   }
 }

test/basic.spec.js

@@ -11,7 +11,7 @@ describe('basic', () => {
   it('should execute query statements', async () => {
     const conn = new Sqlite();
 
-    await conn.create({
+    await conn.open({
       verbose: true,
       database: path.join(__dirname, 'test.db')
     });
@@ -38,7 +38,7 @@ describe('basic', () => {
   it('should format errors', async () => {
     const conn = new Sqlite();
 
-    await conn.create({
+    await conn.open({
       verbose: true,
       database: path.join(__dirname, 'test.db')
     });