sqlitestorage桥接鸿蒙方式及鸿蒙原生方法重写

Author: quweifan

NativeSQLitePlugin.ts

@@ -2,13 +2,19 @@ import type {TurboModule } from 'react-native/Libraries/TurboModule/RCTExport';
 import {TurboModuleRegistry} from 'react-native';
 
 export interface Spec extends TurboModule {
-  DEBUG(isDebug: boolean): void;
-  enablePromise(enablePromise: boolean): void;
-  openDatabase(dbname:string,dbVersion:string,dbDisplayname:string,dbSize:number,success?: () => void,error?: (e: Object) => void,): Object;
-  deleteDatabase(dbname: string, success?: () => void, error?: (err: Object) => void): void;
-  executeSql(store:Object,statement: string, params?: any[], success?: (s?: Object) => void, error?: (e: Object) => void): Promise<void>;
-  // transaction(scope: (tx: Transaction) => void,error?: (e: Object) => void,success?: () => void,): void;
-  close(store:Object,success: () => void, error: (err: Object) => void): void;
+  
+  open(openargs:Object,opensuccesscb:() => void,openerrorcb:(e:Object) => void):void;
+
+  close(closeargs:Object,mysuccess:(t:Object,r:Object) => void,myerror:(e:Object) => void):void;
+
+  attach(attachargs:Object,mysuccess:(t:Object,r:Object) => void,myerror:(e:Object) => void):void;
+
+  backgroundExecuteSqlBatch(args:Object,mysuccess:(result:Object) => void,myerror:(e:Object) => void):void;
+
+  echoStringValue(openargs:Object,mysuccess:(testValue:Object) => void,myerror:(e:Object) => void):void;
+
+  delete(args:Object,mysuccess:(r:Object) => void,myerror:(e:Object) => void):void;
+
 }
 
 export default TurboModuleRegistry.getEnforcing<Spec>('SQLitePlugin');

lib/sqlite.core.js

@@ -13,7 +13,8 @@
  * See http://opensource.org/licenses/alphabetical for full text.
  */
 
-var NativeModules = require("react-native").NativeModules;
+// var NativeModules = require("react-native").NativeModules;
+import NativeModules from '../NativeSQLitePlugin'
 var DB_STATE_INIT, DB_STATE_OPEN, READ_ONLY_REGEX, SQLiteFactory, SQLitePlugin, SQLitePluginTransaction, argsArray, dblocations, newSQLError, txLocks;
 
 var plugin = {};
@@ -86,7 +87,20 @@ plugin.exec = function(method, options, success, error) {
   if (plugin.sqlitePlugin.DEBUG){
     plugin.log("SQLite." + method + "(" + JSON.stringify(options) + ")");
   }
-  NativeModules["SQLite"][method](options,success,error);
+  // NativeModules["SQLite"][method](options,success,error);     
+  if(method=='open'){
+    NativeModules.open(options,success,error);
+  }else if(method=='close'){
+    NativeModules.close(options,success,error);
+  }else if(method=='attach'){
+    NativeModules.attach(options,success,error);
+  }else if(method=='backgroundExecuteSqlBatch'){
+    NativeModules.backgroundExecuteSqlBatch(options,success,error);
+  }else if(method=='echoStringValue'){
+    NativeModules.echoStringValue(options,success,error);
+  }else if(method=='delete'){
+    NativeModules.delete(options,success,error);
+  }
 };
 
 plugin.log = function(...messages) {