技能创建器
skill-creator
创建、改进和评估自定义技能,把专业流程转化为可重复使用的 AI 能力。
electric-sql【数据与研究】Build local-first applications with ElectricSQL — sync Postgres data to client devices in real-time. Use when someone asks to "sync database to client", "local-first app", "ElectricSQL", "offline-first sync", "real-time Postgres sync", "sync Postgres to SQLite", or "build an app that works offline". Covers shape-based sync, real-time subscriptions, o…
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
ElectricSQL syncs Postgres data to client applications in real-time. Instead of fetching data from an API, the data lives locally on the device — queries are instant, the app works offline, and changes sync automatically when connectivity returns. Think "Postgres replication to the browser." Define shapes (subsets of your data) and Electric keeps them in sync.
# Server: Electric sync service
docker run -e DATABASE_URL=postgresql://... -p 3000:3000 electricsql/electric
# Client
npm install @electric-sql/react
// shapes.ts — Define what data to sync to the client
/**
* Shapes are "live queries" — subsets of your Postgres data
* that stay in sync on the client. Only sync what the user needs.
*/
import { ShapeStream } from "@electric-sql/client";
// Sync all todos for a specific user — use a parameterized `where`
// (positional $1, $2, ... in `params.params`), never string-interpolate
// a value into the clause itself.
const stream = new ShapeStream({
url: "http://localhost:3000/v1/shape",
params: {
table: "todos",
where: "user_id = $1",
params: [userId],
},
});
// Stream delivers initial data + real-time updates
stream.subscribe((messages) => {
for (const msg of messages) {
if (msg.headers.operation === "insert") {
console.log("New todo:", msg.value);
}
}
});
// components/TodoList.tsx — Real-time synced todo list
import { useShape } from "@electric-sql/react";
interface Todo {
id: string;
title: string;
completed: boolean;
created_at: string;
}
export function TodoList({ userId }: { userId: string }) {
// Data syncs automatically — no loading states for reads
const { data: todos, isLoading } = useShape<Todo>({
url: "http://localhost:3000/v1/shape",
params: {
table: "todos",
where: "user_id = $1",
params: [userId],
columns: ["id", "title", "completed", "created_at"],
},
});
if (isLoading) return <div>Loading initial sync...</div>;
// Reads are instant — data is local
const active = todos.filter((t) => !t.completed);
const done = todos.filter((t) => t.completed);
return (
<div>
<h2>Active ({active.length})</h2>
{active.map((todo) => (
<div key={todo.id}>
<input
type="checkbox"
onChange={() => toggleTodo(todo.id)}
/>
{todo.title}
</div>
))}
<h2>Completed ({done.length})</h2>
{done.map((todo) => (
<div key={todo.id} style={{ textDecoration: "line-through" }}>
{todo.title}
</div>
))}
</div>
);
}
// Writes go through your API (Electric syncs the result back)
async function toggleTodo(id: string) {
await fetch(`/api/todos/${id}/toggle`, { method: "PATCH" });
// No need to refetch — Electric syncs the update automatically
}
// offline.ts — Electric handles offline automatically
/**
* When the device goes offline, reads still work (data is local).
* When connectivity returns, Electric syncs missed changes.
*
* For writes during offline, queue them and replay on reconnect:
*/
const writeQueue: Array<() => Promise<void>> = [];
async function createTodo(title: string) {
const action = () => fetch("/api/todos", {
method: "POST",
body: JSON.stringify({ title }),
});
if (navigator.onLine) {
await action();
} else {
writeQueue.push(action); // Queue for later
}
}
// Replay queued writes when back online
window.addEventListener("online", async () => {
while (writeQueue.length > 0) {
const action = writeQueue.shift()!;
await action();
}
});
User prompt: "Build a task manager that works without internet and syncs when back online."
The agent will set up Electric with shapes for user tasks, local reads with React hooks, write queue for offline mutations, and automatic sync on reconnect.
User prompt: "Build a dashboard that shows live data from our Postgres database without polling."
The agent will configure Electric shapes for dashboard metrics, subscribe to real-time updates, and render charts that update instantly as the database changes.
where for filtering — only sync data the user should see; pass values through the positional params array (where: "user_id = $1", params: [userId]), never string-interpolate a value into the where clause — Electric's HTTP API parses it as SQL and an interpolated value is a SQL-injection vectorcolumns for projection — reduce sync payload to needed fields