feat: add data editor capability for various SQL data sources and update dependencies

Author: JulianFun123

README.md

@@ -33,12 +33,28 @@ Status:
 
 Datasource types:
 - `mysql`
+- `mariadb`
 - `postgres`
+- `cockroachdb`
 - `sqlite` (local only)
+- `duckdb` (local only)
+- `mssql`
+- `clickhouse`
+- `oracle`
+- `cassandra`
+- `mongodb`
+- `redis`
 - `elasticsearch`
 - `s3`
 - `minio`
 
+Frontend export formats:
+- `csv`
+- `json`
+- `sql inserts`
+- `xml`
+- `html table`
+
 Runtime targets:
 - Electron desktop app with a built-in local backend
 - Hosted backend + Vite frontend for browser usage

packages/backend/package.json

@@ -18,21 +18,28 @@
   "author": "",
   "license": "ISC",
   "dependencies": {
+    "@clickhouse/client": "^1.18.2",
+    "@duckdb/node-api": "1.5.1-r.1",
     "@elastic/elasticsearch": "^9.3.4",
     "@types/body-parser": "^1.19.5",
     "@types/express": "^5.0.2",
     "@types/express-ws": "^3.0.5",
-    "body-parser": "^2.2.0",
     "better-sqlite3": "^12.8.0",
+    "body-parser": "^2.2.0",
+    "cassandra-driver": "^4.8.0",
     "cors": "^2.8.5",
     "drizzle-orm": "^0.45.1",
     "express": "^5.0.2",
     "express-ws": "^5.0.2",
     "minio": "^8.0.7",
+    "mongodb": "^7.1.1",
+    "mssql": "^12.2.1",
     "mysql2": "^3.14.1",
     "nodemon": "^3.1.10",
     "openid-client": "^6.8.2",
+    "oracledb": "^6.10.0",
     "pg": "^8.20.0",
+    "redis": "^5.11.0",
     "ts-node": "^10.9.2",
     "tsx": "^4.21.0",
     "ws": "^8.18.2"

packages/backend/src/datasources/cassandra/adapter.ts

@@ -0,0 +1,71 @@
+import { createRequire } from 'node:module'
+import type { Client } from 'cassandra-driver'
+import type * as CassandraNamespace from 'cassandra-driver'
+import type { QueryResult } from '../../adapters/database/sql/default-sql-adapter/DefaultSQLAdapter.ts'
+import { createSelectResultFromRows, QueryOnlySqlAdapter } from '../shared-sql/query-only-adapter.ts'
+
+type CassandraConfig = {
+  host: string
+  port: number
+  user?: string
+  password?: string
+  database?: string
+  ssl?: boolean
+}
+
+type CassandraModule = typeof CassandraNamespace
+
+export class CassandraSqlAdapter extends QueryOnlySqlAdapter {
+  private static readonly require = createRequire(import.meta.url)
+  private client!: Client
+
+  constructor(private readonly config: CassandraConfig) {
+    super()
+  }
+
+  private loadCassandraModule() {
+    return CassandraSqlAdapter.require('cassandra-driver') as CassandraModule
+  }
+
+  async connect() {
+    const { Client } = this.loadCassandraModule()
+    this.client = new Client({
+      contactPoints: [this.config.host],
+      localDataCenter: 'datacenter1',
+      protocolOptions: {
+        port: this.config.port,
+      },
+      keyspace: this.config.database,
+      credentials:
+        this.config.user
+          ? {
+              username: this.config.user,
+              password: this.config.password ?? '',
+            }
+          : undefined,
+      sslOptions: this.config.ssl ? {} : undefined,
+    })
+
+    await this.client.connect()
+  }
+
+  async close() {
+    await this.client?.shutdown()
+  }
+
+  async execute(sqlText: string): Promise<QueryResult> {
+    const result = await this.client.execute(sqlText)
+    const rows = result.rows.map((row) => ({ ...row }))
+
+    if (rows.length || result.columns?.length) {
+      return createSelectResultFromRows(rows as Record<string, unknown>[])
+    }
+
+    return {
+      type: 'RESULT',
+      result: {
+        command: 'CQL',
+      },
+    }
+  }
+}

packages/backend/src/datasources/cassandra/index.ts

@@ -0,0 +1,41 @@
+import { normalizeNetworkSqlConfig } from '../shared-sql/network-config.ts'
+import type { DataSourceModule } from '../shared/module.ts'
+import { CassandraSqlAdapter } from './adapter.ts'
+
+export const cassandraDataSourceModule = {
+  definition: {
+    type: 'cassandra',
+    kind: 'sql',
+    label: 'Cassandra',
+    icon: 'database',
+    capabilities: {
+      sqlQuery: true,
+      tableBrowser: false,
+      dataEditor: false,
+      schemaEditor: false,
+      resourceBrowser: false,
+    },
+  },
+  secretFields: ['password'],
+  normalizeConfig(config) {
+    return normalizeNetworkSqlConfig(config, {
+      defaultPort: 9042,
+      requireUser: false,
+      requirePassword: false,
+      requireDatabase: false,
+      includeSsl: true,
+    })
+  },
+  createSqlAdapter(config) {
+    return new CassandraSqlAdapter(
+      config as {
+        host: string
+        port: number
+        user?: string
+        password?: string
+        database?: string
+        ssl?: boolean
+      },
+    )
+  },
+} satisfies DataSourceModule