@@ -2,28 +2,29 @@ import { DatabaseConfig } from "../definitions/database-config";
2
2
import { DatabaseBaseTransaction , DatabaseResult } from "../definitions/database-definition" ;
3
3
import { BaseDatabaseAdapter } from "./base-database.adapter" ;
4
4
import { WebSqlTransactionInterface } from "../definitions/websql-interface" ;
5
+ import { SQLiteObjectInterface } from "../definitions" ;
5
6
6
- export abstract class DatabaseAbstractSQLiteService extends BaseDatabaseAdapter < DatabaseSQLiteObject > {
7
+ export abstract class DatabaseAbstractSQLiteService extends BaseDatabaseAdapter < SQLiteObjectInterface > {
7
8
8
9
protected abstract sqliteCreate ( config : DatabaseConfig )
9
- : Promise < DatabaseSQLiteObject > ;
10
+ : Promise < SQLiteObjectInterface > ;
10
11
11
12
protected createDatabaseNative (
12
13
config : DatabaseConfig
13
- ) : Promise < DatabaseSQLiteObject > {
14
+ ) : Promise < SQLiteObjectInterface > {
14
15
return this . sqliteCreate ( config ) ;
15
16
}
16
17
17
18
protected convertToExecuteSql (
18
- databaseNative : DatabaseSQLiteObject
19
+ databaseNative : SQLiteObjectInterface
19
20
) : ( sql : string , values : any ) => Promise < DatabaseResult > {
20
21
return ( statement : string , params : any ) : Promise < DatabaseResult > => {
21
22
return databaseNative . executeSql ( statement , params ) ;
22
23
} ;
23
24
}
24
25
25
26
protected convertToTransaction (
26
- databaseNative : DatabaseSQLiteObject
27
+ databaseNative : SQLiteObjectInterface
27
28
) : ( fn : ( transaction : WebSqlTransactionInterface ) => void ) => Promise < any > {
28
29
return ( fn : ( transaction : DatabaseBaseTransaction ) => void ) : Promise < any > => {
29
30
return databaseNative . transaction ( transaction => {
@@ -45,76 +46,10 @@ export abstract class DatabaseAbstractSQLiteService extends BaseDatabaseAdapter<
45
46
}
46
47
47
48
protected convertToSqlBatch (
48
- databaseNative : DatabaseSQLiteObject
49
+ databaseNative : SQLiteObjectInterface
49
50
) : ( sqlStatements : any [ ] ) => Promise < DatabaseResult [ ] > {
50
51
return ( sqlStatements : Array < ( string | string [ ] | any ) > ) : Promise < DatabaseResult [ ] > => {
51
52
return databaseNative . sqlBatch ( sqlStatements ) ;
52
53
} ;
53
54
}
54
-
55
- protected async getSQLiteVersion ( databaseNative : DatabaseSQLiteObject ) : Promise < string > {
56
- const result = await databaseNative . executeSql ( "select sqlite_version()" , [ ] ) ;
57
- return result . rows . item ( 0 ) ;
58
- }
59
-
60
- protected getLimitVariables ( _databaseNative : DatabaseSQLiteObject ) : Promise < number > {
61
- return Promise . resolve ( 10000 ) ;
62
- }
63
-
64
- // public create(config: DatabaseConfig): Promise<DatabaseObject> {
65
- // return new Promise<DatabaseObject>((resolve, reject) => {
66
- // return this.sqliteCreate(config)
67
- // .then((databaseNative: DatabaseSQLiteObject) => {
68
- // resolve(
69
- // this.injectManagedTransactionInDatabase(
70
- // {
71
- // executeSql: (statement: string, params: any): Promise<DatabaseResult> => {
72
- // return databaseNative.executeSql(statement, params);
73
- // },
74
- // transaction: (fn: (transaction: DatabaseBaseTransaction) => void): Promise<any> => {
75
- // return databaseNative.transaction(transiction => {
76
- // fn({
77
- // executeSql: (sql: string, values: any): Promise<DatabaseResult> => {
78
- // return new Promise<DatabaseResult>((executeSqlResolve, executeSqlReject) => {
79
- // transiction.executeSql(sql, Array.isArray(values) ? values : [],
80
- // (_s: any, r: DatabaseResult | PromiseLike<DatabaseResult>) => {
81
- // executeSqlResolve(r);
82
- // },
83
- // (_r: any, err: any) => {
84
- // executeSqlReject(err);
85
- // });
86
- // });
87
- // }
88
- // });
89
- // });
90
- // },
91
- // sqlBatch: (sqlStatements: Array<(string | string[] | any)>): Promise<DatabaseResult[]> => {
92
- // return databaseNative.sqlBatch(sqlStatements);
93
- // }
94
- // } as DatabaseObject)
95
- // );
96
- // })
97
- // .catch(err => reject(err));
98
- // });
99
- // }
100
- }
101
-
102
- /**
103
- * @hidden
104
- */
105
- export interface DatabaseSQLiteObject {
106
- transaction ( fn : ( transaction : DatabaseSQLiteTransaction ) => void ) : Promise < any > ;
107
- executeSql ( statement : string , params : any ) : Promise < DatabaseResult > ;
108
- /**
109
- * @param sqlStatements {string[] | string[][] | any[]}
110
- * @returns {Promise<any> }
111
- */
112
- sqlBatch ( sqlStatements : Array < ( string | string [ ] | any ) > ) : Promise < any > ;
113
- }
114
-
115
- /**
116
- * @hidden
117
- */
118
- export interface DatabaseSQLiteTransaction {
119
- executeSql : ( sql : any , values ?: any [ ] , success ?: Function , error ?: Function ) => void ;
120
55
}
0 commit comments