订阅表变更
实现客户端代码,监听指定数据库表或行的插入、更新和删除操作。
订阅表变更 是 CoddyKit 上的免费 Supabase Backend as a Service 课时。 这是第 2 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Supabase Backend as a Service 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Supabase Backend as a Service 课程共包含 4 节课。
本课时的部分内容尚未翻译,以英文显示。
Welcome to Live Data!
In the previous lesson, we learned about the idea of realtime data. Now, let's dive into how your app can actually listen for changes happening in your Supabase database!
This means your users can see updates instantly, without refreshing their screen. Think live chat, notifications, or dashboards.
The Realtime Client
Supabase provides a powerful Realtime client that makes listening for database changes super easy. It's built on PostgreSQL's replication features.
- It uses WebSockets for instant communication.
- You'll interact with it through the
supabase.realtimeobject. - It works by connecting to specific 'channels'.
Creating a Channel
Before listening to changes, you need to create a channel. A channel is like a dedicated line for receiving updates from your database.
You specify which table you're interested in, and then you can subscribe to events on that table.
import { createClient } from '@supabase/supabase-js';
const SUPABASE_URL = 'YOUR_SUPABASE_URL';
const SUPABASE_ANON_KEY = 'YOUR_ANON_KEY';
const supabase = createClient(SUPABASE_URL, SUPABASE_ANON_KEY);
// Create a channel for the 'messages' table
const messagesChannel = supabase.channel('table-db-changes')
.on(
'postgres_changes',
{ event: '*', schema: 'public', table: 'messages' },
(payload) => {
console.log('Change received!', payload);
}
)
.subscribe();
console.log('Subscribed to messages channel...');
// In a real app, you'd keep this running to listen.
// For this example, we'll just show the setup.
// You'd typically unsubscribe when the component unmounts.
// messagesChannel.unsubscribe();Listening for All Events
The example above uses event: '*'. This is a wildcard that tells Supabase you want to be notified about all types of changes to your specified table.
- INSERT: A new row was added.
- UPDATE: An existing row was modified.
- DELETE: A row was removed.
Each event type will trigger your callback function.
Code: All Table Changes
Let's refine our channel setup to explicitly listen for all event types on a products table. Imagine we're building an inventory app!
Run this code and imagine new products being added, updated, or deleted.
import { createClient } from '@supabase/supabase-js';
const SUPABASE_URL = 'YOUR_SUPABASE_URL';
const SUPABASE_ANON_KEY = 'YOUR_ANON_KEY';
const supabase = createClient(SUPABASE_URL, SUPABASE_ANON_KEY);
const productChanges = supabase.channel('product_updates')
.on(
'postgres_changes',
{ event: '*', schema: 'public', table: 'products' },
(payload) => {
console.log('Product change detected:', payload.eventType);
console.log('New data:', payload.new);
console.log('Old data:', payload.old);
}
)
.subscribe();
console.log('Listening for all changes on products table...');
// This script would typically run in a browser or Node.js environment
// where Supabase client is properly initialized and events would stream.
// For this interactive example, it shows the setup.
// In a real scenario, you'd wait for actual database events.
Targeting Specific Events
Sometimes you only care about certain types of changes. For instance, maybe you only want to know when a new item is added, not when it's updated or deleted.
You can specify the event type in your subscription options:
event: 'INSERT'event: 'UPDATE'event: 'DELETE'
Filtering by Row Data
Beyond event types, you can also filter updates based on the data within the rows themselves. This is super powerful for listening to changes on specific records!
Use conditions like eq (equals) or neq (not equals) on column values:
filter: 'id=eq.123'(Listen for changes to row with ID 123)filter: 'status=neq.archived'(Listen for changes where status is NOT archived)
Code: Filtered Changes
Let's set up a subscription that only listens for new products being added (INSERT) AND only if their category is 'electronics'.
Run this and see how specific you can get!
import { createClient } from '@supabase/supabase-js';
const SUPABASE_URL = 'YOUR_SUPABASE_URL';
const SUPABASE_ANON_KEY = 'YOUR_ANON_KEY';
const supabase = createClient(SUPABASE_URL, SUPABASE_ANON_KEY);
const newElectronics = supabase.channel('new_electronics_channel')
.on(
'postgres_changes',
{
event: 'INSERT',
schema: 'public',
table: 'products',
filter: 'category=eq.electronics' // Filter by category
},
(payload) => {
console.log('New electronic product added:', payload.new.name);
console.log('Details:', payload.new);
}
)
.subscribe();
console.log('Listening for new electronic products...');
// This code demonstrates the filter setup.
// Actual events would be logged if matching data is inserted.
Handling Incoming Data
When an event occurs, your callback function receives a payload object. This object contains all the details about the change:
eventType: 'INSERT', 'UPDATE', or 'DELETE'.new: The new row data (for INSERT/UPDATE).old: The old row data (for UPDATE/DELETE).table,schema: Info about where the change occurred.
This data lets you update your UI or trigger other logic.
Unsubscribing from Changes
It's important to unsubscribe from channels when they are no longer needed. This prevents memory leaks and unnecessary network traffic.
In a React component, you might unsubscribe in the componentWillUnmount or a useEffect cleanup function. Just call .unsubscribe() on your channel object.
const myChannel = supabase.channel('my_channel')
.on(...)
.subscribe();
// Later, when you're done listening:
myChannel.unsubscribe();
console.log('Unsubscribed from my_channel.');Quick Check: Realtime Filters
You want to listen for any updates to the orders table, specifically for orders where the status changes to 'shipped'.
Which options would you use in your on() method?
Recap: Stay Updated!
Great job! You've learned how to harness Supabase Realtime to listen for live database changes.
- You create a channel for a specific table.
- You use
.on('postgres_changes', options, callback)to subscribe. - You can filter by event type (
INSERT,UPDATE,DELETE) and by row data (e.g.,filter: 'column=eq.value'). - Always remember to unsubscribe when a channel is no longer needed.
Next, we'll build a live chat feature using these concepts!
常见问题解答
「订阅表变更」课时是免费的吗?
是的 — 「订阅表变更」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Supabase Backend as a Service 课程的其余内容,请升级到 CoddyKit PRO。 Supabase Backend as a Service 课程共包含 4 节课。
「订阅表变更」这节课中我会学到什么?
实现客户端代码,监听指定数据库表或行的插入、更新和删除操作。 你通过在浏览器中直接运行的动手代码来练习 Supabase Backend as a Service,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Supabase Backend as a Service 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Supabase Backend as a Service 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 2 节课,共 4 节。
「订阅表变更」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Supabase Backend as a Service 课中编写并运行代码吗?
能。每节 Supabase Backend as a Service 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。