鸿蒙开发-端云一体化--云数据库

一、准备云数据库

        有两种方法，分别是云侧与端侧，推荐使用AGC网页段

        云侧

        （1）新增存储区   

                存储区内部包含多张表，每张表里包含具体的数据类型，且存储区可以把测试环境的数据和线上的数据区分开来

                        点击新增，输入存储区的名称，点击确定

        （2）新建对象类型（表）

                在数据页面上点击新增

                添加字段，选择类型，是否为主键 ，是否非空，是否加密，是否敏感，以及默认值 

                添加索引名，及其字段和排序顺序 

                确定数据权限，点击确定

         （3）添加对象数据

                在数据页点击添加，选择存储区名称和数据类型后添加值后，点击确定

二、端侧调用 

        （1）前提

                1、添加依赖

                在oh-package.json5中添加依赖

"dependencies": {        

         "@hw-agconnect/cloud": "^1.0.1",        

         "@hw-agconnect/hmcore": "^1.0.1",        

         "@hw-agconnect/auth-component": "^1.0.1"

}

                2、下载AGC配置文件

                在AGC的项目设置中找到【agconnect-services.json】文件，下载下来，放置在Dev Eco Studio的【entry\src\main\resources\rawfile】目录下，即配置成功

                3、初始化AGC连接器

                在【src/main/ets/entryability/EntryAbility.ets】中进行初始化 

//初始化项目
let input = await this.context.resourceManager.getRawFileContent('agconnect-services.json')
let jsonString = util.TextDecoder.create('utf-8', { ignoreBOM: true }).decodeWithStream(input, { stream: false })
initialize(this.context, JSON.parse(jsonString));

        （2）建立模型

                选择数据类型后点击导出

                选择js格式，客户端的使用场景，点击确定 

                放置在Dev Eco Studio的ets目录下，新建model目录，将下载下来的js文件放置在此

        （3）导出schema

                选择数据类型后点击导出

                选择json格式，点击确定 

                将下载下来的json文件，放置在【src/main/resources/rawfile/scheme.json】中，并修改文件名为scheme.son

        （4）初始化database

@State database: Database | null = null
aboutToAppear() {this.database = cloud.database({zoneName: "test", //存储区名字objectTypeInfo: scheme  //scheme.json文件中的信息，需要导入})
}

        （5）查询

this.medalList = await this.database.collection(t_medal)  //选择表.query()  //查询.orderByAsc("id") //按什么排序.get()  //获取

        （6）新增

const new_medal = new t_medal()
//设置属性
await this.database.collection(t_medal).upsert(new_medal)

        （7）修改

await this.database.collection(t_medal).upsert(update_medal)

        （6）删除

await this.database.collection(t_medal).delete(medal)