add execlastid implementation for mysql

Author: yshrsmz

examples/authors/mysql/query.sql

@@ -10,7 +10,14 @@ ORDER BY name;
 INSERT INTO authors (
   name, bio
 ) VALUES (
-  ?, ? 
+  ?, ?
+);
+
+/* name: CreateAuthorReturnId :execlastid */
+INSERT INTO authors (
+  name, bio
+) VALUES (
+  ?, ?
 );
 
 /* name: DeleteAuthor :exec */
@@ -19,4 +26,4 @@ WHERE id = ?;
 
 /* name: Test :one */
 SELECT * FROM node_mysql_types
-LIMIT 1;
+LIMIT 1;

examples/bun-mysql2/src/db/query_sql.ts

@@ -1,4 +1,4 @@
-import mysql, { RowDataPacket } from "mysql2/promise";
+import mysql, { RowDataPacket, ResultSetHeader } from "mysql2/promise";
 
 type Client = mysql.Connection | mysql.Pool;
 
@@ -62,7 +62,7 @@ export const createAuthorQuery = `-- name: CreateAuthor :exec
 INSERT INTO authors (
   name, bio
 ) VALUES (
-  ?, ? 
+  ?, ?
 )`;
 
 export interface CreateAuthorArgs {
@@ -77,6 +77,26 @@ export async function createAuthor(client: Client, args: CreateAuthorArgs): Prom
     });
 }
 
+export const createAuthorReturnIdQuery = `-- name: CreateAuthorReturnId :execlastid
+INSERT INTO authors (
+  name, bio
+) VALUES (
+  ?, ?
+)`;
+
+export interface CreateAuthorReturnIdArgs {
+    name: string;
+    bio: string | null;
+}
+
+export async function createAuthorReturnId(client: Client, args: CreateAuthorReturnIdArgs): Promise<number | null> {
+    const [result] = await client.query<ResultSetHeader>({
+        sql: createAuthorReturnIdQuery,
+        values: [args.name, args.bio]
+    });
+    return result?.insertId ?? null;
+}
+
 export const deleteAuthorQuery = `-- name: DeleteAuthor :exec
 DELETE FROM authors
 WHERE id = ?`;

examples/node-mysql2/src/db/query_sql.ts

@@ -1,4 +1,4 @@
-import mysql, { RowDataPacket } from "mysql2/promise";
+import mysql, { RowDataPacket, ResultSetHeader } from "mysql2/promise";
 
 type Client = mysql.Connection | mysql.Pool;
 
@@ -62,7 +62,7 @@ export const createAuthorQuery = `-- name: CreateAuthor :exec
 INSERT INTO authors (
   name, bio
 ) VALUES (
-  ?, ? 
+  ?, ?
 )`;
 
 export interface CreateAuthorArgs {
@@ -77,6 +77,26 @@ export async function createAuthor(client: Client, args: CreateAuthorArgs): Prom
     });
 }
 
+export const createAuthorReturnIdQuery = `-- name: CreateAuthorReturnId :execlastid
+INSERT INTO authors (
+  name, bio
+) VALUES (
+  ?, ?
+)`;
+
+export interface CreateAuthorReturnIdArgs {
+    name: string;
+    bio: string | null;
+}
+
+export async function createAuthorReturnId(client: Client, args: CreateAuthorReturnIdArgs): Promise<number | null> {
+    const [result] = await client.query<ResultSetHeader>({
+        sql: createAuthorReturnIdQuery,
+        values: [args.name, args.bio]
+    });
+    return result?.insertId ?? null;
+}
+
 export const deleteAuthorQuery = `-- name: DeleteAuthor :exec
 DELETE FROM authors
 WHERE id = ?`;

src/app.ts

@@ -53,6 +53,12 @@ interface Driver {
     iface: string | undefined,
     params: Parameter[]
   ) => Node;
+  execlastidDecl: (
+    name: string,
+    text: string,
+    iface: string | undefined,
+    params: Parameter[]
+  ) => Node;
   manyDecl: (
     name: string,
     text: string,
@@ -77,10 +83,10 @@ function createNodeGenerator(driver?: string): Driver {
       return mysql2;
     }
     case "pg": {
-      return pg;
+      return pg as any;
     }
     case "postgres": {
-      return postgres;
+      return postgres as any;
     }
   }
   throw new Error(`unknown driver: ${driver}`);
