# Supabase 集成专家 ## 目的基于超过 2,616 个官方文档文件，为使用 Supabase 构建应用程序提供全面、准确的指导。涵盖数据库操作、身份验证、实时功能、文件存储、边缘功能、矢量搜索和平台集成等各个方面。 ## 文档覆盖范围 **完全访问官方 Supabase 文档（如果可用）：** * **位置：** `docs/supabase_com/` * **文件：** 2,616 个 Markdown 文件 * **覆盖范围：** 完整指南、API 参考、客户端库和平台文档 **注意：** 必须单独提取文档： pipx 安装 docpull docpull https://supabase.com/docs -o .claude/skills/supabase/docs **主要领域：** * **数据库：** PostgreSQL、行级安全性 (RLS)、迁移、函数、触发器 * **身份验证：** 电子邮件/密码、OAuth、魔术链接、SSO、MFA、电话身份验证 * **实时：** 数据库更改、广播、状态、频道 * **存储：** 文件上传、图像转换、CDN、存储桶 * **边缘功能：** Deno 运行时、无服务器、全球部署 * **向量/AI：** pg向量、嵌入、语义搜索、RAG * **客户端库：** JavaScript、Python、Dart (Flutter)、Swift、Kotlin * **平台：** CLI、本地开发、分支、可观察性 * **集成：** Next.js、React、Vue、Svelte、React Native、Expo ## 何时使用当用户提及时调用： * **数据库：** PostgreSQL、Postgres、SQL、数据库、表、查询、迁移 * **Auth：**身份验证、登录、注册、OAuth、SSO、多因素、魔术链接 * **实时：**实时、订阅、websocket、实时数据、状态、广播 * **存储：** 文件上传、文件存储、图片、S3、CDN、存储桶 * **功能：** 边缘功能、无服务器、API、Deno、云功能 * **安全性：** 行级安全性、RLS、策略、权限、访问控制 * **AI/ML：**向量搜索、嵌入、pgvector、语义搜索、AI、RAG * **框架集成：** Next.js、React、Supabase 客户端、hooks ## 如何使用文档回答问题时： 1. **搜索特定主题：** # 使用Grep查找相关文档 grep -r “行级安全性” docs/supabase_com/ --include="*.md" 2. **查找指南：** # 指南按功能组织 ls 文档/supabase_com/guides_* 3. **检查参考文档：** # 客户端库的参考文档 ls 文档/supabase_com/reference_* ## 快速入门 ### 安装 npm 安装@supabase/supabase-js ### 初始化客户端从“@supabase/supabase-js”导入{createClient}；常量 supabase = createClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！，）； **环境变量：** * `NEXT_PUBLIC_SUPABASE_URL` \- 您的项目 URL（对客户端安全） * `NEXT_PUBLIC_SUPABASE_ANON_KEY` \- 匿名/公钥（对客户端安全） * `SUPABASE_SERVICE_ROLE_KEY` \- 管理密钥（仅限服务器端，绕过 RLS） ## 数据库操作 ### CRUD 操作 // 插入 const { 数据，错误 } = 等待 supabase .from("帖子") .插入({ 标题：“你好世界”，内容：“我的第一篇文章”， user_id: 用户.id, }) .select() .single(); // 读取（带过滤器） const { data: posts } = 等待 supabase .from("帖子") .选择（“*”） .eq("已发布", true) .order("created_at", { 升序: false }) .限制(10); // 更新 const { 数据，错误 } = 等待 supabase .from("帖子") .update({ 发布: true }) .eq("id", 帖子ID) .select() .single(); // 删除 const { error } =等待supabase.from("posts").delete().eq("id", postId); // Upsert（插入或更新） const { 数据，错误 } = 等待 supabase .from("个人资料") .upsert({ id: 用户.id, 姓名：“约翰·多伊”， update_at: new Date().toISOString(), }) .select(); ### 高级查询 // 连接 const { data } = 等待 supabase .from("帖子") .选择( ` *, 作者：个人资料（姓名，头像），评论(条) `, ） .eq("已发布", true); // 全文搜索 const { data } = 等待 supabase .from("帖子") .选择（“*”） .textSearch("标题", `'nextjs' & 'supabase'`); // 范围查询 const { data } = 等待 supabase .from("帖子") .选择（“*”） .gte(“创建时间”,“2024-01-01”) .lt("创建时间", "2024-12-31"); // JSON 查询 const { data } = 等待 supabase .from("帖子") .选择（“*”） .contains("元数据", { 标签: ["教程"] }); ### 数据库函数 // 调用存储过程 const { 数据，错误 } = 等待 supabase.rpc("get_user_stats", { user_id：用户ID， }); // 带过滤器的调用 const { data } = 等待 supabase .rpc("search_posts", { search_term: "supabase" }) .限制(10); ## 身份验证 ### 注册/登录 // 邮箱/密码注册 const { 数据，错误 } = 等待 supabase.auth.signUp({ 电子邮件：“user@example.com”，密码：“安全密码”，选项：{ 数据：{ 名字：“约翰”，姓氏：“母鹿”， }, }, }); // 邮箱/密码登录 const { 数据，错误 } = 等待 supabase.auth.signInWithPassword({ 电子邮件：“user@example.com”，密码：“安全密码”， }); // 魔术链接（无密码） const { 数据，错误 } = 等待 supabase.auth.signInWithOtp({ 电子邮件：“user@example.com”，选项：{ emailRedirectTo: "https://example.com/auth/callback", }, }); // 电话/短信 const { 数据，错误 } = 等待 supabase.auth.signInWithOtp({ 电话：“+1234567890”， }); ### OAuth 提供商 // 谷歌登录 const { 数据，错误 } = 等待 supabase.auth.signInWithOAuth({ 提供商：“谷歌”，选项：{ 重定向到：“http://localhost:3000/auth/callback”，范围：“个人资料电子邮件”， }, }); **支持的提供商：** * 谷歌、GitHub、GitLab、Bitbucket * Azure、苹果、Discord、Facebook * Slack、Spotify、Twitch、Twitter/X * Linear、Notion、Figma 等 ### 用户会话管理 // 获取当前用户常量{ 数据：{用户}， } = 等待supabase.auth.getUser(); // 获取会话常量{ 数据：{会话}， } = 等待supabase.auth.getSession(); // 退出 const { 错误 } = 等待 supabase.auth.signOut(); // 监听授权变化 supabase.auth.onAuthStateChange((事件，会话) => { 如果（事件===“SIGNED_IN”）{ console.log("用户登录：", session.user); } 如果（事件===“SIGNED_OUT”）{ console.log("用户已退出"); } 如果（事件===“TOKEN_REFRESHED”）{ console.log("令牌已刷新"); } }); ### 多重身份验证 (MFA) // 注册 MFA const { 数据，错误 } = 等待 supabase.auth.mfa.enroll({ 因素类型：“托普”， FriendlyName：“我的身份验证器应用程序”， }); // 验证MFA const { 数据，错误 } = 等待 supabase.auth.mfa.challengeAndVerify({ 因子Id：数据.id，代码：“123456”， }); // 列出因素 const { data: Factors } = wait supabase.auth.mfa.listFactors(); ## 行级安全性 (RLS) ### 启用 RLS -- 在表上启用 RLS ALTER TABLE posts 启用行级安全； ### 创建策略 -- 公共读取权限创建策略“每个人都可以查看帖子” ON 帖子供选择使用（真实）； -- 用户可以插入自己的帖子创建策略“用户可以创建帖子” 在帖子上插入带检查（auth.uid（）= user_id）； -- 用户只能更新自己的帖子创建策略“用户可以更新自己的帖子” 更新帖子 USING (auth.uid() = user_id); -- 用户只能删除自己的帖子创建策略“用户可以删除自己的帖子” 关于要删除的帖子 USING (auth.uid() = user_id); -- 条件访问（例如高级用户）创建政策“为优质用户提供优质内容” ON 帖子供选择使用（不是高级版或 (auth.uid() IN ( 从订阅中选择 user_id WHERE 状态 = '活动' ）））； ### 辅助函数 -- 获取当前用户ID auth.uid() -- 获取当前JWT auth.jwt() -- 访问 JWT 声明 (auth.jwt()->>'角色')::文本 (auth.jwt()->>'电子邮件')::文本 ## 实时订阅 ### 监听数据库变化常量通道=supabase .channel("帖子更改") .on( “postgres_changes”， { event: "*", // 或 'INSERT', 'UPDATE', 'DELETE' 架构：“公共”，表：“帖子”， }, （有效负载）=> { console.log("收到更改：", Payload); }, ） .subscribe(); // 清理频道.取消订阅(); ### 过滤实时事件 // 只监听特定用户的帖子常量通道=supabase .channel("我的帖子") .on( “postgres_changes”， { 事件：“插入”，架构：“公共”，表：“帖子”，过滤器：`user_id=eq.${userId}`, }, （有效负载）=> { console.log("新帖子：", Payload.new); }, ） .subscribe(); ### 广播（短暂消息） const channel = supabase.channel("聊天室"); // 发送消息等待频道.发送({ 类型：“广播”，事件：“消息”，有效负载：{文本：“你好！”，用户：“约翰”}， }); // 接收消息 Channel.on("广播", { 事件: "消息" }, (有效负载) => { console.log("消息：", Payload.payload); }); 等待频道.subscribe(); ### 状态跟踪 const 通道 = supabase.channel("room-1"); // 跟踪存在频道 .on("存在", { 事件: "同步" }, () => { const state = Channel.presenceState(); console.log("在线用户：", Object.keys(state).length); }) .on("存在", { 事件: "加入" }, ({ key, newPresences }) => { console.log("用户加入：", newPresences); }) .on("存在", { 事件: "离开" }, ({ key, leftPresences }) => { console.log("用户离开：", leftPresences); }) .subscribe(异步（状态）=> { 如果（状态===“已订阅”）{ 等待频道.track({ user_id：用户ID， online_at: new Date().toISOString(), }); } }); ＃＃贮存 ### 上传文件 const 文件 = event.target.files[0]; const { 数据，错误 } = 等待 supabase.storage .from("头像") .upload(`public/${userId}/avatar.png`, 文件, { 缓存控制：“3600”，更新插入：正确， }); // 从base64上传 const { 数据，错误 } = 等待 supabase.storage .from("头像") .upload("文件.png", 解码(base64String), { 内容类型：“图像/png”， }); ### 下载文件 // 下载为 blob const { 数据，错误 } = 等待 supabase.storage .from("头像") .download("public/avatar.png"); const url = URL.createObjectURL(data); ### 公共 URL // 获取公共 URL（对于公共存储桶） const { 数据 } = supabase.storage .from("头像") .getPublicUrl("public/avatar.png"); console.log(data.publicUrl); ### 签名 URL（私人文件） // 创建临时访问URL const { 数据，错误 } = 等待 supabase.storage .from("私人文件") .createSignedUrl("文档.pdf", 3600); // 1 小时 console.log(data.signedUrl); ### 图像转换 const { data } = supabase.storage.from("avatars").getPublicUrl("avatar.png", { 变换：{ 宽度：400，高度：400， resize: "cover", // '包含', '覆盖', '填充' 质量：80， }, }); ### 列出文件 const { data, error } = wait supabase.storage.from("avatars").list("public", { 限制：100，偏移量：0， sortBy: { 列: "created_at", 顺序: "desc" }, }); ## 边函数 ### 创建函数 # 安装 Supabase CLI npm install -g supabase # 初始化项目超级数据库初始化 # 创建函数 SUPABASE 函数新的 my-function ### 函数示例 // supabase/functions/my-function/index.ts 从“https://esm.sh/@supabase/supabase-js@2”导入{createClient}； Deno.serve(async (req) => { 尝试{ // 初始化Supabase客户端常量 supabase = createClient( Deno.env.get("SUPABASE_URL")!, Deno.env.get("SUPABASE_ANON_KEY")!, { 全局：{ headers: { 授权: req.headers.get("授权")! }, }, }, ）； // 获取经过身份验证的用户常量{ 数据：{用户}，错误：验证错误， } = 等待supabase.auth.getUser(); if (authError || !user) { 返回新的响应（JSON.stringify（{错误：“未经授权”}），{ 状态：401， headers: { "Content-Type": "application/json" }, }); } // 查询数据库 const { 数据：帖子，错误 } = 等待 supabase .from("帖子") .选择（“*”） .eq("user_id", user.id); 如果（错误）{ 抛出错误； } 返回新的响应（JSON.stringify（{帖子}），{ headers: { "Content-Type": "application/json" }, }); } 捕获（错误）{ 返回新的响应（JSON.stringify（{错误：error.message}），{ 状态：500， headers: { "Content-Type": "application/json" }, }); } }); ### 部署函数 # 部署单一功能 SUPABASE 函数部署 my-function # 部署所有功能 SUPABASE功能部署 ### 调用函数 const { 数据，错误 } = 等待 supabase.functions.invoke("my-function", { 正文：{名称：“世界”}， }); 控制台.log(数据); ## 矢量搜索（AI/ML） ### 启用 pgvector -- 启用扩展如果不存在则创建扩展向量； -- 创建带有向量列的表创建表文档（ id BIGSERIAL 主键，内容文本，嵌入 VECTOR(1536) -- OpenAI ada-002 尺寸）； -- 创建HNSW索引以进行快速相似性搜索使用 hnsw 创建文档索引（嵌入向量余弦操作）； ### 存储嵌入从“openai”导入OpenAI； const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY }); // 生成嵌入 const 响应 = 等待 openai.embeddings.create({ 型号：“文本嵌入-ada-002”，输入：“Supabase 太棒了”， }); const 嵌入 = response.data[0].embedding; // 存储在数据库中 const { 数据，错误 } =等待supabase.from(“文档”).insert({ 内容：“Supabase 太棒了”，嵌入， }); ### 相似性搜索 // 查找相似文档 const { 数据，错误 } = 等待 supabase.rpc("match_documents", { query_embedding：嵌入，匹配阈值：0.78，匹配次数：10， }); **相似性搜索功能：** 创建函数 match_documents ( 查询嵌入向量（1536）， match_threshold FLOAT，匹配计数 INT ）退货表（ ID 大整数，内容文本，相似度 FLOAT ）语言 plpgsql 作为$$ 开始返回查询选择文档.id, 文件.内容, 1 - (documents.embedding <=> query_embedding) AS 相似性来自文档 WHERE 1 - (documents.embedding <=> query_embedding) > match_threshold ORDER BY files.embedding <=> query_embedding 限制匹配次数；结尾; $$; ## Next.js 集成 ### 服务器组件 // 应用程序/帖子/page.tsx 从“@supabase/ssr”导入{createServerClient}；从“next/headers”导入{cookies}；导出默认异步函数 PostsPage() { const cookieStore = cookies(); const supabase = createServerClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！， { 饼干：{ 获取全部() { 返回 cookieStore.getAll(); }, setAll(cookiesToSet) { 尝试{ cookiesToSet.forEach(({ 名称, 值, 选项 }) => cookieStore.set（名称，值，选项），）； } 抓住 { // 从服务器组件调用 - 忽略 } }, }, }, ）； } ### 客户端组件 // 应用程序/new-post/page.tsx '使用客户端'；从 '@supabase/ssr' 导入 { createBrowserClient }；从'react'导入{useState}；导出默认函数 NewPostPage() { const supabase = createBrowserClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！）； const [标题，setTitle] = useState(''); const handleSubmit = async (e: FormEvent) => { e.preventDefault(); const { 错误 } = 等待 supabase .from('帖子') .insert({ 标题 }); 如果（错误）console.error（错误）； }; 返回 ; } ### 中间件（身份验证保护） // 中间件.ts 从“@supabase/ssr”导入{createServerClient}；从“next/server”导入{NextResponse，输入NextRequest}；导出异步函数中间件（请求：NextRequest）{ 让响应 = NextResponse.next({ 请求， }); const supabase = createServerClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！， { 饼干：{ 获取全部() { 返回 request.cookies.getAll(); }, setAll(cookiesToSet) { for (cookiesToSet 的 const { 名称, 值 }) { request.cookies.set(名称, 值); } 响应 = NextResponse.next({ 请求， }); for (cookiesToSet 的 const { 名称、值、选项 }) { response.cookies.set(名称、值、选项); } }, }, }, ）； const { 数据，错误 } =等待supabase.auth.getClaims(); 如果（错误）{ 抛出错误； } const 用户 = 数据？.claims； // 如果未通过身份验证，则重定向到登录 if (!user && request.nextUrl.pathname.startsWith("/dashboard")) { return NextResponse.redirect(new URL("/login", request.url)); } 返回响应； } 导出常量配置= { 匹配器：[“/仪表板/：路径*”]， }; ### 路由处理程序 // 应用程序/api/posts/route.ts 从“@supabase/ssr”导入{createServerClient}；从“next/headers”导入{cookies}；从“next/server”导入{NextResponse}；异步函数 createClient() { const cookieStore = 等待 cookies(); 返回创建服务器客户端（ process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！， { 饼干：{ 获取全部() { 返回 cookieStore.getAll(); }, setAll(cookiesToSet) { 尝试{ for (cookiesToSet 的 const { 名称、值、选项 }) { cookieStore.set(名称、值、选项); } } 抓住 { // 从服务器组件调用 - 忽略 } }, }, }, ）； } 导出异步函数 GET() { const supabase = 等待 createClient(); const { data: posts } = wait supabase.from("posts").select("*"); 返回 NextResponse.json({ posts }); } 导出异步函数 POST(request: Request) { const supabase = 等待 createClient(); const body =等待request.json(); const { 数据，错误 } = 等待 supabase .from("帖子") .插入（正文） .select() .single(); 如果（错误）{ 返回 NextResponse.json({ 错误: error.message }, { 状态: 400 }); } 返回 NextResponse.json({ post: 数据 }); } ## 数据库迁移 ### 创建迁移 SUPABASE迁移新的create_posts_table ### 迁移文件示例 --supabase/migrations/20241116000000_create_posts_table.sql -- 创建表创建表帖子（ id UUID 默认 gen_random_uuid() 主键， user_id UUID 引用 auth.users NOT NULL, 标题文本不为空，内容文本，发布 BOOLEAN DEFAULT false， create_at TIMESTAMP with TIME ZONE DEFAULT timezone('utc'::text, now()) NOT NULL, Updated_at TIMESTAMP 带时区默认 timezone('utc'::text, now()) NOT NULL ）； -- 启用 RLS ALTER TABLE posts 启用行级安全； -- 制定政策创建策略“每个人都可以查看公共帖子” ON 帖子供选择使用（已发布= true）；创建策略“用户可以查看自己的帖子” ON 帖子供选择 USING (auth.uid() = user_id); 创建策略“用户可以创建帖子” 在帖子上插入带检查（auth.uid（）= user_id）；创建策略“用户可以更新自己的帖子” 更新帖子 USING (auth.uid() = user_id); -- 创建索引创建索引 posts_user_id_idx ON posts(user_id); 创建索引 posts_created_at_idx ON posts(created_at DESC); 在帖子（已发布）上创建索引 posts_published_idx WHERE 已发布 = true; -- 创建updated_at触发器创建或替换函数handle_updated_at() 回报触发为$$ 开始 NEW.updated_at = NOW(); 返回新的；结尾; $$ 语言 plpgsql; 创建触发器 set_updated_at 更新帖子之前对于每一行执行函数handle_updated_at(); ### 运行迁移 # 在本地应用迁移 SUPABASE 数据库重置 # 推送到远程（生产） SUPABASE数据库推送 ## TypeScript 集成 ### 数据库类型生成 # 从数据库模式生成类型 supabase gen 类型 typescript --project-id YOUR_PROJECT_ID > types/supabase.ts # 或者来自本地开发 supabase gen 类型 typescript --local > types/supabase.ts ### 类型安全客户端 // lib/supabase/types.ts 导出类型 Json = |字符串 |数量 |布尔值 |空 | { [键：字符串]：Json |未定义} | Json[]; 导出接口数据库{ 公共：{ 表：{ 帖子：{ 行：{ id：字符串；创建于：字符串；标题：字符串；内容：字符串|无效的; 用户 ID：字符串；发布：布尔值； }; 插入：{ id？：字符串；创建于？：字符串；标题：字符串；内容？：字符串 |无效的; 用户 ID：字符串；已发布？：布尔值； }; 更新：{ id？：字符串；创建于？：字符串；标题？：字符串；内容？：字符串 |无效的; user_id？：字符串；已发布？：布尔值； }; }; 配置文件：{ 行：{ id：字符串；名称：字符串|无效的; avatar_url: 字符串 |无效的; 创建于：字符串； }; 插入：{ id：字符串；名称？：字符串 |无效的; avatar_url？：字符串 |无效的; 创建于？：字符串； }; 更新：{ id？：字符串；名称？：字符串 |无效的; avatar_url？：字符串 |无效的; 创建于？：字符串； }; }; }; 浏览次数：{ [_在从不]：从不； }; 功能：{ [_在从不]：从不； }; 枚举：{ [_在从不]：从不； }; }; } // lib/supabase/client.ts 从“@supabase/supabase-js”导入{createClient}；从“./types”导入{数据库}；导出 const supabase = createClient<数据库>( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！，）； // 现在你获得了完整的类型安全！ const { data } = 等待 supabase .from("posts") // ✅ TypeScript 知道该表存在 .select("title, content,profiles(name)") // ✅ TypeScript 验证列 .eq("已发布", true); // ✅ TypeScript 验证类型 // 数据输入为： // 数组<{ 标题: 字符串;内容：字符串|无效的;配置文件：{名称：字符串|空 } }> ### 服务器与客户端 Supabase // lib/supabase/client.ts - 客户端（尊重 RLS）从“@supabase/ssr”导入{createBrowserClient}；从“./types”导入{数据库}；导出函数createClient() { 返回 createBrowserClient<数据库>( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！，）； } // lib/supabase/server.ts - 服务器端（Next.js 应用程序路由器）从“@supabase/ssr”导入{createServerClient}；从“next/headers”导入{cookies}；从“./types”导入{数据库}；导出异步函数createClient() { const cookieStore = 等待 cookies(); 返回 createServerClient<数据库>( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！， { 饼干：{ 获取全部() { 返回 cookieStore.getAll(); }, setAll(cookiesToSet) { 尝试{ for (cookiesToSet 的 const { 名称、值、选项 }) { cookieStore.set(名称、值、选项); } } 抓住 { // 从服务器组件调用 - 忽略 } }, }, }, ）； } // lib/supabase/admin.ts - 管理客户端（绕过 RLS）从“@supabase/supabase-js”导入{createClient}；从“./types”导入{数据库}；导出 const supabaseAdmin = createClient<数据库>( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.SUPABASE_SERVICE_ROLE_KEY!, // ⚠️ 仅限服务器端！ { 授权：{ 自动刷新令牌：假，持久会话：假， }, }, ）； ## Next.js 应用程序路由器模式 ### 服务器组件（推荐） // 应用程序/帖子/page.tsx 从 '@/lib/supabase/server' 导入 { createClient } 导出默认异步函数 PostsPage() { const supabase = createClient() // 在服务器上获取数据（不需要加载状态！） const { data: posts } = 等待 supabase .from('帖子') .select('*, 配置文件(*)') .eq('已发布', true) .order('created_at', { 升序: false }) 返回（

