Turso 边缘数据库¶

# 安装CLI
curl -sSfL https://get.tur.so/install.sh | bash

# 登录
turso auth login

# 创建数据库
turso db create my-app-db

# 获取连接URL
turso db show my-app-db --url

# 创建认证token
turso db tokens create my-app-db

# JavaScript/TypeScript
npm install @libsql/client

# Python
pip install libsql-client

# Rust
cargo add libsql

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

const client = createClient({
  url: 'libsql://my-app-db-username.turso.io',
  authToken: process.env.TURSO_AUTH_TOKEN,
});

// 创建表
await client.execute(`
  CREATE TABLE IF NOT EXISTS users (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    name TEXT NOT NULL,
    email TEXT UNIQUE,
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
  )
`);

// 插入
await client.execute({
  sql: 'INSERT INTO users (name, email) VALUES (?, ?)',
  args: ['张三', 'zhangsan@example.com'],
});

// 查询
const result = await client.execute('SELECT * FROM users');
console.log(result.rows);

// 批量操作(事务)
await client.batch([
  { sql: 'INSERT INTO users (name, email) VALUES (?, ?)', args: ['李四', 'lisi@example.com'] },
  { sql: 'INSERT INTO users (name, email) VALUES (?, ?)', args: ['王五', 'wangwu@example.com'] },
], 'write');

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

// 本地副本 + 远程同步
const client = createClient({
  url: 'file:local-replica.db',  // 本地文件
  syncUrl: 'libsql://my-app-db-username.turso.io',  // 远程同步
  authToken: process.env.TURSO_AUTH_TOKEN,
  syncInterval: 60,  // 每60秒同步
});

// 读操作：从本地副本读(极快)
const users = await client.execute('SELECT * FROM users');

// 写操作：写入远程，然后同步到本地
await client.execute({
  sql: 'INSERT INTO users (name) VALUES (?)',
  args: ['新用户'],
});

// 手动同步
await client.sync();

import { drizzle } from 'drizzle-orm/libsql';
import { createClient } from '@libsql/client';
import { sqliteTable, text, integer } from 'drizzle-orm/sqlite-core';

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

const db = drizzle(client);

// Schema
const users = sqliteTable('users', {
  id: integer('id').primaryKey({ autoIncrement: true }),
  name: text('name').notNull(),
  email: text('email').unique(),
});

// 类型安全查询
const allUsers = await db.select().from(users);
await db.insert(users).values({ name: '张三', email: 'z@t.com' });

# 每个租户一个数据库
turso db create tenant-001
turso db create tenant-002

# 使用Platform API管理
curl -X POST 'https://api.turso.tech/v1/organizations/{org}/databases' \
  -H "Authorization: Bearer $TURSO_API_TOKEN" \
  -d '{"name": "tenant-003", "group": "default"}'

# 从生产创建分支(用于开发)
turso db create my-app-dev --from-db my-app-db