1 | import mysql from "mysql2/promise"; |
2 |
|
3 | type Mysql = { |
4 | host: string; |
5 | port: number; |
6 | user: string; |
7 | database: string; |
8 | password: string; |
9 | ssl: boolean; |
10 | }; |
11 | export async function main(mysql_conn: Mysql, query: string) { |
12 | const conn = await mysql.createConnection({ |
13 | host: mysql_conn.host, |
14 | port: mysql_conn.port, |
15 | user: mysql_conn.user, |
16 | database: mysql_conn.database, |
17 | password: mysql_conn.password, |
18 | ssl: mysql_conn.ssl ? {} : undefined, |
19 | }); |
20 |
|
21 | const [rows] = await conn.query(query); |
22 | await conn.end(); |
23 | return rows; |
24 | } |
25 |
|