{帖子？.map(帖子 => ( <文章键={post.id}>

{帖子.标题}

作者：{post.profiles?.name}

{post.content}

))}

） } ### 服务器突变操作 // 应用程序/操作/posts.ts “使用服务器”；从“@/lib/supabase/server”导入{createClient}；从“next/cache”导入{revalidatePath}；从“下一步/导航”导入{重定向}；导出异步函数 createPost(formData: FormData) { const supabase = createClient(); 常量{ 数据：{用户}， } = 等待supabase.auth.getUser(); 如果（！用户）{ 重定向（“/登录”）； } const title = formData.get("title") as string; const content = formData.get("content") as string; const { 错误 } = 等待 supabase.from("posts").insert({ 标题，内容， user_id: 用户.id, }); 如果（错误）{ 抛出新的错误（错误.消息）； } revalidatePath(“/帖子”); 重定向（“/帖子”）； } 导出异步函数 updatePost(id: string, formData: FormData) { const supabase = createClient(); 常量{ 数据：{用户}， } = 等待supabase.auth.getUser(); 如果（！用户）{ 抛出新错误（“未经授权”）； } const { 错误 } = 等待 supabase .from("帖子") .更新({ 标题：formData.get(“标题”)作为字符串，内容： formData.get("content") 作为字符串， }) .eq("id", id) .eq("user_id", user.id); // 确保用户拥有该帖子如果（错误）{ 抛出新的错误（错误.消息）； } revalidatePath(“/帖子”); } 导出异步函数deletePost(id: string) { const supabase = createClient(); 常量{ 数据：{用户}， } = 等待supabase.auth.getUser(); 如果（！用户）{ 抛出新错误（“未经授权”）； } const { 错误 } = 等待 supabase .from("帖子") .delete() .eq("id", id) .eq("user_id", user.id); 如果（错误）{ 抛出新的错误（错误.消息）； } revalidatePath(“/帖子”); } ### 实时客户端组件 // 应用程序/组件/PostsList.tsx “使用客户端” 从 'react' 导入 { useEffect, useState } 从 '@/lib/supabase/client' 导入 { createClient } 从'@/lib/supabase/types'导入{数据库} type Post = Database['public']['Tables']['posts']['Row'] 导出函数PostsList（{initialPosts}：{initialPosts：Post []}）{ const [帖子，setPosts] = useState(initialPosts) const supabase = createClient() 使用效果（（）=> { 常量通道=supabase .channel('帖子更改') .on( 'postgres_changes', { 事件：'*'，模式：'公共'，表：“帖子”，过滤器：'已发布=eq.true'， }, （有效负载）=> { if (payload.eventType === '插入') { setPosts(prev => [payload.new as Post, ...prev]) } else if (payload.eventType === '更新') { 设置帖子（上一篇 => 上一页. 地图（后 => post.id === 负载.new.id ？ (payload.new as Post) : 发布）） } else if (payload.eventType === '删除') { setPosts(prev => prev.filter(post => post.id !== payload.old.id)) } } ） .subscribe() 返回（）=> { supabase.removeChannel(通道) } }, [supabase]) 返回（

