【Day 14】HarmonyOS分布式数据库实战

一、分布式数据库基础

1. 核心概念速记表

 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. 优化方案

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. 常见问题解决方案