push

Author: quangta99

package.json

@@ -64,4 +64,4 @@
       "react-app"
     ]
   }
-}
+}

src/App.tsx

@@ -73,7 +73,7 @@ function App() {
         status: false
       },
       {
-        userId: '6',
+        userId: '7',
         name: '7',
         email: '7',
         status: false

src/services/SqliteMobile/SqliteMobile.ts

@@ -1,5 +1,5 @@
-import {Attribute, Attributes, Manager, Statement, StringMap} from './metadata';
-import {buildToSave, buildToSaveBatch} from './build';
+import { Attribute, Attributes, Manager, Statement, StringMap } from './metadata';
+import { buildToSave, buildToSaveBatch } from './build';
 
 export class DatabaseManager implements Manager {
   constructor(public database: any) {
@@ -13,8 +13,8 @@ export class DatabaseManager implements Manager {
   exec(sql: string, args?: any[]): Promise<number> {
     return exec(this.database, sql, args);
   }
-  execBatch(statements: Statement[]): Promise<number> {
-    return execBatch(this.database, statements);
+  execBatch(statements: Statement[], firstSuccess?: boolean): Promise<number> {
+    return execBatch(this.database, statements, firstSuccess);
   }
   query<T>(sql: string, args?: any[], m?: StringMap, fields?: Attribute[]): Promise<T[]> {
     return query(this.database, sql, args, m, fields);
@@ -31,71 +31,158 @@ export class DatabaseManager implements Manager {
 }
 
 export function execute(db: any, sql: string): Promise<void> {
-  return new Promise<void>((resolve, reject) => {
-    return db.transaction(txn => {
-      txn.executeSql(sql, [], () => {
+  if (db.executeSql) {
+    return new Promise<void>((resolve, reject) => {
+      db.executeSql(sql, [], () => {
         return resolve();
       }, (err: any) => {
         return reject(err);
       });
     });
-  });
+  } else {
+    return new Promise<void>((resolve, reject) => {
+      return db.transaction(txn => {
+        txn.executeSql(sql, [], () => {
+          return resolve();
+        });
+      }, (err: any) => {
+        return reject(err);
+      });
+    });
+  }
+}
+export function execBatch(db: any, statements: Statement[], firstSuccess?: boolean): Promise<number> {
+  if (!statements || statements.length === 0) {
+    return Promise.resolve(0);
+  } else if (statements.length === 1) {
+    return exec(db, statements[0].query, statements[0].params);
+  }
+  if (firstSuccess) {
+    return new Promise<number>((resolve, reject) => {
+      return db.transaction(txn => {
+        return txn.executeSql(statements[0].query, statements[0].params, (tx, result) => {
+          if (result && result.rowsAffected > 0) {
+            let listStatements = statements.slice(1);
+            listStatements.forEach(item => {
+              txn.executeSql(item.query, toArray(item.params));
+            });
+          }
+        }, (err: any) => {
+          return reject(err);
+        });
+      }, (e: any) => {
+        reject(e);
+      }, () => {
+        resolve(1);
+      });
+    });
+  } else {
+    return new Promise<number>((resolve, reject) => {
+      return db.transaction(txn => {
+        statements.forEach(item => {
+          txn.executeSql(item.query, toArray(item.params));
+        })
+      }, (e: any) => {
+        console.log(e);
+        reject(e);
+      }, () => {
+        resolve(1);
+      });
+    });
+  }
 }
-export function execBatch(db: any, statements: Statement[]): Promise<number> {
+export function getTransaction(db: any): Promise<any> {
   return new Promise<number>((resolve, reject) => {
     return db.transaction(txn => {
-      statements.forEach(item => {
-        txn.executeSql(item.query, toArray(item.params));
-      })
-    }, (e: any) => {
-      console.log(e);
-      reject(e);
-    }, () => {
-      resolve(1);
+      return resolve(txn);
     });
   });
 }
+/**
+ * 
+ * @param db can be db or transaction
+ * @param sql 
+ * @param args 
+ */
 export function exec(db: any, sql: string, args?: any[]): Promise<number> {
-  const p = args ? toArray(args) : [];
-  console.log({p});
-  return new Promise<number>((resolve, reject) => {
-    return db.transaction(txn => {
-      txn.executeSql(sql, p, () => {
-        return resolve(1);
-      }, (err: any) => {
-        console.log({ err });
-        return reject(0);
+  const p = toArray(args);
+  if (db.executeSql) {
+    return new Promise<number>((resolve, reject) => {
+      db.executeSql(sql, p, (tx, result) => {
+        if (result && result.rowsAffected > 0) {
+          return resolve(1);
+        } else if (!result) {
+          return reject(0);
+        }
       });
     });
-  });
+  } else {
+    console.log('db does not have executeSql fuction');
+    return new Promise<number>((resolve, reject) => {
+      return db.transaction(txn => {
+        txn.executeSql(sql, p, (tx, result) => {
+          if (result && result.rowsAffected > 0) {
+            return resolve(1);
+          }
+        });
+      }, (e: any) => {
+        console.log(e);
+        reject(e);
+      }, () => {
+        resolve(1);
+      });
+    });
+  }
 }
 export function query<T>(db: any, sql: string, args?: any[], m?: StringMap, bools?: Attribute[]): Promise<T[]> {
   const p = args ? args : [];
-  return new Promise<T[]>((resolve, reject) => {
-    return db.transaction(txn => {
-      txn.executeSql(sql, p, (tx, results: any) => {
+  console.log(db);
+  if (db.executeSql) {
+    return new Promise<T[]>((resolve, reject) => {
+      db.executeSql(sql, p, (tx, results: any) => {
         return resolve(handleResults<T>(results.rows._array, m, bools));
       });
-    }, (err: any) => {
-      reject(err);
     });
-  });
+  } else {
+    return new Promise<T[]>((resolve, reject) => {
+      return db.transaction(txn => {
+        txn.executeSql(sql, p, (tx, results: any) => {
+          return resolve(handleResults<T>(results.rows._array, m, bools));
+        });
+      }, (err: any) => {
+        reject(err);
+      });
+    });
+  }
 }
 export function queryOne<T>(db: any, sql: string, args?: any[], m?: StringMap, bools?: Attribute[]): Promise<T> {
   const p = args ? args : [];
-  return new Promise<T>((resolve, reject) => {
-    return db.transaction(txn => {
-      txn.executeSql(sql, p, (tx, result: any) => {
+  if (db.executeSql) {
+    return new Promise<T>((resolve, reject) => {
+      db.executeSql(sql, p, (tx, result: any) => {
         if (result.rows && result.rows._array && result.rows.length > 0) {
-          return resolve(handleResult<T>(result.rows._array, m, bools));  
+          return resolve(handleResult<T>(result.rows._array, m, bools));
         } else {
           return resolve(null);
         }
       });
-    }, (err: any) => {
-      reject(err);
     });
-  });
+  } else {
+    return new Promise<T>((resolve, reject) => {
+      return db.transaction(txn => {
+        txn.executeSql(sql, p, (tx, result: any) => {
+          console.log({ tx }, { result });
+          if (result.rows && result.rows._array && result.rows.length > 0) {
+            return resolve(handleResult<T>(result.rows._array, m, bools));
+          } else {
+            return resolve(null);
+          }
+        });
+      }, (err: any) => {
+        reject(err);
+      });
+    });
+  }
 }
 export function execScalar<T>(db: any, sql: string, args?: any[]): Promise<T> {
   return queryOne<T>(db, sql, args).then(r => {

src/services/SqliteMobile/metadata.ts

@@ -8,7 +8,7 @@ export interface Statement {
 
 export interface Manager {
   exec(sql: string, args?: any[]): Promise<number>;
-  execBatch(statements: Statement[]): Promise<number>;
+  execBatch(statements: Statement[], firstSuccess?: boolean): Promise<number>;
   query<T>(sql: string, args?: any[], m?: StringMap, bools?: Attribute[]): Promise<T[]>;
   queryOne<T>(sql: string, args?: any[], m?: StringMap, bools?: Attribute[]): Promise<T>;
   execScalar<T>(sql: string, args?: any[]): Promise<T>;

src/sqlite-hook.ts

@@ -5,15 +5,15 @@ import { DatabaseManager } from "./services/SqliteMobile/SqliteMobile";
 
 export const useSqlite = () => {
   // @ts-ignore: Unreachable code error
-  const database = window.sqlitePlugin.openDatabase('database.db','1.0', 'user database', 1000000);
+  const database = window.sqlitePlugin.openDatabase('database.db', '1.0', 'user database', 1000000);
   const [users, setUser] = useState<User[]>([]);
   const sqliteUser = new DatabaseManager(database);
 
   useEffect(() => {
-      (() => {
-        // deleteTable();
-        initTable();
-      })();
+    (() => {
+      // deleteTable();
+      initTable();
+    })();
   }, []);
 
   const initTable = () => {
@@ -46,7 +46,7 @@ export const useSqlite = () => {
 
   const insert = (user: User) => {
     const string = 'INSERT INTO users (userId, name, email, status) VALUES (?,?,?,?)';
-    const args =[user.userId, user.name, user.email, user.status];
+    const args = [user.userId, user.name, user.email, user.status];
     sqliteUser.exec(string, args).then(() => {
       alert('Insert Success!');
     }).catch(() => alert('Insert Failed!'));
@@ -72,13 +72,12 @@ export const useSqlite = () => {
 
   const insertMany = (users: User[]) => {
     const statements: Statement[] = users.map((item) => {
-      return { query: 'INSERT INTO users (userId, name, email, status) VALUES (?,?,?,?)', params: [item.userId, item.name, item.email, item.status]};
+      return { query: 'INSERT INTO users (userId, name, email, status) VALUES (?,?,?,?)', params: [item.userId, item.name, item.email, item.status] };
     });
-    return sqliteUser.execBatch(statements).then(() => {
-      console.log({statements});
+    return sqliteUser.execBatch(statements, true).then(() => {
       alert('Success!');
     }).catch(() => alert('Rollback!'));
   }
 
-  return {database, all, insert, users, deleteUser, load, update, insertMany};
+  return { database, all, insert, users, deleteUser, load, update, insertMany };
 };

www/asset-manifest.json

@@ -1,8 +1,8 @@
 {
   "files": {
     "main.css": "./static/css/main.48c09e40.chunk.css",
-    "main.js": "./static/js/main.be3b3e98.chunk.js",
-    "main.js.map": "./static/js/main.be3b3e98.chunk.js.map",
+    "main.js": "./static/js/main.44f580df.chunk.js",
+    "main.js.map": "./static/js/main.44f580df.chunk.js.map",
     "runtime-main.js": "./static/js/runtime-main.8b1a174c.js",
     "runtime-main.js.map": "./static/js/runtime-main.8b1a174c.js.map",
     "static/js/2.d470b951.chunk.js": "./static/js/2.d470b951.chunk.js",
@@ -18,6 +18,6 @@
     "static/js/runtime-main.8b1a174c.js",
     "static/js/2.d470b951.chunk.js",
     "static/css/main.48c09e40.chunk.css",
-    "static/js/main.be3b3e98.chunk.js"
+    "static/js/main.44f580df.chunk.js"
   ]
 }

www/index.html

@@ -1 +1 @@
-<!doctype html><html lang="en"><head><meta charset="utf-8"/><link rel="icon" href="./favicon.ico"/><meta name="viewport" content="width=device-width,initial-scale=1"/><meta name="theme-color" content="#000000"/><meta name="description" content="Web site created using create-react-app"/><meta name="format-detection" content="telephone=no"><meta name="msapplication-tap-highlight" content="no"><meta name="viewport" content="initial-scale=1,width=device-width,viewport-fit=cover,maximum-scale=1"><link rel="apple-touch-icon" href="./logo192.png"/><link rel="manifest" href="./manifest.json"/><title>React App</title><link href="./static/css/main.48c09e40.chunk.css" rel="stylesheet"></head><body><noscript>You need to enable JavaScript to run this app.</noscript><div id="root"></div><script src="cordova.js" type="text/javascript"></script><script>!function(e){function r(r){for(var n,a,i=r[0],c=r[1],l=r[2],s=0,p=[];s<i.length;s++)a=i[s],Object.prototype.hasOwnProperty.call(o,a)&&o[a]&&p.push(o[a][0]),o[a]=0;for(n in c)Object.prototype.hasOwnProperty.call(c,n)&&(e[n]=c[n]);for(f&&f(r);p.length;)p.shift()();return u.push.apply(u,l||[]),t()}function t(){for(var e,r=0;r<u.length;r++){for(var t=u[r],n=!0,i=1;i<t.length;i++){var c=t[i];0!==o[c]&&(n=!1)}n&&(u.splice(r--,1),e=a(a.s=t[0]))}return e}var n={},o={1:0},u=[];function a(r){if(n[r])return n[r].exports;var t=n[r]={i:r,l:!1,exports:{}};return e[r].call(t.exports,t,t.exports,a),t.l=!0,t.exports}a.e=function(e){var r=[],t=o[e];if(0!==t)if(t)r.push(t[2]);else{var n=new Promise((function(r,n){t=o[e]=[r,n]}));r.push(t[2]=n);var u,i=document.createElement("script");i.charset="utf-8",i.timeout=120,a.nc&&i.setAttribute("nonce",a.nc),i.src=function(e){return a.p+"static/js/"+({}[e]||e)+"."+{3:"4acb901f"}[e]+".chunk.js"}(e);var c=new Error;u=function(r){i.onerror=i.onload=null,clearTimeout(l);var t=o[e];if(0!==t){if(t){var n=r&&("load"===r.type?"missing":r.type),u=r&&r.target&&r.target.src;c.message="Loading chunk "+e+" failed.\n("+n+": "+u+")",c.name="ChunkLoadError",c.type=n,c.request=u,t[1](c)}o[e]=void 0}};var l=setTimeout((function(){u({type:"timeout",target:i})}),12e4);i.onerror=i.onload=u,document.head.appendChild(i)}return Promise.all(r)},a.m=e,a.c=n,a.d=function(e,r,t){a.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},a.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},a.t=function(e,r){if(1&r&&(e=a(e)),8&r)return e;if(4&r&&"object"==typeof e&&e&&e.__esModule)return e;var t=Object.create(null);if(a.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:e}),2&r&&"string"!=typeof e)for(var n in e)a.d(t,n,function(r){return e[r]}.bind(null,n));return t},a.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return a.d(r,"a",r),r},a.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},a.p="./",a.oe=function(e){throw console.error(e),e};var i=this["webpackJsonpio.cordova.hellocordova"]=this["webpackJsonpio.cordova.hellocordova"]||[],c=i.push.bind(i);i.push=r,i=i.slice();for(var l=0;l<i.length;l++)r(i[l]);var f=c;t()}([])</script><script src="./static/js/2.d470b951.chunk.js"></script><script src="./static/js/main.be3b3e98.chunk.js"></script></body></html>
+<!doctype html><html lang="en"><head><meta charset="utf-8"/><link rel="icon" href="./favicon.ico"/><meta name="viewport" content="width=device-width,initial-scale=1"/><meta name="theme-color" content="#000000"/><meta name="description" content="Web site created using create-react-app"/><meta name="format-detection" content="telephone=no"><meta name="msapplication-tap-highlight" content="no"><meta name="viewport" content="initial-scale=1,width=device-width,viewport-fit=cover,maximum-scale=1"><link rel="apple-touch-icon" href="./logo192.png"/><link rel="manifest" href="./manifest.json"/><title>React App</title><link href="./static/css/main.48c09e40.chunk.css" rel="stylesheet"></head><body><noscript>You need to enable JavaScript to run this app.</noscript><div id="root"></div><script src="cordova.js" type="text/javascript"></script><script>!function(e){function r(r){for(var n,a,i=r[0],c=r[1],l=r[2],s=0,p=[];s<i.length;s++)a=i[s],Object.prototype.hasOwnProperty.call(o,a)&&o[a]&&p.push(o[a][0]),o[a]=0;for(n in c)Object.prototype.hasOwnProperty.call(c,n)&&(e[n]=c[n]);for(f&&f(r);p.length;)p.shift()();return u.push.apply(u,l||[]),t()}function t(){for(var e,r=0;r<u.length;r++){for(var t=u[r],n=!0,i=1;i<t.length;i++){var c=t[i];0!==o[c]&&(n=!1)}n&&(u.splice(r--,1),e=a(a.s=t[0]))}return e}var n={},o={1:0},u=[];function a(r){if(n[r])return n[r].exports;var t=n[r]={i:r,l:!1,exports:{}};return e[r].call(t.exports,t,t.exports,a),t.l=!0,t.exports}a.e=function(e){var r=[],t=o[e];if(0!==t)if(t)r.push(t[2]);else{var n=new Promise((function(r,n){t=o[e]=[r,n]}));r.push(t[2]=n);var u,i=document.createElement("script");i.charset="utf-8",i.timeout=120,a.nc&&i.setAttribute("nonce",a.nc),i.src=function(e){return a.p+"static/js/"+({}[e]||e)+"."+{3:"4acb901f"}[e]+".chunk.js"}(e);var c=new Error;u=function(r){i.onerror=i.onload=null,clearTimeout(l);var t=o[e];if(0!==t){if(t){var n=r&&("load"===r.type?"missing":r.type),u=r&&r.target&&r.target.src;c.message="Loading chunk "+e+" failed.\n("+n+": "+u+")",c.name="ChunkLoadError",c.type=n,c.request=u,t[1](c)}o[e]=void 0}};var l=setTimeout((function(){u({type:"timeout",target:i})}),12e4);i.onerror=i.onload=u,document.head.appendChild(i)}return Promise.all(r)},a.m=e,a.c=n,a.d=function(e,r,t){a.o(e,r)||Object.defineProperty(e,r,{enumerable:!0,get:t})},a.r=function(e){"undefined"!=typeof Symbol&&Symbol.toStringTag&&Object.defineProperty(e,Symbol.toStringTag,{value:"Module"}),Object.defineProperty(e,"__esModule",{value:!0})},a.t=function(e,r){if(1&r&&(e=a(e)),8&r)return e;if(4&r&&"object"==typeof e&&e&&e.__esModule)return e;var t=Object.create(null);if(a.r(t),Object.defineProperty(t,"default",{enumerable:!0,value:e}),2&r&&"string"!=typeof e)for(var n in e)a.d(t,n,function(r){return e[r]}.bind(null,n));return t},a.n=function(e){var r=e&&e.__esModule?function(){return e.default}:function(){return e};return a.d(r,"a",r),r},a.o=function(e,r){return Object.prototype.hasOwnProperty.call(e,r)},a.p="./",a.oe=function(e){throw console.error(e),e};var i=this["webpackJsonpio.cordova.hellocordova"]=this["webpackJsonpio.cordova.hellocordova"]||[],c=i.push.bind(i);i.push=r,i=i.slice();for(var l=0;l<i.length;l++)r(i[l]);var f=c;t()}([])</script><script src="./static/js/2.d470b951.chunk.js"></script><script src="./static/js/main.44f580df.chunk.js"></script></body></html>