feat: mysql connector

.env.example

@@ -1,7 +1,7 @@
 POSTGRESQL_URL=postgresql://<user>:@localhost:5432/db0
+MYSQL_URL=
 
 # PlanetScale
 PLANETSCALE_HOST=aws.connect.psdb.cloud
 PLANETSCALE_USERNAME=username
 PLANETSCALE_PASSWORD=password
-

docs/2.connectors/1.index.md

@@ -13,6 +13,7 @@ Currently supported connectors:
 - [LibSQL](/connectors/libsql)
 - [PlanetScale](/connectors/planetscale)
 - [PostgreSQL](/connectors/postgresql)
+- [MySQL](/connectors/mysql)
 - [SQLite](/connectors/sqlite)
 
 ::read-more{to="https://github.com/unjs/db0/issues/32"}

docs/2.connectors/mysql.md

@@ -4,10 +4,27 @@ icon: simple-icons:mysql
 
 # MySQL
 
-> Connect DB0 to Mysql Database
+> Connect DB0 to Mysql Database using mysql2
 
-:read-more{to="https://github.com/sidorares/node-mysql2"}
+## Usage
 
-::read-more{to="https://github.com/unjs/db0/issues/32"}
-This connector is planned to be supported. Follow up via [unjs/db0#32](https://github.com/unjs/db0/issues/32).
-::
+For this connector, you need to install [`mysql2`](https://www.npmjs.com/package/mysql2) dependency:
+
+:pm-install{name="mysql2"}
+
+Use `mysql2` connector:
+
+```js
+import { createDatabase, sql } from "db0";
+import mysql from "db0/connectors/mysql2";
+
+const db = createDatabase(
+  mysql({
+    /* options */
+  }),
+);
+```
+
+## Options
+
+:read-more{to="https://github.com/sidorares/node-mysql2/blob/master/typings/mysql/lib/Connection.d.ts#L82-L329"}

src/connectors/mysql2.ts

@@ -0,0 +1,48 @@
+import mysql from "mysql2/promise";
+
+import type { Connector, Statement } from "../types";
+
+export default function mysqlConnector(opts: mysql.ConnectionOptions) {
+  let _connection: mysql.Connection | undefined;
+  const getConnection = async () => {
+    if (_connection) {
+      return _connection;
+    }
+
+    _connection = await mysql.createConnection({
+      ...opts,
+    })
+
+    return _connection;
+  };
+
+  return <Connector>{
+    name: "mysql",
+    dialect: "mysql",
+    exec(sql: string) {
+      return getConnection().then((c) => c.query(sql).then((res) => res[0]));
+    },
+    prepare(sql: string) {
+      const stmt = <Statement>{
+        _sql: sql,
+        _params: [],
+        bind(...params) {
+          if (params.length > 0) {
+            this._params = params;
+          }
+          return stmt;
+        },
+        all(...params) {
+          return getConnection().then((c) => c.query(this._sql, params || this._params).then((res) => res[0]));
+        },
+        run(...params) {
+          return getConnection().then((c) => c.query(this._sql, params || this._params).then((res) => res[0]));
+        },
+        get(...params) {
+          return getConnection().then((c) => c.query(this._sql, params || this._params).then((res) => res[0][0]));
+        },
+      };
+      return stmt;
+    },
+  };
+}

test/connectors/mysql2.test.ts

@@ -0,0 +1,18 @@
+import { describe } from "vitest";
+import connector from "../../src/connectors/mysql2";
+import { testConnector } from "./_tests";
+
+describe.runIf(process.env.MYSQL_URL)(
+  "connectors: mysql2.test",
+  () => {
+    testConnector({
+      dialect: "mysql",
+      connector: connector({
+        host: "localhost",
+        user: "root",
+        password: "root",
+        database: "db0",
+      }),
+    });
+  },
+);