{posts.map(帖子 => ( <文章键={post.id}>

{帖子.标题}

{帖子内容}

))}

） } ### 路由处理程序 // 应用程序/api/posts/route.ts 从“@/lib/supabase/server”导入{createClient}；从“next/server”导入{ NextRequest, NextResponse }；导出异步函数 GET(请求: NextRequest) { const supabase = createClient(); const { searchParams } = 新 URL(request.url); const limit = parseInt(searchParams.get("limit") || "10"); const { 数据，错误 } = 等待 supabase .from("帖子") .选择（“*”） .eq("已发布", true) .order("created_at", { 升序: false }) .limit(限制); 如果（错误）{ 返回 NextResponse.json({ 错误: error.message }, { 状态: 500 }); } 返回 NextResponse.json(数据); } 导出异步函数 POST(request: NextRequest) { const supabase = createClient(); 常量{ 数据：{用户}， } = 等待supabase.auth.getUser(); 如果（！用户）{ 返回 NextResponse.json({ 错误: "未经授权" }, { 状态: 401 }); } const body =等待request.json(); const { 数据，错误 } = 等待 supabase .from("帖子") .插入({ ...身体， user_id: 用户.id, }) .select() .single(); 如果（错误）{ 返回 NextResponse.json({ 错误: error.message }, { 状态: 500 }); } 返回 NextResponse.json(数据); } ## 高级身份验证 ### 电子邮件/密码以及电子邮件确认 // 应用程序/操作/auth.ts “使用服务器”；从“@/lib/supabase/server”导入{createClient}；从“下一步/导航”导入{重定向}；导出异步函数signUp(formData: FormData) { const supabase = createClient(); const email = formData.get("email") as string; const 密码 = formData.get("密码") as string; const name = formData.get("name") as string; const { 错误 } = 等待 supabase.auth.signUp({ 电子邮件，密码，选项：{ 数据：{ name, // 存储在 auth.users.raw_user_meta_data 中 }, emailRedirectTo: `${process.env.NEXT_PUBLIC_URL}/auth/callback`, }, }); 如果（错误）{ 返回 { 错误：错误.消息 }; } return { success: true, message: "检查您的电子邮件以确认您的帐户" }; } 导出异步函数signIn(formData: FormData) { const supabase = createClient(); const email = formData.get("email") as string; const 密码 = formData.get("密码") as string; const { 错误 } = 等待 supabase.auth.signInWithPassword({ 电子邮件，密码， }); 如果（错误）{ 返回 { 错误：错误.消息 }; } 重定向（“/仪表板”）； } 导出异步函数signOut() { const supabase = createClient(); 等待 supabase.auth.signOut(); 重定向（“/”）； } ### OAuth（Google、GitHub 等） // 应用程序/操作/auth.ts 导出异步函数signInWithGoogle() { const supabase = createClient(); const { 数据，错误 } = 等待 supabase.auth.signInWithOAuth({ 提供商：“谷歌”，选项：{ 重定向到：`${process.env.NEXT_PUBLIC_URL}/auth/callback`, 查询参数：{ access_type: "离线", 提示：“同意”， }, }, }); 如果（数据？.url）{ 重定向（数据.url）； } } 导出异步函数signInWithGitHub() { const supabase = createClient(); const { 数据 } = 等待 supabase.auth.signInWithOAuth({ 提供者：“github”，选项：{ 重定向到：`${process.env.NEXT_PUBLIC_URL}/auth/callback`, 范围：“读取：用户用户：电子邮件”， }, }); 如果（数据？.url）{ 重定向（数据.url）； } } ### 魔法链接导出异步函数 sendMagicLink(email: string) { const supabase = createClient(); const { 错误 } = 等待 supabase.auth.signInWithOtp({ 电子邮件，选项：{ emailRedirectTo: `${process.env.NEXT_PUBLIC_URL}/auth/callback`, }, }); 如果（错误）{ 返回 { 错误：错误.消息 }; } return { success: true, message: "检查您的电子邮件中是否有登录链接" }; } ### 电话验证（短信）导出异步函数 sendPhoneOTP(phone: string) { const supabase = createClient(); const { 错误 } = 等待 supabase.auth.signInWithOtp({ 电话, }); 如果（错误）{ 返回 { 错误：错误.消息 }; } 返回 { 成功：真 }; } 导出异步函数 verifyPhoneOTP(phone: string, token: string) { const supabase = createClient(); const { 错误 } = 等待 supabase.auth.verifyOtp({ 电话, 令牌，类型：“短信”， }); 如果（错误）{ 返回 { 错误：错误.消息 }; } 重定向（“/仪表板”）； } ### 多重身份验证 (MFA) // 为用户启用MFA 导出异步函数enableMFA() { const supabase = createClient(); const { 数据，错误 } = 等待 supabase.auth.mfa.enroll({ 因素类型：“托普”，友好名称：“身份验证器应用程序”， }); 如果（错误）{ 抛出错误； } // data.totp.qr_code - 要扫描的二维码 // data.totp.secret - 手动输入的秘密返回数据； } // 验证MFA 导出异步函数 verifyMFA(factorId: string, code: string) { const supabase = createClient(); const { 数据，错误 } = 等待 supabase.auth.mfa.challengeAndVerify({ 因子 ID, 代码， }); 如果（错误）{ 抛出错误； } 返回数据； } ### 身份验证回调处理程序 // 应用程序/auth/callback/route.ts 从“@/lib/supabase/server”导入{createClient}；从“next/server”导入{ NextRequest, NextResponse }；导出异步函数 GET(请求: NextRequest) { const requestUrl = 新 URL(request.url); const code = requestUrl.searchParams.get("code"); 如果（代码）{ const supabase = createClient(); 等待 supabase.auth.exchangeCodeForSession(code); } // 重定向到仪表板或任何地方返回 NextResponse.redirect(new URL("/dashboard", request.url)); } ### 受保护的路由 // 中间件.ts 从“@supabase/ssr”导入{createServerClient}；从“next/server”导入{NextResponse，输入NextRequest}；导出异步函数中间件（请求：NextRequest）{ 让响应 = NextResponse.next({ 请求， }); const supabase = createServerClient( process.env.NEXT_PUBLIC_SUPABASE_URL!, process.env.NEXT_PUBLIC_SUPABASE_ANON_KEY！， { 饼干：{ 获取全部() { 返回 request.cookies.getAll(); }, setAll(cookiesToSet) { for (cookiesToSet 的 const { 名称, 值 }) { request.cookies.set(名称, 值); } 响应 = NextResponse.next({ 请求， }); for (cookiesToSet 的 const { 名称、值、选项 }) { response.cookies.set(名称、值、选项); } }, }, }, ）； const { 数据，错误 } =等待supabase.auth.getClaims(); 如果（错误）{ 抛出错误； } const 用户 = 数据？.claims； // 保护仪表板路由 if (request.nextUrl.pathname.startsWith("/dashboard") && !user) { return NextResponse.redirect(new URL("/login", request.url)); } // 将经过身份验证的用户重定向到身份验证页面 if (request.nextUrl.pathname.startsWith("/login") && 用户) { 返回 NextResponse.redirect(new URL("/dashboard", request.url)); } 返回响应； } 导出常量配置= { 匹配器：[“/仪表板/：路径*”，“/登录”，“/注册”]， }; ## 高级行级安全性 ### 复杂的 RLS 策略 -- 用户只能看到已发布的帖子或自己的草稿创建策略“用户可以阅读适当的帖子” ON 帖子供选择使用（已发布 = 真实或 auth.uid() = user_id ）； -- 用户只能更新自己的帖子创建策略“用户可以更新自己的帖子” 更新帖子使用 (auth.uid() = user_id) 带检查（auth.uid（）= user_id）； -- 基于团队的访问创建表团队（ id UUID 主键默认 uuid_generate_v4(), 名称文本不为空）；创建表 team_members ( team_id UUID 参考团队， user_id UUID 引用 auth.users，角色 TEXT CHECK (角色 IN ('所有者', '管理员', '成员')), 主键（团队 ID、用户 ID））；创建表 team_documents ( id UUID 主键默认 uuid_generate_v4(), team_id UUID 参考团队，标题文本，内容文本）； -- 只有团队成员才能看到团队文档创建策略“团队成员可以查看文档” ON team_documents FOR SELECT 使用（团队 ID IN ( 选择 team_id 来自团队成员其中 user_id = auth.uid() ））； -- 只有团队所有者/管理员可以删除创建策略“团队管理员可以删除文档” ON team_documents FOR DELETE 使用（团队 ID IN ( 选择 team_id 来自团队成员其中 user_id = auth.uid() AND 角色 IN ('所有者', '管理员') ））； ### 基于函数的 RLS -- 创建辅助函数创建或替换函数 is_team_admin(team_id UUID) 返回布尔值 $$ 开始返回存在（选择1 来自团队成员 WHERE team_members.team_id = is_team_admin.team_id AND team_members.user_id = auth.uid() AND team_members.role IN ('所有者', '管理员') ）；结尾; $$ 语言 plpgsql 安全定义器； -- 政策中的使用创建策略“管理员可以更新团队设置” 团队更新使用（is_team_admin（id））带检查（is_team_admin（id））； ### RLS 与 JWT 声明 -- 访问自定义 JWT 声明创建策略“高级用户可以查看高级内容” ON premium_content FOR SELECT 使用（ (auth.jwt() -> 'user_metadata' ->> 'subscription_tier') = 'premium' ）； -- 基于角色的访问创建策略“管理员拥有完全访问权限” 全部敏感数据使用（ (auth.jwt() -> 'user_metadata' ->> '角色') = '管理员' ）； ## 高级实时功能 ### 存在（谁在线） “使用客户端” 从 'react' 导入 { useEffect, useState } 从 '@/lib/supabase/client' 导入 { createClient } 导出函数 OnlineUsers() { const [onlineUsers, setOnlineUsers] = useState([]) const supabase = createClient() 使用效果（（）=> { constchannel = supabase.channel('在线用户') 频道 .on('存在', { 事件: '同步' }, () => { const 状态 = 通道.presenceState() const users = Object.values(state).flat() 设置在线用户（用户） }) .on('存在', { 事件: '加入' }, ({ newPresences }) => { console.log('用户加入：', newPresences) }) .on('存在', { 事件: '离开' }, ({ leftPresences }) => { console.log('离开的用户：', leftPresences) }) .subscribe(异步（状态）=> { 如果（状态==='已订阅'）{ // 跟踪该用户 const { data: { user } } =等待supabase.auth.getUser() 如果（用户）{ 等待频道.track({ user_id: 用户.id, 电子邮件：用户.电子邮件， online_at: new Date().toISOString(), }) } } }) 返回（）=> { supabase.removeChannel(通道) } }, []) 返回（

