TiDB Cloud Serverless Driver (Beta)

为什么要使用 TiDB Cloud Serverless Driver (Beta)

传统的基于 TCP 的 MySQL 驱动并不适用于无服务器函数，因为它们期望建立长时间存在的、持久的 TCP 连接，这与无服务器函数的短生命周期特性相矛盾。此外，在 Vercel Edge Functions 和 Cloudflare Workers 等边缘环境中，可能缺乏对完整 TCP 的支持和完整的 Node.js 兼容性，这些驱动甚至可能无法工作。

TiDB Cloud serverless driver (Beta) 针对 JavaScript，可以让你通过 HTTP 连接到 TiDB Cloud Starter 或 TiDB Cloud Essential 集群，而 HTTP 通常被无服务器环境所支持。借助该驱动，现在可以从边缘环境连接到 TiDB Cloud Starter 或 TiDB Cloud Essential 集群，并在保持与传统基于 TCP 的 MySQL 驱动类似开发体验的同时，减少 TCP 带来的连接开销。

安装无服务器驱动

你可以通过 npm 安装该驱动：

npm install @tidbcloud/serverless

使用无服务器驱动

你可以使用无服务器驱动查询 TiDB Cloud Starter 或 TiDB Cloud Essential 集群的数据，或执行交互式事务。

查询

要从 TiDB Cloud Starter 或 TiDB Cloud Essential 集群查询数据，你需要先创建一个连接。然后可以使用该连接执行原生 SQL 查询。例如：

import { connect } from '@tidbcloud/serverless'

const conn = connect({url: 'mysql://[username]:[password]@[host]/[database]'})
const results = await conn.execute('select * from test where id = ?',[1])

事务（实验性）

你也可以使用无服务器驱动执行交互式事务。例如：

import { connect } from '@tidbcloud/serverless'

const conn = connect({url: 'mysql://[username]:[password]@[host]/[database]'})
const tx = await conn.begin()

try {
  await tx.execute('insert into test values (1)')
  await tx.execute('select * from test')
  await tx.commit()
} catch (err) {
  await tx.rollback()
  throw err
}

边缘环境示例

以下是在边缘环境中使用无服务器驱动的一些示例。你也可以尝试这个 在线演示 获取完整示例。

import { NextResponse } from 'next/server';
import type { NextRequest } from 'next/server';
import { connect } from '@tidbcloud/serverless'
export const runtime = 'edge'

export async function GET(request: NextRequest) {
  const conn = connect({url: process.env.DATABASE_URL})
  const result = await conn.execute('show tables')
  return NextResponse.json({result});
}

import { connect } from '@tidbcloud/serverless'
export interface Env {
  DATABASE_URL: string;
}
export default {
  async fetch(request: Request, env: Env, ctx: ExecutionContext): Promise<Response> {
    const conn = connect({url: env.DATABASE_URL})
    const result = await conn.execute('show tables')
    return new Response(JSON.stringify(result));
  },
};

import { connect } from 'https://esm.sh/@tidbcloud/serverless'

export default async () => {
  const conn = connect({url: Netlify.env.get('DATABASE_URL')})
  const result = await conn.execute('show tables')
  return new Response(JSON.stringify(result));
}

import { connect } from "npm:@tidbcloud/serverless"

const conn = connect({url: Deno.env.get('DATABASE_URL')})
const result = await conn.execute('show tables')

import { connect } from "@tidbcloud/serverless"

const conn = connect({url: Bun.env.DATABASE_URL})
const result = await conn.execute('show tables')

配置无服务器驱动

你可以在连接级别和 SQL 级别配置 TiDB Cloud serverless driver。

连接级别配置

在连接级别，你可以进行如下配置：

数据库 URL

当配置了 url 后，无需单独配置 host、username、password 和 database。以下代码是等价的：

const config = {
  host: '<host>',
  username: '<user>',
  password: '<password>',
  database: '<database>',
  arrayMode: true,
}

const conn = connect(config)

const config = {
  url: process.env['DATABASE_URL'] || 'mysql://[username]:[password]@[host]/[database]',
  arrayMode: true
}

const conn = connect(config)

SQL 级别选项

在 SQL 级别，你可以配置以下选项：

arrayMode 和 fullResult

如果你希望以数组形式返回完整的结果对象，可以如下配置 arrayMode 和 fullResult 选项：

const conn = connect({url: process.env['DATABASE_URL'] || 'mysql://[username]:[password]@[host]/[database]'})
const results = await conn.execute('select * from test',null,{arrayMode:true,fullResult:true})

isolation

isolation 选项只能在 begin 函数中使用。

const conn = connect({url: 'mysql://[username]:[password]@[host]/[database]'})
const tx = await conn.begin({isolation:"READ COMMITTED"})

decoders

如果你想自定义返回列值的格式，可以在 connect() 方法中配置 decoder 选项，如下所示：

import { connect, ColumnType } from '@tidbcloud/serverless';

const conn = connect({
  url: 'mysql://[username]:[password]@[host]/[database]',
  decoders: {
    // 默认情况下，TiDB Cloud serverless driver 会将 BIGINT 类型作为文本值返回。此解码器将 BIGINT 转换为 JavaScript 内置的 BigInt 类型。
    [ColumnType.BIGINT]: (rawValue: string) => BigInt(rawValue),
    
    // 默认情况下，TiDB Cloud serverless driver 会将 DATETIME 类型以 'yyyy-MM-dd HH:mm:ss' 格式的文本值返回。此解码器将 DATETIME 文本转换为 JavaScript 原生的 Date 对象。
    [ColumnType.DATETIME]: (rawValue: string) => new Date(rawValue),
  }
})

// 你也可以在 SQL 级别配置 decoder 选项，以覆盖连接级别中相同 key 的 decoders。
conn.execute(`select ...`, [], {
  decoders: {
    // ...
  }
})

功能特性

支持的 SQL 语句

支持 DDL，并支持以下 SQL 语句：SELECT、SHOW、EXPLAIN、USE、INSERT、UPDATE、DELETE、BEGIN、COMMIT、ROLLBACK 和 SET。

数据类型映射

TiDB 与 Javascript 之间的数据类型映射如下：

ORM 集成

TiDB Cloud serverless driver 已集成以下 ORM：

• TiDB Cloud serverless driver Kysely dialect。
• TiDB Cloud serverless driver Prisma adapter。

计费

无服务器驱动本身是免费的，但使用该驱动访问数据会产生 Request Units (RUs) 和存储用量。

• 对于 TiDB Cloud Starter 集群，计费遵循 TiDB Cloud Starter 计费 模型。
• 对于 TiDB Cloud Essential 集群，计费遵循 TiDB Cloud Essential 计费 模型。

限制

目前，使用无服务器驱动有以下限制：

• 单次查询最多可获取 10,000 行数据。
• 每次只能执行一条 SQL 语句，不支持在一个查询中执行多条 SQL 语句。
• 暂不支持通过 私有终端节点 连接。

后续步骤

• 了解如何 在本地 Node.js 项目中使用 TiDB Cloud serverless driver。