データ永続化

// 1. AI に要件を伝える
Prompt: "ユーザー、商品、注文、注文明細テーブルを含む、EC システムのデータベースを設計してください..."

// 2. AI が生成した Prisma Schema
model User {
  id        String   @id @default(cuid())
  email     String   @unique
  name      String?
  orders    Order[]
  createdAt DateTime @default(now())
}

model Product {
  id          String      @id @default(cuid())
  name        String
  price       Decimal     @db.Decimal(10, 2)
  description String?
  orderItems  OrderItem[]
  createdAt   DateTime    @default(now())
}

model Order {
  id         String     @id @default(cuid())
  userId     String
  user       User       @relation(fields: [userId], references: [id])
  items      OrderItem[]
  total      Decimal    @db.Decimal(10, 2)
  status     String     @default("pending")
  createdAt  DateTime   @default(now())
  
  @@index([userId])
}

model OrderItem {
  id        String   @id @default(cuid())
  orderId   String
  productId String
  order     Order    @relation(fields: [orderId], references: [id])
  product   Product  @relation(fields: [productId], references: [id])
  quantity  Int
  price     Decimal  @db.Decimal(10, 2)
  
  @@index([orderId])
  @@index([productId])
}

// NL2SQL 関数の実装
async function nl2sql(question: string, schema: DatabaseSchema): Promise<string> {
  const prompt = `データベースの Schema に基づいて、質問を SQL に変換してください：

Schema: ${JSON.stringify(schema)}
質問: ${question}

SQL のみを返し、パラメータ化クエリを使用してください。`;

  const sql = await callLLM(prompt);
  return validateAndSanitizeSQL(sql);
}

// 使用例
const sql = await nl2sql(
  "直近 1 週間に作成されたすべての記事とその著者情報を検索する",
  { tables: { users: [...], posts: [...] } }
);
// 戻り値: SELECT p.*, u.name as author_name 
//       FROM posts p 
//       JOIN users u ON p.author_id = u.id 
//       WHERE p.created_at > NOW() - INTERVAL '7 days'

// RAG 完全なフロー
async function ragQuery(question: string) {
  // 1. 質問のベクトル化
  const questionEmbedding = await getEmbedding(question);
  
  // 2. ベクトル検索（Pinecone）
  const results = await pineconeIndex.query({
    vector: questionEmbedding,
    topK: 5,
    includeMetadata: true
  });
  
  // 3. コンテキストを構築
  const context = results.matches
    .map(m => m.metadata?.text)
    .join('\n\n');
  
  // 4. LLM が回答を生成
  const answer = await generateAnswer(question, context);
  
  return answer;
}

// 使用
const answer = await ragQuery("Prisma とは何ですか？");
// AI は検索された文書に基づいて正確な回答を生成する