pg

server/prisma/convert-sqlite-to-postgres.js

@@ -0,0 +1,116 @@
+const fs = require('fs');
+const path = require('path');
+
+/**
+ * 将 SQLite 迁移文件转换为 PostgreSQL 语法
+ */
+
+// SQLite 到 PostgreSQL 的转换映射
+const sqliteToPostgresConversions = [
+  // 主键和自动递增
+  {
+    pattern: /INTEGER\s+NOT\s+NULL\s+PRIMARY\s+KEY\s+AUTOINCREMENT/g,
+    replacement: 'SERIAL PRIMARY KEY'
+  },
+  {
+    pattern: /\s+AUTOINCREMENT/g,
+    replacement: ''
+  },
+  // 数据类型
+  {
+    pattern: /\bDATETIME\b/g,
+    replacement: 'TIMESTAMP'
+  },
+  // 布尔值默认值 - 修复正则表达式，更精确的匹配
+  {
+    pattern: /DEFAULT\s+(?:'?(false|true)'?)/gi,
+    replacement: "DEFAULT $1"
+  },
+  // 数字默认值
+  {
+    pattern: /DEFAULT\s+'?0'?/g,
+    replacement: "DEFAULT 0"
+  },
+  {
+    pattern: /DEFAULT\s+'?1'?/g,
+    replacement: "DEFAULT 1"
+  }
+];
+
+/**
+ * 转换单个 SQL 文件
+ */
+function convertSqlFile(filePath) {
+  try {
+    let sqlContent = fs.readFileSync(filePath, 'utf8');
+
+    console.log(`转换文件: ${path.basename(filePath)}`);
+
+    // 应用所有转换规则
+    sqliteToPostgresConversions.forEach(({ pattern, replacement }) => {
+      sqlContent = sqlContent.replace(pattern, replacement);
+    });
+
+    // 写回文件
+    fs.writeFileSync(filePath, sqlContent);
+
+    console.log(`✓ ${path.basename(filePath)} 转换完成`);
+    return true;
+  } catch (error) {
+    console.error(`✗ ${path.basename(filePath)} 转换失败:`, error.message);
+    return false;
+  }
+}
+
+/**
+ * 递归处理目录中的所有迁移文件
+ */
+function convertMigrationsDirectory(migrationsDir) {
+  const items = fs.readdirSync(migrationsDir);
+
+  let successCount = 0;
+  let failCount = 0;
+
+  items.forEach(item => {
+    const itemPath = path.join(migrationsDir, item);
+    const stat = fs.statSync(itemPath);
+
+    if (stat.isDirectory() && item !== 'migration_lock.toml') {
+      // 递归处理子目录
+      const result = convertMigrationsDirectory(itemPath);
+      successCount += result.successCount;
+      failCount += result.failCount;
+    } else if (item === 'migration.sql') {
+      // 处理迁移文件
+      if (convertSqlFile(itemPath)) {
+        successCount++;
+      } else {
+        failCount++;
+      }
+    }
+  });
+
+  return { successCount, failCount };
+}
+
+/**
+ * 主函数
+ */
+function main() {
+  const migrationsDir = path.join(__dirname, 'migrations');
+
+  console.log('开始转换 SQLite 迁移文件到 PostgreSQL 语法...\n');
+
+  const result = convertMigrationsDirectory(migrationsDir);
+
+  console.log(`\n转换完成!`);
+  console.log(`成功: ${result.successCount} 个文件`);
+  console.log(`失败: ${result.failCount} 个文件`);
+}
+
+// 运行转换
+if (require.main === module) {
+  main();
+}
+
+module.exports = { convertSqlFile, convertMigrationsDirectory };

server/prisma/migrations/20230921191814_init/migration.sql

