feat(drizzle): abstract shared sql code to new package (#7320)

- Abstract shared sql code to a new drizzle package
- Adds sqlite package, not ready to publish until drizzle patches some
issues
- Add `transactionOptions` to allow customizing or disabling db
transactions
- Adds "experimental" label to the `schemaName` property until drizzle
patches an issue

packages/db-sqlite/src/createJSONQuery/convertPathToJSONTraversal.ts

@@ -0,0 +1,9 @@
+export const convertPathToJSONTraversal = (incomingSegments: string[]): string => {
+  const segments = [...incomingSegments]
+  segments.shift()
+
+  return segments.reduce((res, segment) => {
+    const formattedSegment = Number.isNaN(parseInt(segment)) ? `'${segment}'` : segment
+    return `${res}->>${formattedSegment}`
+  }, '')
+}

packages/db-sqlite/src/createJSONQuery/index.ts

@@ -0,0 +1,86 @@
+import type { CreateJSONQueryArgs } from '@payloadcms/drizzle/types'
+
+type FromArrayArgs = {
+  isRoot?: true
+  operator: string
+  pathSegments: string[]
+  table: string
+  treatAsArray?: string[]
+  value: boolean | number | string
+}
+
+const fromArray = ({
+  isRoot,
+  operator,
+  pathSegments,
+  table,
+  treatAsArray,
+  value,
+}: FromArrayArgs) => {
+  const newPathSegments = pathSegments.slice(1)
+  const alias = `${pathSegments[isRoot ? 0 : 1]}_alias_${newPathSegments.length}`
+
+  return `EXISTS (
+    SELECT 1
+    FROM json_each(${table}.${pathSegments[0]}) AS ${alias}
+    WHERE ${createJSONQuery({
+      operator,
+      pathSegments: newPathSegments,
+      table: alias,
+      treatAsArray,
+      value,
+    })}
+  )`
+}
+
+type CreateConstraintArgs = {
+  alias?: string
+  operator: string
+  pathSegments: string[]
+  treatAsArray?: string[]
+  value: boolean | number | string
+}
+
+const createConstraint = ({
+  alias,
+  operator,
+  pathSegments,
+  value,
+}: CreateConstraintArgs): string => {
+  const newAlias = `${pathSegments[0]}_alias_${pathSegments.length - 1}`
+  let formattedValue = value
+  let formattedOperator = operator
+
+  if (['contains', 'like'].includes(operator)) {
+    formattedOperator = 'like'
+    formattedValue = `%${value}%`
+  } else if (operator === 'equals') {
+    formattedOperator = '='
+  }
+
+  return `EXISTS (
+  SELECT 1
+  FROM json_each(${alias}.value -> '${pathSegments[0]}') AS ${newAlias}
+  WHERE ${newAlias}.value ->> '${pathSegments[1]}' ${formattedOperator} '${formattedValue}'
+  )`
+}
+
+export const createJSONQuery = ({
+  operator,
+  pathSegments,
+  table,
+  treatAsArray,
+  value,
+}: CreateJSONQueryArgs): string => {
+  if (treatAsArray.includes(pathSegments[1])) {
+    return fromArray({
+      operator,
+      pathSegments,
+      table,
+      treatAsArray,
+      value,
+    })
+  }
+
+  return createConstraint({ alias: table, operator, pathSegments, treatAsArray, value })
+}