fix: 옵션명 변경

croquiscom · Apr 15, 2024 · 21ad465 · 21ad465
1 parent 25724a1
commit 21ad465
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git a/packages/cormo/lib/adapters/mysql.d.ts b/packages/cormo/lib/adapters/mysql.d.ts
@@ -14,7 +14,7 @@ export interface AdapterSettingsMySQL {
     collation?: string;
     pool_size?: number;
     query_timeout?: number;
-    idle_timeout?: number;
+    max_lifetime?: number;
     replication?: {
         use_master_for_read?: boolean;
         read_replicas: Array<{

diff --git a/packages/cormo/lib/adapters/mysql.js b/packages/cormo/lib/adapters/mysql.js
@@ -795,7 +795,7 @@ class MySQLAdapter extends sql_base_1.SQLAdapterBase {
         this._client._node_id = 'MASTER';
         this._client.queryAsync = util_1.default.promisify(this._client.query);
         this._client.getConnectionAsync = util_1.default.promisify(this._client.getConnection);
-        this._setEvent(this._client, settings.idle_timeout);
+        this._setEvent(this._client, settings.max_lifetime);
         if (settings.replication) {
             this._read_clients = [];
             if (settings.replication.use_master_for_read) {
@@ -817,7 +817,7 @@ class MySQLAdapter extends sql_base_1.SQLAdapterBase {
                 read_client._node_id = `SLAVE${i + 1}`;
                 read_client.queryAsync = util_1.default.promisify(read_client.query);
                 read_client.getConnectionAsync = util_1.default.promisify(read_client.getConnection);
-                this._setEvent(read_client, settings.idle_timeout);
+                this._setEvent(read_client, settings.max_lifetime);
                 this._read_clients.push(read_client);
             }
         }
@@ -1281,15 +1281,15 @@ class MySQLAdapter extends sql_base_1.SQLAdapterBase {
         return MySQLAdapter.wrapError(msg, cause);
     }
     /** @internal */
-    _setEvent(client, idle_timeout) {
-        if (!idle_timeout || idle_timeout < 0) {
+    _setEvent(client, max_lifetime) {
+        if (!max_lifetime || max_lifetime < 0) {
             return;
         }
         client.on('connection', (connection) => {
             connection._connected_ts = Date.now();
         });
         client.on('release', (connection) => {
-            if (Date.now() - connection._connected_ts >= idle_timeout) {
+            if (Date.now() - connection._connected_ts >= max_lifetime) {
                 connection.destroy();
             }
         });

diff --git a/packages/cormo/src/adapters/mysql.ts b/packages/cormo/src/adapters/mysql.ts
@@ -43,7 +43,7 @@ export interface AdapterSettingsMySQL {
   collation?: string;
   pool_size?: number;
   query_timeout?: number;
-  idle_timeout?: number;
+  max_lifetime?: number;
   replication?: {
     use_master_for_read?: boolean;
     read_replicas: Array<{
@@ -873,7 +873,7 @@ export class MySQLAdapter extends SQLAdapterBase {
     this._client._node_id = 'MASTER';
     this._client.queryAsync = util.promisify(this._client.query);
     this._client.getConnectionAsync = util.promisify(this._client.getConnection);
-    this._setEvent(this._client, settings.idle_timeout);
+    this._setEvent(this._client, settings.max_lifetime);
 
     if (settings.replication) {
       this._read_clients = [];
@@ -896,7 +896,7 @@ export class MySQLAdapter extends SQLAdapterBase {
         read_client._node_id = `SLAVE${i + 1}`;
         read_client.queryAsync = util.promisify(read_client.query);
         read_client.getConnectionAsync = util.promisify(read_client.getConnection);
-        this._setEvent(read_client, settings.idle_timeout);
+        this._setEvent(read_client, settings.max_lifetime);
         this._read_clients.push(read_client);
       }
     }
@@ -1379,15 +1379,15 @@ export class MySQLAdapter extends SQLAdapterBase {
   }
 
   /** @internal */
-  private _setEvent(client: any, idle_timeout?: number) {
-    if (!idle_timeout || idle_timeout < 0) {
+  private _setEvent(client: any, max_lifetime?: number) {
+    if (!max_lifetime || max_lifetime < 0) {
       return;
     }
     client.on('connection', (connection: any) => {
       connection._connected_ts = Date.now();
     });
     client.on('release', (connection: any) => {
-      if (Date.now() - connection._connected_ts >= idle_timeout) {
+      if (Date.now() - connection._connected_ts >= max_lifetime) {
         connection.destroy();
       }
     });