@@ -1,107 +1,107 @@
 -- CreateTable
 CREATE TABLE "api_keys" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "secret" TEXT,
     "createdBy" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "workspace_documents" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "docId" TEXT NOT NULL,
     "filename" TEXT NOT NULL,
     "docpath" TEXT NOT NULL,
     "workspaceId" INTEGER NOT NULL,
     "metadata" TEXT,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_documents_workspaceId_fkey" FOREIGN KEY ("workspaceId") REFERENCES "workspaces" ("id") ON DELETE RESTRICT ON UPDATE CASCADE
 );
 
 -- CreateTable
 CREATE TABLE "invites" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "code" TEXT NOT NULL,
     "status" TEXT NOT NULL DEFAULT 'pending',
     "claimedBy" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "createdBy" INTEGER NOT NULL,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "system_settings" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "label" TEXT NOT NULL,
     "value" TEXT,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "users" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "username" TEXT,
     "password" TEXT NOT NULL,
     "role" TEXT NOT NULL DEFAULT 'default',
     "suspended" INTEGER NOT NULL DEFAULT 0,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "document_vectors" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "docId" TEXT NOT NULL,
     "vectorId" TEXT NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "welcome_messages" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "user" TEXT NOT NULL,
     "response" TEXT NOT NULL,
     "orderIndex" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateTable
 CREATE TABLE "workspaces" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "name" TEXT NOT NULL,
     "slug" TEXT NOT NULL,
     "vectorTag" TEXT,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "openAiTemp" REAL,
     "openAiHistory" INTEGER NOT NULL DEFAULT 20,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "openAiPrompt" TEXT
 );
 
 -- CreateTable
 CREATE TABLE "workspace_chats" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "workspaceId" INTEGER NOT NULL,
     "prompt" TEXT NOT NULL,
     "response" TEXT NOT NULL,
     "include" BOOLEAN NOT NULL DEFAULT true,
     "user_id" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_chats_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 
 -- CreateTable
 CREATE TABLE "workspace_users" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "user_id" INTEGER NOT NULL,
     "workspace_id" INTEGER NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_users_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "workspace_users_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );

server/prisma/migrations/20231101195421_init/migration.sql

@@ -1,11 +1,11 @@
 -- CreateTable
 CREATE TABLE "cache_data" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "name" TEXT NOT NULL,
     "data" TEXT NOT NULL,
     "belongsTo" TEXT,
     "byId" INTEGER,
-    "expiresAt" DATETIME,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "expiresAt" TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );

server/prisma/migrations/20240202002020_init/migration.sql

@@ -1,6 +1,6 @@
 -- CreateTable
 CREATE TABLE "embed_configs" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "uuid" TEXT NOT NULL,
     "enabled" BOOLEAN NOT NULL DEFAULT false,
     "chat_mode" TEXT NOT NULL DEFAULT 'query',
@@ -13,14 +13,14 @@ CREATE TABLE "embed_configs" (
     "workspace_id" INTEGER NOT NULL,
     "createdBy" INTEGER,
     "usersId" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "embed_configs_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "embed_configs_usersId_fkey" FOREIGN KEY ("usersId") REFERENCES "users" ("id") ON DELETE SET NULL ON UPDATE CASCADE
 );
 
 -- CreateTable
 CREATE TABLE "embed_chats" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "prompt" TEXT NOT NULL,
     "response" TEXT NOT NULL,
     "session_id" TEXT NOT NULL,
@@ -28,7 +28,7 @@ CREATE TABLE "embed_chats" (
     "connection_information" TEXT,
     "embed_id" INTEGER NOT NULL,
     "usersId" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "embed_chats_embed_id_fkey" FOREIGN KEY ("embed_id") REFERENCES "embed_configs" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "embed_chats_usersId_fkey" FOREIGN KEY ("usersId") REFERENCES "users" ("id") ON DELETE SET NULL ON UPDATE CASCADE
 );

server/prisma/migrations/20240206181106_init/migration.sql

@@ -1,11 +1,11 @@
 -- CreateTable
 CREATE TABLE "workspace_suggested_messages" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "workspaceId" INTEGER NOT NULL,
     "heading" TEXT NOT NULL,
     "message" TEXT NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_suggested_messages_workspaceId_fkey" FOREIGN KEY ("workspaceId") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20240206211916_init/migration.sql

