Change executeSql definition to fail when status equals 1

Author: Oscar Franco

example/src/App.tsx

@@ -17,8 +17,8 @@ import {
   testTransaction,
   typeORMGetBooks,
   typeORMInit,
+  executeFailingTypeORMQuery,
 } from './Database';
-// import { typeORMInit } from './Database';
 import type { User } from './model/User';
 import { Buffer } from 'buffer';
 
@@ -30,11 +30,9 @@ export default function App() {
     // const users = queryUsers();
     // setUsers(users);
     typeORMInit().then(() => {
-      console.warn('db initialized');
       typeORMGetBooks().then((books) => {
-        console.warn('typeORM books', books);
-        
-      })
+        // console.warn('typeORM books', books);
+      });
     });
   }, []);
 
@@ -62,6 +60,10 @@ export default function App() {
           testTransaction();
         }}
       />
+      <Button
+        title="Execute typeORM failing query"
+        onPress={executeFailingTypeORMQuery}
+      />
       <FlatList
         data={users}
         renderItem={({ item }: ListRenderItemInfo<User>) => {

example/src/Database.ts

@@ -4,7 +4,7 @@ import { DataSource } from 'typeorm';
 import { Book } from './model/Book';
 import { User } from './model/User';
 // import { Buffer } from 'buffer';
-let datasource: DataSource
+let datasource: DataSource;
 
 export const lowLevelInit = () => {
   // Start by opening a connection
@@ -86,11 +86,10 @@ export async function typeORMInit() {
     database: 'test2',
     location: '.',
     entities: [Book],
-    synchronize: true
+    synchronize: true,
   });
 
-  await datasource.initialize()
-
+  await datasource.initialize();
 
   // await createConnection({
   //   type: 'react-native',
@@ -129,5 +128,17 @@ export async function typeORMInit() {
 
 export async function typeORMGetBooks() {
   const bookRepository = datasource.getRepository(Book);
-  return await bookRepository.find()
-}
+  return await bookRepository.find();
+}
+
+export async function executeFailingTypeORMQuery() {
+  const bookRepository = datasource.getRepository(Book);
+
+  try {
+    const manualQuery = await bookRepository.query(`
+          SELECT * From UnexistingTable
+        `);
+  } catch (e) {
+    console.warn('should have cached');
+  }
+}

src/index.ts

@@ -359,7 +359,12 @@ export const openDatabase = (
         try {
           let response = sqlite.executeSql(options.name, sql, params);
           enhanceQueryResult(response);
-          ok(response);
+
+          if (response.status === 1) {
+            fail(response.message);
+          } else {
+            ok(response);
+          }
         } catch (e) {
           fail(e);
         }