@@ -156,6 +162,12 @@ ${query.text}`
           );
           break;
         }
+        case ":execlastid": {
+          nodes.push(
+            driver.execlastidDecl(lowerName, textName, argIface, query.params)
+          )
+          break;
+        }
         case ":one": {
           nodes.push(
             driver.oneDecl(

src/drivers/mysql2.ts

@@ -178,6 +178,11 @@ export function preamble(queries: unknown) {
             undefined,
             factory.createIdentifier("RowDataPacket")
           ),
+          factory.createImportSpecifier(
+            false,
+            undefined,
+            factory.createIdentifier("ResultSetHeader")
+          ),
         ])
       ),
       factory.createStringLiteral("mysql2/promise"),
@@ -611,10 +616,117 @@ export function oneDecl(
   );
 }
 
+export function execlastidDecl(
+  funcName: string,
+  queryName: string,
+  argIface: string | undefined,
+  params: Parameter[]
+) {
+  const funcParams = funcParamsDecl(argIface, params);
+
+  return factory.createFunctionDeclaration(
+    [
+      factory.createToken(SyntaxKind.ExportKeyword),
+      factory.createToken(SyntaxKind.AsyncKeyword),
+    ],
+    undefined,
+    factory.createIdentifier(funcName),
+    undefined,
+    funcParams,
+    factory.createTypeReferenceNode(factory.createIdentifier("Promise"), [
+      factory.createUnionTypeNode([
+        factory.createTypeReferenceNode('number', undefined),
+        factory.createLiteralTypeNode(factory.createNull()),
+      ])
+    ]),
+    factory.createBlock(
+      [
+        factory.createVariableStatement(
+          undefined,
+          factory.createVariableDeclarationList(
+            [
+              factory.createVariableDeclaration(
+                factory.createArrayBindingPattern([
+                  factory.createBindingElement(
+                    undefined,
+                    undefined,
+                    factory.createIdentifier("result"),
+                    undefined
+                  ),
+                ]),
+                undefined,
+                undefined,
+                factory.createAwaitExpression(
+                  factory.createCallExpression(
+                    factory.createPropertyAccessExpression(
+                      factory.createIdentifier("client"),
+                      factory.createIdentifier("query")
+                    ),
+                    [
+                      factory.createTypeReferenceNode(
+                        factory.createIdentifier("ResultSetHeader"),
+                        undefined
+                      )
+                    ],
+                    [
+                      factory.createObjectLiteralExpression(
+                        [
+                          factory.createPropertyAssignment(
+                            factory.createIdentifier("sql"),
+                            factory.createIdentifier(queryName)
+                          ),
+                          factory.createPropertyAssignment(
+                            factory.createIdentifier("values"),
+                            factory.createArrayLiteralExpression(
+                              params.map((param, i) =>
+                                factory.createPropertyAccessExpression(
+                                  factory.createIdentifier("args"),
+                                  factory.createIdentifier(
+                                    argName(i, param.column)
+                                  )
+                                )
+                              ),
+                              false
+                            )
+                          ),
+                        ],
+                        true
+                      ),
+                    ]
+                  )
+                )
+              )
+            ],
+            NodeFlags.Const |
+              // NodeFlags.Constant |
+              NodeFlags.AwaitContext |
+              // NodeFlags.Constant |
+              NodeFlags.ContextFlags |
+              NodeFlags.TypeExcludesFlags
+          )
+        ),
+        factory.createReturnStatement(
+          factory.createBinaryExpression(
+            factory.createPropertyAccessChain(
+              factory.createIdentifier("result"),
+              factory.createToken(SyntaxKind.QuestionDotToken),
+              factory.createIdentifier("insertId")
+            ),
+            factory.createToken(SyntaxKind.QuestionQuestionToken),
+            factory.createNull()
+          )
+        ),
+      ],
+      true
+    )
+  )
+}
+
 export default {
   columnType,
   preamble,
   execDecl,
   manyDecl,
   oneDecl,
+  execlastidDecl,
 };