@@ -1,10 +1,10 @@
 -- CreateTable
 CREATE TABLE "event_logs" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "event" TEXT NOT NULL,
     "metadata" TEXT,
     "userId" INTEGER,
-    "occurredAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP
+    "occurredAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
 );
 
 -- CreateIndex

server/prisma/migrations/20240208224848_init/migration.sql

@@ -3,13 +3,13 @@ ALTER TABLE "workspace_chats" ADD COLUMN "thread_id" INTEGER;
 
 -- CreateTable
 CREATE TABLE "workspace_threads" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "name" TEXT NOT NULL,
     "slug" TEXT NOT NULL,
     "workspace_id" INTEGER NOT NULL,
     "user_id" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_threads_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "workspace_threads_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );

server/prisma/migrations/20240412183346_init/migration.sql

@@ -4,15 +4,15 @@ ALTER TABLE "workspaces" ADD COLUMN "agentProvider" TEXT;
 
 -- CreateTable
 CREATE TABLE "workspace_agent_invocations" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "uuid" TEXT NOT NULL,
     "prompt" TEXT NOT NULL,
     "closed" BOOLEAN NOT NULL DEFAULT false,
     "user_id" INTEGER,
     "thread_id" INTEGER,
     "workspace_id" INTEGER NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_agent_invocations_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "workspace_agent_invocations_workspace_id_fkey" FOREIGN KEY ("workspace_id") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );

server/prisma/migrations/20240425004220_init/migration.sql

@@ -3,20 +3,20 @@ ALTER TABLE "users" ADD COLUMN "seen_recovery_codes" BOOLEAN DEFAULT false;
 
 -- CreateTable
 CREATE TABLE "recovery_codes" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "user_id" INTEGER NOT NULL,
     "code_hash" TEXT NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "recovery_codes_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 
 -- CreateTable
 CREATE TABLE "password_reset_tokens" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "user_id" INTEGER NOT NULL,
     "token" TEXT NOT NULL,
-    "expiresAt" DATETIME NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "expiresAt" TIMESTAMP NOT NULL,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "password_reset_tokens_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20240510032311_init/migration.sql

@@ -1,13 +1,13 @@
 -- CreateTable
 CREATE TABLE "slash_command_presets" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "command" TEXT NOT NULL,
     "prompt" TEXT NOT NULL,
     "description" TEXT NOT NULL,
     "uid" INTEGER NOT NULL DEFAULT 0,
     "userId" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "slash_command_presets_userId_fkey" FOREIGN KEY ("userId") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20240618224346_init/migration.sql

@@ -3,22 +3,22 @@ ALTER TABLE "workspace_documents" ADD COLUMN "watched" BOOLEAN DEFAULT false;
 
 -- CreateTable
 CREATE TABLE "document_sync_queues" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "staleAfterMs" INTEGER NOT NULL DEFAULT 604800000,
-    "nextSyncAt" DATETIME NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastSyncedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "nextSyncAt" TIMESTAMP NOT NULL,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastSyncedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     "workspaceDocId" INTEGER NOT NULL,
     CONSTRAINT "document_sync_queues_workspaceDocId_fkey" FOREIGN KEY ("workspaceDocId") REFERENCES "workspace_documents" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 
 -- CreateTable
 CREATE TABLE "document_sync_executions" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "queueId" INTEGER NOT NULL,
     "status" TEXT NOT NULL DEFAULT 'unknown',
     "result" TEXT,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "document_sync_executions_queueId_fkey" FOREIGN KEY ("queueId") REFERENCES "document_sync_queues" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20240824005054_init/migration.sql

