TursoでSQLiteをクラウド化！AI時代の軽量データベースを解説

# Turso CLIのインストール
curl --proto '=https' --tlsv1.2 -LsSf \
  https://github.com/tursodatabase/turso/releases/latest/download/turso_cli-installer.sh | sh

# GitHubでログイン
turso auth login

# データベースを作成
turso db create my-app-db

# データベースURLを確認
turso db show my-app-db

# 認証トークンを生成
turso db tokens create my-app-db

# プロジェクト初期化
mkdir turso-demo
cd turso-demo
npm init -y

# Turso SDK（libSQL）をインストール
npm install @libsql/client

TURSO_DATABASE_URL=libsql://your-database-url.turso.io
TURSO_AUTH_TOKEN=your-auth-token-here

import { createClient } from '@libsql/client';
import dotenv from 'dotenv';

dotenv.config();

// Tursoクライアントを作成
const client = createClient({
  url: process.env.TURSO_DATABASE_URL,
  authToken: process.env.TURSO_AUTH_TOKEN
});

async function main() {
  try {
    // テーブル作成
    await client.execute(`
      CREATE TABLE IF NOT EXISTS users (
        id INTEGER PRIMARY KEY AUTOINCREMENT,
        name TEXT NOT NULL,
        email TEXT UNIQUE NOT NULL,
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
      )
    `);
    
    console.log('テーブルを作成しました');
    
  } catch (error) {
    console.error('エラー:', error);
  }
}

main();

import { createClient } from '@libsql/client';
import dotenv from 'dotenv';

dotenv.config();

const client = createClient({
  url: process.env.TURSO_DATABASE_URL,
  authToken: process.env.TURSO_AUTH_TOKEN
});

// ユーザーを作成
async function createUser(name, email) {
  const result = await client.execute({
    sql: 'INSERT INTO users (name, email) VALUES (?, ?)',
    args: [name, email]
  });
  
  console.log('ユーザーを作成しました:', result.lastInsertRowid);
  return result.lastInsertRowid;
}

// ユーザー一覧を取得
async function getUsers() {
  const result = await client.execute('SELECT * FROM users');
  return result.rows;
}

// ユーザーを更新
async function updateUser(id, name, email) {
  await client.execute({
    sql: 'UPDATE users SET name = ?, email = ? WHERE id = ?',
    args: [name, email, id]
  });
  
  console.log('ユーザーを更新しました:', id);
}

// ユーザーを削除
async function deleteUser(id) {
  await client.execute({
    sql: 'DELETE FROM users WHERE id = ?',
    args: [id]
  });
  
  console.log('ユーザーを削除しました:', id);
}

// 実行例
async function main() {
  try {
    // ユーザー作成
    const userId = await createUser('山田太郎', 'yamada@example.com');
    await createUser('佐藤花子', 'sato@example.com');
    
    // 一覧取得
    const users = await getUsers();
    console.log('ユーザー一覧:', users);
    
    // 更新
    await updateUser(userId, '山田次郎', 'yamada2@example.com');
    
    // 削除
    // await deleteUser(userId);
    
  } catch (error) {
    console.error('エラー:', error);
  }
}

main();

// lib/turso-manager.js
import { createClient } from '@libsql/client';

// Turso Platform APIを使ってユーザーごとのDBを作成
async function createUserDatabase(userId) {
  const response = await fetch('https://api.turso.tech/v1/databases', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.TURSO_API_TOKEN}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      name: `user-${userId}`,
      group: 'default'
    })
  });
  
  const data = await response.json();
  return data;
}

// ユーザー専用DBに接続
function getUserDatabaseClient(userId, authToken) {
  return createClient({
    url: `libsql://user-${userId}.turso.io`,
    authToken: authToken
  });
}

export { createUserDatabase, getUserDatabaseClient };

// app/api/users/[userId]/data/route.js
import { createClient } from '@libsql/client';
import { NextResponse } from 'next/server';

// ユーザー専用DBクライアントを取得
function getUserClient(userId) {
  return createClient({
    url: `libsql://user-${userId}.turso.io`,
    authToken: process.env.TURSO_AUTH_TOKEN
  });
}

// GET: ユーザーデータ取得
export async function GET(request, { params }) {
  const { userId } = params;
  const client = getUserClient(userId);
  
  try {
    const result = await client.execute('SELECT * FROM user_data');
    return NextResponse.json({ data: result.rows });
  } catch (error) {
    return NextResponse.json({ error: error.message }, { status: 500 });
  }
}

// POST: ユーザーデータ作成
export async function POST(request, { params }) {
  const { userId } = params;
  const body = await request.json();
  const client = getUserClient(userId);
  
  try {
    const result = await client.execute({
      sql: 'INSERT INTO user_data (title, content) VALUES (?, ?)',
      args: [body.title, body.content]
    });
    
    return NextResponse.json({ 
      id: result.lastInsertRowid,
      message: 'データを作成しました' 
    });
  } catch (error) {
    return NextResponse.json({ error: error.message }, { status: 500 });
  }
}