async query(sql: string, params?: any, options?: any): Promise<any> {
return new Promise((resolve, reject) => {
const connector = this.dataSource.connector!;
connector.execute!(sql, params, options, (err: any, ...results: any) => {
if (err) {
return reject(err);
}
if (results.length === 0) {
return resolve([]);
}
if (results.length === 1) {
return resolve(results[0]);
}
resolve(results);
});
});
}