@@ -1,10 +1,10 @@
 -- CreateTable
 CREATE TABLE "browser_extension_api_keys" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "key" TEXT NOT NULL,
     "user_id" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "lastUpdatedAt" DATETIME NOT NULL,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "lastUpdatedAt" TIMESTAMP NOT NULL,
     CONSTRAINT "browser_extension_api_keys_user_id_fkey" FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20241029203722_init/migration.sql

@@ -1,10 +1,10 @@
 -- CreateTable
 CREATE TABLE "temporary_auth_tokens" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "token" TEXT NOT NULL,
     "userId" INTEGER NOT NULL,
-    "expiresAt" DATETIME NOT NULL,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "expiresAt" TIMESTAMP NOT NULL,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "temporary_auth_tokens_userId_fkey" FOREIGN KEY ("userId") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20250318154720_init/migration.sql

@@ -1,13 +1,13 @@
 -- CreateTable
 CREATE TABLE "system_prompt_variables" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "key" TEXT NOT NULL,
     "value" TEXT,
     "description" TEXT,
     "type" TEXT NOT NULL DEFAULT 'system',
     "userId" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
-    "updatedAt" DATETIME NOT NULL,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP NOT NULL,
     CONSTRAINT "system_prompt_variables_userId_fkey" FOREIGN KEY ("userId") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20250506214129_init/migration.sql

@@ -1,10 +1,10 @@
 -- CreateTable
 CREATE TABLE "prompt_history" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "workspaceId" INTEGER NOT NULL,
     "prompt" TEXT NOT NULL,
     "modifiedBy" INTEGER,
-    "modifiedAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "modifiedAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "prompt_history_workspaceId_fkey" FOREIGN KEY ("workspaceId") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "prompt_history_modifiedBy_fkey" FOREIGN KEY ("modifiedBy") REFERENCES "users" ("id") ON DELETE SET NULL ON UPDATE CASCADE
 );

server/prisma/migrations/20250725194841_init/migration.sql

@@ -1,12 +1,12 @@
 -- CreateTable
 CREATE TABLE "desktop_mobile_devices" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "deviceOs" TEXT NOT NULL,
     "deviceName" TEXT NOT NULL,
     "token" TEXT NOT NULL,
     "approved" BOOLEAN NOT NULL DEFAULT false,
     "userId" INTEGER,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "desktop_mobile_devices_userId_fkey" FOREIGN KEY ("userId") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE
 );
 

server/prisma/migrations/20250808171557_init/migration.sql

