#跟着晓明学鸿蒙# HarmonyOS Next数据持久化开发指南：高效存储与跨设备同步实践

2501_92043647

5人浏览 · 2025-05-21 16:36:07

2501_92043647 · 2025-05-21 16:36:07 发布

HarmonyOS Next数据持久化开发指南：高效存储与跨设备同步实践

一、本地轻量存储方案

1.1 用户首选项（Preferences）

import { preferences } from '@kit.ArkData';

// 初始化首选项实例
let pref = await preferences.getPreferences(this.context, 'user_profile');

// 存储用户偏好
await pref.put('dark_mode', true);
await pref.put('last_login', new Date().toISOString());

// 同步提交数据
await pref.flush();

// 读取配置项
let isDarkMode = await pref.get('dark_mode', false);

1.2 键值型数据库（DistributedKVStore）

import { distributedKVStore } from '@kit.ArkData';

// 创建数据库管理器
const kvManager = distributedKVStore.createKVManager({
  context: this.context,
  bundleName: 'com.example.myapp'
});

// 定义数据库结构
const options = {
  createIfMissing: true,
  encrypt: false,
  backup: false,
  autoSync: true
};

// 获取KVStore实例
let kvStore = await kvManager.getKVStore('user_cache', options);

// 存储结构化数据
await kvStore.put('user:1001', {
  name: '张三',
  level: 28,
  last_active: Date.now()
});

// 查询数据操作
const entry = await kvStore.getEntries('user:');
console.log(`匹配到${entry.length}条记录`);

二、关系型数据库方案

2.1 数据库初始化

import { relationalStore } from '@kit.ArkData';

// 定义数据表结构
const SQL_CREATE_TABLE = `
  CREATE TABLE IF NOT EXISTS task (
    id INTEGER PRIMARY KEY AUTOINCREMENT,
    title TEXT NOT NULL,
    completed BOOLEAN DEFAULT 0,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
  )`;

// 创建数据库连接
let store = await relationalStore.getRdbStore(this.context, {
  name: 'todo.db',
  securityLevel: relationalStore.SecurityLevel.S1
});

// 执行建表语句
await store.executeSql(SQL_CREATE_TABLE);

2.2 数据操作示例

// 插入新任务
const values = {
  title: '完成持久化模块开发',
  completed: 0
};
await store.insert('task', values);

// 更新任务状态
const predicates = new relationalStore.RdbPredicates('task');
predicates.equalTo('id', 5);
await store.update({ completed: 1 }, predicates);

// 复杂查询示例
const columns = ['id', 'title', 'created_at'];
predicates.notEqualTo('completed', 1)
          .orderByAsc('created_at');
const results = await store.query(predicates, columns);

三、跨设备数据同步

3.1 分布式数据对象

import { distributedDataObject } from '@kit.ArkData';

// 创建分布式数据对象
const source = {
  profile: {
    name: 'dev_member',
    permissions: ['read', 'write']
  },
  sessionToken: 'xxxx-xxxx-xxxx'
};

let dObject = distributedDataObject.create(this.context, source);

// 设置同步组网
dObject.setSessionId('dev_team_group');

// 监听数据变化
dObject.on('change', (sessionId, fields) => {
  console.log(`数据变化来自设备：${sessionId}`);
  console.log('变更字段：', fields);
});

// 修改分布式属性
dObject['profile'].permissions.push('admin');