From ea8a2eab6b3a06ab87338f0b151ec814d3da415f Mon Sep 17 00:00:00 2001
From: Benjamin Toby <devops@tben.me>
Date: Thu, 16 Apr 2026 15:05:35 +0100
Subject: [PATCH] Updates

---
 dist/types/index.d.ts       | 13 +++++++++++--
 dist/utils/sql-generator.js |  5 +++--
 package.json                |  2 +-
 src/types/index.ts          | 15 +++++++++++++--
 src/utils/sql-generator.ts  |  5 +++--
 5 files changed, 31 insertions(+), 9 deletions(-)

diff --git a/dist/types/index.d.ts b/dist/types/index.d.ts
index e0cc5b8..0f05c58 100644
--- a/dist/types/index.d.ts
+++ b/dist/types/index.d.ts
@@ -643,7 +643,6 @@ export type ServerQueryParam<T extends {
     /**
      * Raw SQL to use as select
      */
-    select_sql?: string;
     [key: string]: any;
 };
 /**
@@ -808,7 +807,17 @@ export type ServerQueryParamsJoin<Table extends string = string, Field extends o
     /**
      * Raw SQL to use as join select
      */
-    select_sql?: string;
+    /**
+     * Concatenate multiple matches from another table
+     */
+    group_concat?: {
+        field: string;
+        alias: string;
+        /**
+         * Separator. Default `,`
+         */
+        separator?: string;
+    };
 };
 /**
  * Defines how a root-table field maps to a join-table field in an `ON` clause.
diff --git a/dist/utils/sql-generator.js b/dist/utils/sql-generator.js
index 13e22e8..37797a8 100644
--- a/dist/utils/sql-generator.js
+++ b/dist/utils/sql-generator.js
@@ -215,8 +215,9 @@ export default function sqlGenerator({ tableName, genObject, dbFullName, count }
                         if (existingJoinTableNames.includes(joinTableName))
                             return null;
                         existingJoinTableNames.push(joinTableName);
-                        if (joinObj.select_sql) {
-                            return joinObj.select_sql;
+                        if (joinObj.group_concat) {
+                            let group_concat = `GROUP_CONCAT(${joinTableName}.${joinObj.group_concat.field}, ${joinObj.group_concat.separator || ","}) AS ${joinObj.group_concat.alias}`;
+                            return group_concat;
                         }
                         else if (joinObj.selectFields) {
                             return joinObj.selectFields
diff --git a/package.json b/package.json
index 2f8040c..ac63d4f 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "@moduletrace/bun-sqlite",
-    "version": "1.0.37",
+    "version": "1.0.38",
     "description": "SQLite manager for Bun",
     "author": "Benjamin Toby",
     "main": "dist/index.js",
diff --git a/src/types/index.ts b/src/types/index.ts
index 66dc5ef..c333764 100644
--- a/src/types/index.ts
+++ b/src/types/index.ts
@@ -715,7 +715,7 @@ export type ServerQueryParam<
     /**
      * Raw SQL to use as select
      */
-    select_sql?: string;
+    // select_sql?: string;
     [key: string]: any;
 };
 
@@ -902,7 +902,18 @@ export type ServerQueryParamsJoin<
     /**
      * Raw SQL to use as join select
      */
-    select_sql?: string;
+    // select_sql?: string;
+    /**
+     * Concatenate multiple matches from another table
+     */
+    group_concat?: {
+        field: string;
+        alias: string;
+        /**
+         * Separator. Default `,`
+         */
+        separator?: string;
+    };
 };
 
 /**
diff --git a/src/utils/sql-generator.ts b/src/utils/sql-generator.ts
index 53e584b..8568ffd 100644
--- a/src/utils/sql-generator.ts
+++ b/src/utils/sql-generator.ts
@@ -312,8 +312,9 @@ export default function sqlGenerator<
                             return null;
                         existingJoinTableNames.push(joinTableName);
 
-                        if (joinObj.select_sql) {
-                            return joinObj.select_sql;
+                        if (joinObj.group_concat) {
+                            let group_concat = `GROUP_CONCAT(${joinTableName}.${joinObj.group_concat.field}, ${joinObj.group_concat.separator || ","}) AS ${joinObj.group_concat.alias}`;
+                            return group_concat;
                         } else if (joinObj.selectFields) {
                             return joinObj.selectFields
                                 .map((selectField) => {