@@ -1,13 +1,13 @@
 -- CreateTable
 CREATE TABLE "workspace_parsed_files" (
-    "id" INTEGER NOT NULL PRIMARY KEY AUTOINCREMENT,
+    "id" SERIAL PRIMARY KEY,
     "filename" TEXT NOT NULL,
     "workspaceId" INTEGER NOT NULL,
     "userId" INTEGER,
     "threadId" INTEGER,
     "metadata" TEXT,
     "tokenCountEstimate" INTEGER DEFAULT 0,
-    "createdAt" DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "createdAt" TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
     CONSTRAINT "workspace_parsed_files_workspaceId_fkey" FOREIGN KEY ("workspaceId") REFERENCES "workspaces" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "workspace_parsed_files_userId_fkey" FOREIGN KEY ("userId") REFERENCES "users" ("id") ON DELETE CASCADE ON UPDATE CASCADE,
     CONSTRAINT "workspace_parsed_files_threadId_fkey" FOREIGN KEY ("threadId") REFERENCES "workspace_threads" ("id") ON DELETE CASCADE ON UPDATE CASCADE

server/prisma/verify-postgres-conversions.js

@@ -0,0 +1,139 @@
+const fs = require('fs');
+const path = require('path');
+
+/**
+ * 验证 PostgreSQL 转换是否正确
+ */
+
+// 需要检查的 SQLite 语法模式
+const sqlitePatterns = [
+  /AUTOINCREMENT/i,
+  /DATETIME/i,
+  /INTEGER\s+NOT\s+NULL\s+PRIMARY\s+KEY\s+AUTOINCREMENT/i
+];
+
+/**
+ * 验证单个 SQL 文件
+ */
+function verifySqlFile(filePath) {
+  try {
+    const sqlContent = fs.readFileSync(filePath, 'utf8');
+    const issues = [];
+
+    // 检查是否还有 SQLite 语法
+    sqlitePatterns.forEach(pattern => {
+      if (pattern.test(sqlContent)) {
+        issues.push(`发现 SQLite 语法: ${pattern.source}`);
+      }
+    });
+
+    // 检查 PostgreSQL 语法是否正确
+    if (!sqlContent.includes('SERIAL PRIMARY KEY') && sqlContent.includes('CREATE TABLE')) {
+      // 检查是否有 SERIAL 或者 SERIAL PRIMARY KEY
+      const hasSerial = /\bSERIAL\b/.test(sqlContent);
+      const hasPrimaryKey = /\bPRIMARY\s+KEY\b/.test(sqlContent);
+
+      if (!hasSerial && !hasPrimaryKey) {
+        issues.push('缺少 SERIAL 或 PRIMARY KEY 定义');
+      }
+    }
+
+    return {
+      file: path.basename(filePath),
+      issues: issues,
+      isValid: issues.length === 0
+    };
+  } catch (error) {
+    return {
+      file: path.basename(filePath),
+      issues: [`读取文件失败: ${error.message}`],
+      isValid: false
+    };
+  }
+}
+
+/**
+ * 递归验证目录中的所有迁移文件
+ */
+function verifyMigrationsDirectory(migrationsDir) {
+  const items = fs.readdirSync(migrationsDir);
+  const results = [];
+
+  items.forEach(item => {
+    const itemPath = path.join(migrationsDir, item);
+    const stat = fs.statSync(itemPath);
+
+    if (stat.isDirectory() && item !== 'migration_lock.toml') {
+      // 递归处理子目录
+      const subResults = verifyMigrationsDirectory(itemPath);
+      results.push(...subResults);
+    } else if (item === 'migration.sql') {
+      // 验证迁移文件
+      results.push(verifySqlFile(itemPath));
+    }
+  });
+
+  return results;
+}
+
+/**
+ * 生成验证报告
+ */
+function generateReport(results) {
+  const validFiles = results.filter(r => r.isValid);
+  const invalidFiles = results.filter(r => !r.isValid);
+
+  console.log('=== PostgreSQL 转换验证报告 ===\n');
+
+  console.log(`总文件数: ${results.length}`);
+  console.log(`有效文件: ${validFiles.length}`);
+  console.log(`有问题的文件: ${invalidFiles.length}\n`);
+
+  if (invalidFiles.length > 0) {
+    console.log('=== 有问题的文件 ===');
+    invalidFiles.forEach(result => {
+      console.log(`\n📄 ${result.file}:`);
+      result.issues.forEach(issue => {
+        console.log(`  ❌ ${issue}`);
+      });
+    });
+  }
+
+  console.log('\n=== 有效文件 ===');
+  validFiles.forEach(result => {
+    console.log(`  ✅ ${result.file}`);
+  });
+
+  return {
+    total: results.length,
+    valid: validFiles.length,
+    invalid: invalidFiles.length
+  };
+}
+
+/**
+ * 主函数
+ */
+function main() {
+  const migrationsDir = path.join(__dirname, 'migrations');
+
+  console.log('开始验证 PostgreSQL 转换...\n');
+
+  const results = verifyMigrationsDirectory(migrationsDir);
+  const report = generateReport(results);
+
+  if (report.invalid === 0) {
+    console.log('\n🎉 所有文件都已正确转换为 PostgreSQL 语法！');
+  } else {
+    console.log(`\n⚠️  发现 ${report.invalid} 个文件需要手动检查。`);
+  }
+
+  return report;
+}
+
+// 运行验证
+if (require.main === module) {
+  main();
+}
+
+module.exports = { verifySqlFile, verifyMigrationsDirectory, generateReport };