adding json selector support per dialect

Author: cblanquera

packages/inquire/src/dialect/Mysql.ts

@@ -557,6 +557,30 @@ const Mysql: Dialect = {
 
     return { query: query.join(' '), values };
   },
+
+  /**
+   * Converts to proper JSON selector
+   */
+  json(column: string, path: string, separator = '.') {
+    if (path.length === 0) {
+      return `JSON_UNQUOTE(JSON_EXTRACT(${q}${column}${q}, '$'))`;
+    }
+    //path examples to consider:
+    // - 0: array root: JSON_EXTRACT(column, '$[0]')
+    // - id: object key: JSON_EXTRACT(column, '$.id')
+    // - 0.id: array of objects: JSON_EXTRACT(column, '$[0].id')
+    // - ids.0: object with array value: JSON_EXTRACT(column, '$.ids[0]')
+    const selector = path
+      .split(separator)
+      .filter(Boolean)
+      .map(path => (
+        /^\d+$/.test(path)
+          ? `[${path}]`
+          : `."${path.replace(/\\/g, '\\\\').replace(/"/g, '\\"')}"`
+      ))
+      .join('');
+    return `JSON_UNQUOTE(JSON_EXTRACT(${q}${column}${q}, '$${selector}'))`;
+  }
 };
 
 export default Mysql;

packages/inquire/src/dialect/Pgsql.ts

@@ -593,6 +593,27 @@ const Pgsql: Dialect = {
 
     return { query: query.join(' '), values };
   },
+
+  /**
+   * Converts to proper JSON selector
+   */
+  json(column: string, path: string, separator = '.') {
+    if (path.length === 0) {
+      return `${q}${column}${q}::text`;
+    }
+    //path examples to consider:
+    // - 0: array root: column->0
+    // - id: object key: column->'id'
+    // - 0.id: array of objects: column->0->'id'
+    // - ids.0: object with array value: column->'ids'->0
+    const paths = path.split(separator).filter(Boolean);
+    const last = paths.pop()!;
+    const selector = paths.map(
+      part => /^\d+$/.test(part) ? `->${part}` : `->$$${part}$$`
+    );
+    selector.push(/^\d+$/.test(last) ? `->>${last}` : `->>$$${last}$$`)
+    return `${q}${column}${q}${selector.join('')}`;
+  }
 };
 
 export default Pgsql;

packages/inquire/src/dialect/Sqlite.ts

@@ -504,6 +504,22 @@ const Sqlite: Dialect = {
 
     return { query: query.join(' '), values };
   },
+
+  /**
+   * Converts to proper JSON selector
+   */
+  json(column: string, path: string, separator = '.') {
+    if (path.length === 0) {
+      return `json_extract(${q}${column}${q}, '$')`;
+    }
+    const selector = path
+      .split(separator)
+      .filter(Boolean)
+      .map(path => /^\d+$/.test(path) ? `[${path}]` : `.${path}`)
+      .join('');
+
+    return `json_extract(${q}${column}${q}, '$${selector}')`;
+  }
 };
 
 export default Sqlite;

packages/inquire/src/types.ts

@@ -105,6 +105,7 @@ export type Dialect = {
   select(builder: Select): QueryObject;
   truncate(table: string, cascade?: boolean): QueryObject;
   update(builder: Update): QueryObject;
+  json(column: string, path: string, separator?: string): string;
 };
 
 //--------------------------------------------------------------------//