fix(mysql): fix mysql package

OptimistikSAS · Apr 17, 2023 · cf7391b · cf7391b
1 parent 3d2218c
commit cf7391b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/south/south-sql/south-sql.js b/src/south/south-sql/south-sql.js
@@ -3,7 +3,7 @@ import path from 'node:path'
 
 import db from 'better-sqlite3'
 import mssql from 'mssql'
-import mysql from 'mysql2/promise'
+import { createConnection } from 'mysql2/promise'
 import * as pg from 'pg'
 import { DateTime } from 'luxon'
 import humanizeDuration from 'humanize-duration'
@@ -296,7 +296,7 @@ export default class SouthSQL extends SouthConnector {
     let connection = null
     let data = []
     try {
-      connection = await mysql.createConnection(config)
+      connection = await createConnection(config)
 
       const params = generateReplacementParameters(this.query, startTime, endTime)
       const [rows] = await connection.execute(

diff --git a/src/south/south-sql/south-sql.test.js b/src/south/south-sql/south-sql.test.js
@@ -1,4 +1,4 @@
-import mysql from 'mysql2/promise'
+import { createConnection } from 'mysql2/promise'
 import { Client } from 'pg'
 import mssql from 'mssql'
 
@@ -37,7 +37,7 @@ describe('MySQL Integration test', () => {
   }
 
   beforeAll(async () => {
-    const connection = await mysql.createConnection(mysqlConfig)
+    const connection = await createConnection(mysqlConfig)
     await connection.query('CREATE TABLE IF NOT EXISTS history (temperature double, created_at datetime)')
 
     await connection.query('INSERT INTO history (temperature, created_at) '
@@ -49,7 +49,7 @@ describe('MySQL Integration test', () => {
   })
 
   afterAll(async () => {
-    const connection = await mysql.createConnection(mysqlConfig)
+    const connection = await createConnection(mysqlConfig)
     await connection.query('DROP TABLE history')
     await connection.end()
   })