一、分布式数据库基础
1. 核心概念速记表
术语 | 解释 | 示例场景 |
---|---|---|
分布式数据库 | 数据自动同步到同账号设备 | 手机添加商品→平板立即显示 |
KV数据模型 | 键值对存储(类似JSON) | {"cart_item1": {"name":"牛奶","price":10}} |
数据同步策略 | 自动(实时)/手动(按需) | 手表仅同步关键健康数据 |
冲突解决 | 最后写入优先/自定义合并规则 | 手机平板同时修改商品数量 |
2. 基础操作代码块
// 1. 创建分布式数据库
const DB_NAME = 'shopping_cart_db'
const store = relationalStore.getRdbStore(this.context, {name: DB_NAME,distributed: true // 关键配置!
})// 2. 创建表(购物车示例)
await store.executeSql(`CREATE TABLE IF NOT EXISTS cart (item_id TEXT PRIMARY KEY,name TEXT,price REAL,count INTEGER)`
)// 3. 插入数据(多设备自动同步)
await store.insert('cart', {item_id: '1001',name: '鸿蒙开发板',price: 599,count: 1
})
二、进阶实战:购物车多端同步
1. 数据同步冲突处理
// 设置冲突解决策略(在数据库初始化时)
store.setConflictResolver((localData, remoteData) => {// 规则1:价格冲突时取最低价if (localData.price !== remoteData.price) {return localData.price < remoteData.price ? localData : remoteData}// 规则2:数量冲突时求和return { ...localData, count: localData.count + remoteData.count }}
)
2. 设备差异化同步
// 根据设备类型选择同步字段(手表不同步图片)
const syncColumns = deviceInfo.deviceType === 'watch' ? ['item_id', 'name', 'price'] : ['*']store.sync({tables: ['cart'],columns: syncColumns,mode: relationalStore.SyncMode.PUSH_PULL
})
三、性能优化技巧
1. 优化方案
- 数据分片:大表按时间分片同步
store.sync({tables: ['cart'],condition: 'timestamp > ?',conditionArgs: [Date.now() - 86400000] // 只同步24小时内数据
})
2.索引优化:为高频查询字段添加索引
await store.executeSql('CREATE INDEX idx_price ON cart(price)')
3.批量操作:减少跨设备通信次数
await store.batchInsert('cart', itemList)
四、调试与问题排查
1. 常用调试命令
# 查看分布式同步日志
hdc shell hilog | grep DistributedDB# 强制重置本地数据库
hdc shell rm -rf /data/app/el2/100/database/包名/
2. 常见问题解决方案
问题现象 | 解决步骤 | 原理说明 |
---|---|---|
设备间数据不同步 | 1. 检查华为账号是否相同2. 验证网络状态3. 查看数据库权限 | 分布式安全策略限制 |
同步速度慢 | 1. 减少单次同步数据量2. 关闭非必要表的同步 | 蓝牙/WiFi带宽限制 |
频繁发生冲突 | 1. 优化冲突解决策略2. 添加时间戳字段辅助判断 | 多设备并发写入导致 |