diff --git a/lib/MySQL/store.d.ts b/lib/MySQL/store.d.ts index c60acb2..31f5120 100644 --- a/lib/MySQL/store.d.ts +++ b/lib/MySQL/store.d.ts @@ -31,6 +31,6 @@ export declare class MysqlStore; rollback(txnId: string): Promise; connect(): void; - disconnect(): void; + disconnect(): Promise; initialize(option: CreateEntityOption): Promise; } diff --git a/lib/MySQL/store.js b/lib/MySQL/store.js index 4caf11e..06450be 100644 --- a/lib/MySQL/store.js +++ b/lib/MySQL/store.js @@ -288,8 +288,8 @@ class MysqlStore extends CascadeStore_1.CascadeStore { connect() { this.connector.connect(); } - disconnect() { - this.connector.disconnect(); + async disconnect() { + await this.connector.disconnect(); } async initialize(option) { const schema = this.getSchema();