{onlineUsers.length} 个在线用户

{user.email}

） } ### 广播（发送消息） // 光标跟踪导出函数 CollaborativeCanvas() { const supabase = createClient() 使用效果（（）=> { const 通道 = supabase.channel('canvas') 频道 .on('广播', { 事件: '光标' }, (有效负载) => { // 更新光标位置更新游标(有效负载.有效负载) }) .subscribe() // 发送光标位置 const handleMouseMove = (e: MouseEvent) => { 频道.发送({ 类型：'广播'，事件：'光标'，有效负载：{x：e.clientX，y：e.clientY}， }) } window.addEventListener('mousemove',handleMouseMove) 返回（）=> { window.removeEventListener('mousemove',handleMouseMove) supabase.removeChannel(通道) } }, []) 返回<画布/> } ### Postgres 更改（数据库事件） // 监听特定列常量通道=supabase .channel("更改后") .on( “postgres_changes”， { 事件：“更新”，架构：“公共”，表：“帖子”， filter: "id=eq.123", // 特定行 }, （有效负载）=> { console.log(“更新后：”，payload); }, ） .subscribe(); // 监听多个表常量通道=supabase .channel("改变") .on( “postgres_changes”， { 事件：“*”，模式：“公共”，表：“帖子”}，处理PostChange，） .on( “postgres_changes”， { 事件：“*”，模式：“公共”，表：“评论”}，处理CommentChange，） .subscribe(); ## 高级存储 ### 图像转换 // 上传并转换导出异步函数 uploadAvatar(file: File, userId: string) { const supabase = createClient(); const fileExt = file.name.split(".").pop(); const fileName = `${userId}-${Date.now()}.${fileExt}`; const filePath = `头像/${fileName}`; const { 错误：uploadError } = 等待supabase.storage .from("头像") .upload(文件路径, 文件, { 缓存控制：“3600”，更新插入：假， }); 如果（上传错误）{ 抛出上传错误； } // 获取转换后的图片URL const { data } = supabase.storage.from("头像").getPublicUrl(filePath, { 变换：{ 宽度：200，高度：200，调整大小：“覆盖”，质量：80， }, }); 返回数据.publicUrl; } ### 签名 URL（私人文件） // 生成签名 URL（1 小时后过期）导出异步函数 getPrivateFileUrl(path: string) { const supabase = createClient(); const { 数据，错误 } = 等待 supabase.storage .from("私人文件") .createSignedUrl(路径, 3600); // 1 小时如果（错误）{ 抛出错误； } 返回数据.signedUrl; } // 上传到私有存储桶导出异步函数 uploadPrivateFile(file: File, userId: string) { const supabase = createClient(); const filePath = `${userId}/${file.name}`; const { 错误 } = 等待 supabase.storage .from("私人文件") .upload(文件路径, 文件); 如果（错误）{ 抛出错误； } 返回文件路径； } ### 存储 RLS -- 在 storage.objects 上启用 RLS 创建策略“用户可以上传到自己的文件夹” ON storage.objects FOR INSERT 带支票（ Bucket_id = '头像' AND (storage.foldername(name))[1] = auth.uid()::text ）；创建策略“用户可以查看自己的文件” ON storage.objects FOR SELECT 使用（ Bucket_id = '头像' AND (storage.foldername(name))[1] = auth.uid()::text ）；创建策略“用户可以更新自己的文件” ON storage.objects 用于更新使用（ Bucket_id = '头像' AND (storage.foldername(name))[1] = auth.uid()::text ）；创建策略“用户可以删除自己的文件” ON storage.objects FOR DELETE 使用（ Bucket_id = '头像' AND (storage.foldername(name))[1] = auth.uid()::text ）； ## 边函数 ### 基本边缘函数 //supabase/functions/hello/index.ts 从“https://deno.land/std@0.168.0/http/server.ts”导入{服务}；服务（异步（请求）=> { const { name } = wait req.json(); 返回新的 Response(JSON.stringify({ message: `Hello ${name}!` }), { headers: { "Content-Type": "application/json" }, }); }); ### 带有 Supabase 客户端的边缘功能 // supabase/functions/create-post/index.ts 从“https://deno.land/std@0.168.0/http/server.ts”导入{服务}；从“https://esm.sh/@supabase/supabase-js@2”导入{createClient}；服务（异步（请求）=> { 尝试{ 常量 supabaseClient = createClient( Deno.env.get("SUPABASE_URL") ?? "", Deno.env.get("SUPABASE_ANON_KEY") ?? "", { 全局：{ headers: { 授权: req.headers.get("授权")! }, }, }, ）； // 获取经过身份验证的用户常量{ 数据：{用户}，错误：用户错误， } = 等待supabaseClient.auth.getUser(); if (userError || !user) { 返回新的响应（JSON.stringify（{错误：“未经授权”}），{ 状态：401， }); } const { 标题，内容 } = wait req.json(); const { 数据，错误 } = 等待 supabaseClient .from("帖子") .插入({ 标题，内容， user_id: 用户.id, }) .select() .single(); 如果（错误）{ 抛出错误； } 返回新的响应（JSON.stringify（数据），{ headers: { "Content-Type": "application/json" }, }); } 捕获（错误）{ 返回新的响应（JSON.stringify（{错误：error.message}），{ 状态：500， }); } }); ### 计划边缘函数 (Cron) //supabase/functions/cleanup-old-data/index.ts 从“https://deno.land/std@0.168.0/http/server.ts”导入{服务}；从“https://esm.sh/@supabase/supabase-js@2”导入{createClient}；服务（异步（请求）=> { // 验证请求来自 Supabase Cron const authHeader = req.headers.get("授权"); if (authHeader !== `承载 ${Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")}`) { return new Response("未经授权", { status: 401 }); } 常量 supabase = createClient( Deno.env.get("SUPABASE_URL")!, Deno.env.get("SUPABASE_SERVICE_ROLE_KEY")!, ）； // 删除旧数据 const三十天前=新日期（）；三十天前.setDate(三十天前.getDate() - 30); const { 错误 } = 等待 supabase .from(“临时数据”) .delete() .lt("created_at",三十天前.toISOString()); 如果（错误）{ 返回新的响应（JSON.stringify（{错误：error.message}），{ 状态：500， }); } 返回新的 Response(JSON.stringify({ success: true })); }); // 在仪表板中配置：数据库 > Cron 作业 // 时间表：0 2 * * *（每天凌晨 2 点） // HTTP 请求：https://your-project.supabase.co/functions/v1/cleanup-old-data ### 从客户端调用边缘函数 // 客户端 const { 数据，错误 } = 等待 supabase.functions.invoke("hello", { 正文：{名称：“世界”}， }); // 自动包含 auth 标头常量{ 数据：{会话}， } = 等待supabase.auth.getSession(); const { 数据，错误 } = 等待 supabase.functions.invoke("create-post", { 正文：{ 标题：“我的帖子”，内容：“此处内容”， }, 标题：{ 授权：`承载${session?.access_token}`, }, }); ## 矢量搜索（AI/RAG） ### 启用 pgvector -- 启用向量扩展如果不存在则创建扩展向量； -- 创建带有嵌入列的表创建表文档（ id UUID 主键默认 uuid_generate_v4(), 内容文本不为空，元数据 JSONB，嵌入向量(1536), -- 对于 OpenAI ada-002（1536 维） NOW 时区默认的 TIMESTAMP create_at() ）； -- 创建索引以进行快速相似性搜索使用 ivfflat 在文档上创建索引（嵌入 vector_cosine_ops）与（列表= 100）； -- 或者使用 HNSW 以获得更好的性能 (Postgres 15+) 使用 hnsw 创建文档索引（嵌入向量余弦操作）； ### 生成并存储嵌入 // lib/embeddings.ts 从“openai”导入{OpenAI}； const openai = 新 OpenAI({ apiKey: process.env.OPENAI_API_KEY!, }); 导出异步函数generateEmbedding(text: string): Promise { const 响应 = 等待 openai.embeddings.create({ 型号：“文本嵌入-ada-002”，输入：文本， }); 返回response.data[0].embedding； } // 存储嵌入的文档导出异步函数 storeDocument(内容：字符串，元数据：任意) { const supabase = createClient(); const embedding =等待generateEmbedding（内容）； const { 数据，错误 } = 等待 supabase .from("文档") .插入({ 内容，元数据，嵌入， }) .select() .single(); 如果（错误）{ 抛出错误； } 返回数据； } ### 语义搜索 // 搜索相似文档导出异步函数 searchSimilarDocuments(query: string, limit = 5) { const supabase = createClient(); // 生成查询的嵌入 const queryEmbedding =等待generateEmbedding（查询）； // 使用RPC函数进行搜索 const { 数据，错误 } = 等待 supabase.rpc("match_documents", { query_embedding：查询嵌入， match_threshold: 0.78, // 最小相似度 match_count：限制， }); 如果（错误）{ 抛出错误； } 返回数据； } // 创建RPC函数创建或替换函数 match_documents ( 查询嵌入向量（1536）， match_threshold浮点数，匹配计数 int ）退货表（ id UUID, 内容文本，元数据 JSONB，相似度浮动）语言 SQL 稳定作为$$ 选择文档.id, 文件.内容, 文档.元数据， 1 - (documents.embedding <=> query_embedding) AS 相似性来自文档 WHERE 1 - (documents.embedding <=> query_embedding) > match_threshold ORDER BY files.embedding <=> query_embedding 限制匹配次数； $$; ### RAG（检索增强生成）导出异步函数 ragQuery(问题：字符串) { // 1.搜索相关文档 const relatedDocs = 等待 searchSimilarDocuments(问题, 5); // 2. 从相关文档构建上下文 const context = relatedDocs.map((doc) => doc.content).join("\n\n"); // 3. 使用 GPT 生成答案 const 完成 = 等待 openai.chat.completions.create({ 型号：“gpt-4”，消息：[ { 角色：“系统”，内容： “你是一个有用的助手。根据提供的上下文回答问题。”, }, { 角色：“用户”，内容: `上下文:\n${context}\n\n问题: ${question}`, }, ], }); 返回{ 答案：completion.choices[0].message.content，来源：相关文档， }; } ## 数据库函数和触发器 ### 自定义函数 -- 获取用户的帖子数创建或替换函数 get_user_post_count(user_id UUID) 返回整数为 $$ 选择计数(*)::整数来自帖子 WHERE posts.user_id = get_user_post_count.user_id; $$ 语言 SQL 稳定； -- 从 TypeScript 调用 const { 数据，错误 } = 等待 supabase.rpc('get_user_post_count', { user_id：用户ID， }) ### 触发器 -- 自动更新updated_at列创建或替换函数handle_updated_at() 回报触发为$$ 开始 NEW.updated_at = NOW(); 返回新的；结尾; $$ 语言 plpgsql; 创建触发器 set_updated_at 更新帖子之前对于每一行执行函数handle_updated_at(); -- 创建/删除帖子时更新帖子计数创建或替换函数 update_post_count() 回报触发为$$ 开始如果 TG_OP = '插入' 那么更新个人资料设置帖子计数 = 帖子计数 + 1 WHERE id = NEW.user_id; 返回新的； ELSIF TG_OP = '删除' 那么更新个人资料设置帖子计数 = 帖子计数 - 1 WHERE id = OLD.user_id; 返老还童；结束如果；结尾; $$ 语言 plpgsql; 创建触发器 update_post_count_trigger 在帖子上插入或删除后对于每一行执行函数 update_post_count(); ## 性能优化 ### 查询优化 // 不好：N+1查询问题 const { data: posts } = wait supabase.from("posts").select("*"); for (const post of posts) { const { 数据：作者 } = 等待 supabase .from("个人资料") .选择（“*”） .eq("id", post.user_id) .single(); } // 好：加入单个查询 const { data: posts } = wait supabase.from("posts").select(` *, 配置文件（身份证号，名字，头像网址） `); // 好：使用特定列 const { data: posts } = 等待 supabase .from("帖子") .select("id, title,created_at,profiles(name)") // 仅您需要的 .eq("已发布", true) .order("created_at", { 升序: false }) .限制(20); ### 索引 -- 经常过滤的列上的索引创建索引 posts_user_id_idx ON posts(user_id); 创建索引 posts_created_at_idx ON posts(created_at DESC); -- 部分索引（过滤）在帖子（已发布）上创建索引 posts_published_idx 发布地点 = true； -- 综合指数创建索引 posts_user_published_idx ON posts(user_id,published,created_at DESC); -- 全文检索索引在帖子上创建索引 posts_content_idx 使用 GIN (to_tsvector('english', content)); ### 连接池 // 使用连接池进行无服务器 (Supavisor) // 连接字符串: postgresql://postgres.[project-ref]:[password]@aws-0-us-east-1.pooler.supabase.com:6543/postgres 从“@supabase/supabase-js”导入{createClient}；常量 supabase = createClient( process.env.SUPABASE_URL!, process.env.SUPABASE_ANON_KEY!, { 数据库：{ 架构：“公共”， }, 全局：{ headers: { "x-my-custom-header": "my-app-name" }, }, }, ）； ### 缓存 // Next.js 缓存并重新验证从“next/cache”导入{unstable_cache}；从“@/lib/supabase/server”导入{createClient}；导出 const getCachedPosts =不稳定_缓存（异步（）=> { const supabase = createClient(); const { data } = 等待 supabase .from("帖子") .选择（“*”） .eq("已发布", true); 返回数据； }, [“帖子”]， { 重新验证: 300, // 5 分钟标签：[“帖子”]， }, ）； // 重新验证突变从“next/cache”导入{revalidateTag}；导出异步函数 createPost(data: any) { const supabase = createClient(); 等待 supabase.from("posts").insert(data); revalidateTag(“帖子”); } ## 本地发展 ### 设置本地 Supabase # 安装 Supabase CLI 酿造安装supabase/tap/supabase # 初始化项目超级数据库初始化 # 启动本地Supabase（需要Docker）超级数据库启动 # 这开始： # - PostgreSQL # - GoTrue（授权） # - 实时 # - 存储 # - Kong（API网关） # - 工作室（仪表板） ### 本地开发 URL # SUPABASE 启动后： API地址：http://localhost:54321 工作室网址：http://localhost:54323 Inbucket URL: http://localhost:54324 # 邮件测试 ### 迁移工作流程 # 创建迁移 SUPABASE迁移新的add_posts_table # 编辑supabase/migrations/中的迁移文件 # 本地应用迁移 SUPABASE 数据库重置 # 推送到生产环境 SUPABASE数据库推送 # 拉取远程模式 SUPABASE 数据库拉取 ### 从本地数据库生成类型 # 生成 TypeScript 类型 supabase gen 类型 typescript --local > types/database.ts ## 测试 ### 测试 RLS 策略 -- 以特定用户身份测试设置本地角色已验证； SET LOCAL "request.jwt.claims" TO '{"sub": "user-uuid-here"}'; -- 测试查询从帖子中选择 *； -- 重置重置角色； ### 使用 Supabase 测试助手进行测试 // 测试/posts.test.ts 从“@supabase/supabase-js”导入{createClient}；常量 supabase = createClient( process.env.SUPABASE_URL!, process.env.SUPABASE_SERVICE_ROLE_KEY!, // 用于测试）；描述（“帖子”，（）=> { beforeEach(异步() => { // 清理等待苏帕巴斯 .from("帖子") .delete() .neq("id", "00000000-0000-0000-0000-000000000000"); }); it("应该创建帖子", async () => { const { 数据，错误 } = 等待 supabase .from("帖子") .insert({ 标题: "测试", 内容: "测试" }) .select() .single(); 期望(错误).toBeNull(); 期望(data.title).toBe(“测试”); }); }); ## 错误处理 ### 综合错误处理程序从“@supabase/supabase-js”导入{PostgrestError}；导出函数handleSupabaseError（错误：PostgrestError | null）{ 如果（！错误）{ 返回空值； } // 常见错误码 const errorMessages: Record<字符串, 字符串> = { "23505": "该记录已存在", // 唯一违规 "23503": "未找到相关记录", // 外键违规 "42P01": "表不存在", "42501": "权限被拒绝", PGRST116：“未找到行”， }; const userMessage = errorMessages[错误代码] ||错误信息; console.error("Supabase 错误:", { 代码：错误代码，消息：错误消息，详细信息：错误。详细信息，提示：错误提示， }); 返回用户消息； } // 用法 const { data, error } = wait supabase.from("posts").insert(postData); 如果（错误）{ const 消息=handleSupabaseError(错误); 错误（消息）；返回; } ## 最佳实践 1. **行级安全性：** * 在所有表上启用 RLS * 切勿仅依赖客户端检查 * 彻底测试政策 * 谨慎使用服务角色密钥（仅限服务器端） 2. **查询优化：** * 使用 `.select()` 指定需要的列 * 为过滤/排序列添加数据库索引 * 使用 `.limit()` 限制结果 * 考虑对大型数据集进行分页 3. **实时订阅：** * 组件卸载时始终取消订阅 * 使用RLS策略过滤事件 * 使用广播来获取临时数据 * 限制同时订阅的数量 4. **身份验证：** * 尽可能将 JWT 存储在 httpOnly cookie 中 * 过期前刷新token * 处理授权状态变化 * 服务器端验证用户 5. **存储：** * 设置适当的存储桶策略 * 使用图像变换进行优化 * 考虑存储限制 * 清理未使用的文件 6. **错误处理：** * 始终检查`error`对象 * 提供用户友好的错误信息 * 记录错误以供调试 * 优雅地处理网络故障 ## 常见模式 ### 注册时自动创建个人资料 -- 创建配置文件表创建表配置文件（ id UUID 引用 auth.users 主键，名称文本， avatar_url 文本， NOW 时区默认的 TIMESTAMP create_at() ）； -- 触发功能创建或替换函数 public.handle_new_user() 回报触发为$$ 开始插入 public.profiles (id, name, avatar_url) 值（新.id, NEW.raw_user_meta_data->>'名称', NEW.raw_user_meta_data->>'avatar_url' ）；返回新的；结尾; $$ 语言 plpgsql 安全定义器； -- 触发在_auth_user_created 上创建触发器插入 auth.users 后对于每一行执行函数 public.handle_new_user(); ## 文档快速参考 **需要找到特定的东西吗？** 搜索 2,616 个文档文件： # 搜索所有文档 grep -r“搜索词”docs/supabase_com/ # 寻找指南 ls 文档/supabase_com/guides_* # 查找API参考 ls 文档/supabase_com/reference_* **常见文档位置：** * 指南：`docs/supabase_com/guides_*` * JavaScript 参考：`docs/supabase_com/reference_javascript_*` * 数据库：`docs/supabase_com/guides_database_*` * 授权：`docs/supabase_com/guides_auth_*` * 存储：`docs/supabase_com/guides_storage_*` ## 资源 * **仪表板：** * **文档：** * **状态：** * **CLI 文档：** ## 实施清单 * 创建Supabase项目 * 安装：`npm install @supabase/supabase-js` * 设置环境变量 * 设计数据库架构 * 创建迁移 * 启用 RLS 并创建策略 * 设置身份验证 * 实现授权状态管理 * 创建CRUD操作 * 添加实时订阅（如果需要） * 配置存储桶（如果需要） * 测试RLS策略 * 添加数据库索引 * 部署边缘功能（如果需要） * 生产中测试

苏帕贝专家

包含技能