add test for raw with placeholders

Author: invisal

src/connections/sql-base.ts

@@ -67,7 +67,11 @@ export abstract class SqlConnection extends Connection {
         }
 
         // Named placeholder
-        const { query: newQuery, bindings } = namedPlaceholder(query, params!);
+        const { query: newQuery, bindings } = namedPlaceholder(
+            query,
+            params!,
+            this.numberedPlaceholder
+        );
         return await this.internalQuery({
             query: newQuery,
             parameters: bindings,

src/utils/placeholder.ts

@@ -28,7 +28,6 @@ function parse(query: string): [string] | [string[], (string | number)[]] {
         do {
             for (i = curpos, end = ppos.index; i < end; ++i) {
                 let chr = query.charCodeAt(i);
-                console.log(i, query[i], inQuote, qchr);
                 if (chr === BSLASH) escape = !escape;
                 else {
                     if (escape) {
@@ -90,7 +89,7 @@ export function namedPlaceholder(
             const key = placeholders[i];
 
             if (numbered) {
-                newQuery += `$${key}`;
+                newQuery += `$${i + 1}`;
             } else {
                 newQuery += `?`;
             }

tests/connections/connection.test.ts

@@ -36,6 +36,34 @@ function cleanup(data: Record<string, unknown>[]) {
 }
 
 describe('Database Connection', () => {
+    test('Support named parameters', async () => {
+        if (process.env.CONNECTION_TYPE === 'mongo') return;
+
+        const sql =
+            process.env.CONNECTION_TYPE === 'mysql'
+                ? 'SELECT CONCAT(:hello, :world) AS testing_word'
+                : 'SELECT (:hello || :world) AS testing_word';
+
+        const { data } = await db.raw(sql, {
+            hello: 'hello ',
+            world: 'world',
+        });
+
+        expect(data).toEqual([{ testing_word: 'hello world' }]);
+    });
+
+    test('Support positional placeholder', async () => {
+        if (process.env.CONNECTION_TYPE === 'mongo') return;
+
+        const sql =
+            process.env.CONNECTION_TYPE === 'mysql'
+                ? 'SELECT CONCAT(?, ?) AS testing_word'
+                : 'SELECT (? || ?) AS testing_word';
+
+        const { data } = await db.raw(sql, ['hello ', 'world']);
+        expect(data).toEqual([{ testing_word: 'hello world' }]);
+    });
+
     test('Create table', async () => {
         const { error: createTableTeamError } = await db.createTable(
             DEFAULT_SCHEMA,