返回发烧友论坛
发 帖  

[文章]HarmonyOS应用开发数据交互--关系型数据库完整流程练习

李洋水蛟龙
2021-09-13 15:05:44
阅读量0
0
2
1.创建一个空的java项目


2.创建data Ability
如下步骤所示，创建完成后会生成相应的文件，同时会帮您修改好配置文件。


配置文件（这部分自动生成，与你的目录结果、建议不要修改）：
  1. {
  2.   "permissions": [
  3.     "com.example.rdb.DataAbilityShellProvider.PROVIDER"
  4.   ],
  5.   "name": "com.example.rdb.Database.fristRDB",
  6.   "icon": "$media:icon",
  7.   "description": "$string:fristrdb_description",
  8.   "type": "data",
  9.   "visible": false,
  10.   "uri": "dataability://com.example.rdb.Database.fristRDB"
  11. }
复制代码

3.编写创建数据库代码
编写的fristRDB.java文件：
  1. package com.example.rdb.Database;

  3. import ohos.aafwk.ability.Ability;
  4. import ohos.aafwk.ability.DataAbilityHelper;
  5. import ohos.aafwk.content.Intent;
  6. import ohos.data.DatabaseHelper;
  7. import ohos.data.dataability.DataAbilityUtils;
  8. import ohos.data.rdb.*;
  9. import ohos.data.resultset.ResultSet;
  10. import ohos.data.dataability.DataAbilityPredicates;

  12. import ohos.hiviewdfx.HiLog;
  13. import ohos.hiviewdfx.HiLogLabel;
  14. import ohos.utils.net.Uri;
  15. import ohos.utils.PacMap;

  17. import java.io.FileDescriptor;

  19. public class fristRDB extends Ability {
  20.     //    数据库参数
  21.     private static final String DB_NAME = "persondataability.db";       //数据库名称
  22.     private static final String DB_TAB_NAME = "person";                 //表名称
  23.     private static final String DB_COLUMN_PERSON_ID = "id";             //列 id
  24.     private static final String DB_COLUMN_NAME = "name";                //列 name
  25.     private static final String DB_COLUMN_GENDER = "gender";            //列 gender
  26.     private static final String DB_COLUMN_AGE = "age";                  //列 age
  27.     private static final int DB_VERSION = 1;                            //版本

  29.     private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD001100, "Demo");


  32.     private StoreConfig config = StoreConfig.newDefaultConfig(DB_NAME);  //通过指定数据库名称使用默认配置创建数据库配置。
  33.     private RdbStore rdbStore;  //提供管理关系数据库 (RDB) 的方法。
  34.     //   RdbOpenCallback 管理数据库创建、升级和降级。
  35.     private RdbOpenCallback rdbOpenCallback = new RdbOpenCallback() {
  36.         @Override
  37.         public void onCreate(RdbStore store) {  // 数据库创建时被回调，开发者可以在该方法中初始化表结构，并添加一些应用使用到的初始化数据。
  38.             store.executeSql("create table if not exists "
  39.                     + DB_TAB_NAME + " ("
  40.                     + DB_COLUMN_PERSON_ID + " integer primary key, "
  41.                     + DB_COLUMN_NAME + " text not null, "
  42.                     + DB_COLUMN_GENDER + " text not null, "
  43.                     + DB_COLUMN_AGE + " integer)");
  44.         }

  46.         @Override
  47.         public void onUpgrade(RdbStore store, int oldVersion, int newVersion) {
  48.         }
  49.     };

  51.     @Override
  52.     public void onStart(Intent intent) {
  53.         super.onStart(intent);
  54.         HiLog.info(LABEL_LOG, "fristRDB onStart");
  55.         DatabaseHelper databaseHelper = new DatabaseHelper(this);
  56.         //   根据配置创建或打开数据库。
  57.         rdbStore = databaseHelper.getRdbStore(config, DB_VERSION, rdbOpenCallback, null);
  58.     }

  60.     /**
  61.      * 数据查询
  62.      * @param uri
  63.      * @param columns
  64.      * @param predicates
  65.      * @return
  66.      */
  67.     @Override
  68.     public ResultSet query(Uri uri, String[] columns, DataAbilityPredicates predicates) {
  69.         //   拼装查询语句
  70.         RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME);
  71.         //   查询表中数据 根据 查询语句 + 查找的列
  72.         ResultSet resultSet = rdbStore.query(rdbPredicates, columns);
  73.         if (resultSet == null) {
  74.             HiLog.info(LABEL_LOG, "resultSet is null");
  75.         }
  76.         return resultSet;
  77.     }

  79.     /**
  80.      * 数据添加
  81.      * @param uri  插入的目标路径
  82.      * @param value  插入的数据值
  83.      * @return
  84.      */
  85.     @Override
  86.     public int insert(Uri uri, ValuesBucket value) {
  87.         HiLog.info(LABEL_LOG, "fristRDB insert");

  89.         String path = uri.getLastPath();
  90.         // 判断数据添加的表名称
  91.         if (!"person".equals(path)) {
  92.             HiLog.info(LABEL_LOG, "DataAbility insert path is not matched");
  93.             return -1;
  94.         }
  95.         //用于整理存储添加的数据
  96.         ValuesBucket values = new ValuesBucket();
  97.         values.putInteger(DB_COLUMN_PERSON_ID, value.getInteger(DB_COLUMN_PERSON_ID));
  98.         values.putString(DB_COLUMN_NAME, value.getString(DB_COLUMN_NAME));
  99.         values.putString(DB_COLUMN_GENDER, value.getString(DB_COLUMN_GENDER));
  100.         values.putInteger(DB_COLUMN_AGE, value.getInteger(DB_COLUMN_AGE));
  101.         int index = (int) rdbStore.insert(DB_TAB_NAME, values);
  102.         //  当表格数据插入成功时，可执行DataAbilityHelper.creator(this, uri).notifyChange(uri)，通知该表格数据的订阅者
  103.         DataAbilityHelper.creator(this, uri).notifyChange(uri);
  104.         return index;
  105.     }

  107.     /**
  108.      *  数据删除
  109.      * @param uri  删除的目标路径
  110.      * @param predicates  删除条件
  111.      * @return
  112.      */
  113.     @Override
  114.     public int delete(Uri uri, DataAbilityPredicates predicates) {
  115.         //   解析出要删除的数据
  116.         RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME);
  117.         int index = rdbStore.delete(rdbPredicates);
  118.         HiLog.info(LABEL_LOG, "delete: " + index);
  119.         //   通知观察者数据已经修改
  120.         DataAbilityHelper.creator(this, uri).notifyChange(uri);
  121.         return index;
  122.     }

  124.     /**
  125.      * 数据修改
  126.      * @param uri
  127.      * @param value
  128.      * @param predicates
  129.      * @return
  130.      */
  131.     @Override
  132.     public int update(Uri uri, ValuesBucket value, DataAbilityPredicates predicates) {
  133.         //   解析出要修改的数据
  134.         RdbPredicates rdbPredicates = DataAbilityUtils.createRdbPredicates(predicates, DB_TAB_NAME);
  135.         int index = rdbStore.update(value, rdbPredicates);
  136.         HiLog.info(LABEL_LOG, "update: " + index);
  137.         //   通知观察者数据已经修改
  138.         DataAbilityHelper.creator(this, uri).notifyChange(uri);
  139.         return index;
  140.     }

  142.     @Override
  143.     public FileDescriptor openFile(Uri uri, String mode) {
  144.         return null;
  145.     }

  147.     @Override
  148.     public String[] getFileTypes(Uri uri, String mimeTypeFilter) {
  149.         return new String[0];
  150.     }

  152.     @Override
  153.     public PacMap call(String method, String arg, PacMap extras) {
  154.         return null;
  155.     }

  157.     @Override
  158.     public String getType(Uri uri) {
  159.         return null;
  160.     }

  162.     public void myInsert(){
  163.         ValuesBucket values = new ValuesBucket();
  164.         values.putInteger("id", 1);
  165.         values.putString("name", "zhangsan");
  166.         values.putInteger("age", 18);
  167.         long id = rdbStore.insert("person", values);
  168.     }
  169. }
复制代码

4.编写数据操作代码
为了方便在在MainAbility上编写数据库操作代码。
  1. package com.example.rdb.slice;

  3. import com.example.rdb.Database.MyDataAbilityHelper;
  4. import com.example.rdb.ResourceTable;
  5. import ohos.aafwk.ability.AbilitySlice;
  6. import ohos.aafwk.ability.DataAbilityHelper;
  7. import ohos.aafwk.ability.DataAbilityRemoteException;
  8. import ohos.aafwk.content.Intent;
  9. import ohos.app.Context;
  10. import ohos.data.dataability.DataAbilityPredicates;
  11. import ohos.data.rdb.RdbStore;
  12. import ohos.data.rdb.ValuesBucket;
  13. import ohos.data.resultset.ResultSet;
  14. import ohos.hiviewdfx.HiLog;
  15. import ohos.hiviewdfx.HiLogLabel;
  16. import ohos.utils.net.Uri;

  18. public class MainAbilitySlice extends AbilitySlice {

  20.     private static final HiLogLabel LABEL_LOG = new HiLogLabel(3, 0xD001100, "Demo");

  22.     private static final String BASE_URI = "dataability:///com.example.rdb.Database.fristRDB";
  23.     private static final String DATA_PATH = "/person";
  24.     private static final String DB_COLUMN_PERSON_ID = "id";
  25.     private static final String DB_COLUMN_NAME = "name";
  26.     private static final String DB_COLUMN_GENDER = "gender";
  27.     private static final String DB_COLUMN_AGE = "age";
  28.     private DataAbilityHelper databaseHelper = DataAbilityHelper.creator((Context) this);

  30.     @Override
  31.     public void onStart(Intent intent) {
  32.         super.onStart(intent);
  33.         super.setUIContent(ResourceTable.Layout_ability_main);

  35.         databaseHelper = DataAbilityHelper.creator(this);

  37.         insert(33, "Tom", "man", 20);
  38.         query();
  39.         delete(33);
  40.     }

  42.     @Override
  43.     public void onActive() {
  44.         super.onActive();
  45.     }

  47.     @Override
  48.     public void onForeground(Intent intent) {
  49.         super.onForeground(intent);
  50.     }

  52.     public void query() {
  53.         String[] columns = new String[] {DB_COLUMN_PERSON_ID,
  54.                 DB_COLUMN_NAME, DB_COLUMN_GENDER, DB_COLUMN_AGE};
  55.         // 构造查询条件
  56.         DataAbilityPredicates predicates = new DataAbilityPredicates();
  57.         predicates.between(DB_COLUMN_AGE, 15, 40);
  58.         try {
  59.             ResultSet resultSet = databaseHelper.query(Uri.parse(BASE_URI + DATA_PATH),
  60.                     columns, predicates);
  61.             if (resultSet == null || resultSet.getRowCount() == 0) {
  62.                 HiLog.info(LABEL_LOG, "query: resultSet is null or no result found");
  63.                 return;
  64.             }
  65.             //移动到第一行
  66.             resultSet.goToFirstRow();
  67.             do {
  68.                 int id = resultSet.getInt(resultSet.getColumnIndexForName(DB_COLUMN_PERSON_ID));
  69.                 String name = resultSet.getString(resultSet.getColumnIndexForName(DB_COLUMN_NAME));
  70.                 String gender = resultSet.getString(resultSet.getColumnIndexForName(DB_COLUMN_GENDER));
  71.                 int age = resultSet.getInt(resultSet.getColumnIndexForName(DB_COLUMN_AGE));
  72.                 HiLog.info(LABEL_LOG, "query: Id :" + id + " Name :" + name + " Gender :" + gender + " Age :" + age);
  73.             } while (resultSet.goToNextRow());//移动到下一行一行
  74.         } catch (DataAbilityRemoteException | IllegalStateException exception) {
  75.             HiLog.error(LABEL_LOG, "query: dataRemote exception | illegalStateException");
  76.         }
  77.     }

  79.     public void insert(int id, String name, String gender, int age) {
  80.         ValuesBucket valuesBucket = new ValuesBucket();
  81.         valuesBucket.putInteger(DB_COLUMN_PERSON_ID, id);
  82.         valuesBucket.putString(DB_COLUMN_NAME, name);
  83.         valuesBucket.putString(DB_COLUMN_GENDER, gender);
  84.         valuesBucket.putInteger(DB_COLUMN_AGE, age);
  85.         HiLog.info(LABEL_LOG, "valuesBucket:"+valuesBucket);
  86.         try {
  87.             if (databaseHelper.insert(Uri.parse(BASE_URI + DATA_PATH), valuesBucket) != -1) {
  88.                 HiLog.info(LABEL_LOG, "insert successful");
  89.             }
  90.         } catch (DataAbilityRemoteException | IllegalStateException exception) {
  91.             HiLog.error(LABEL_LOG, "insert: dataRemote exception|illegalStateException");
  92.         }
  93.     }

  95.     public void update() {
  96.         DataAbilityPredicates predicates = new DataAbilityPredicates();
  97.         predicates.equalTo(DB_COLUMN_PERSON_ID, 102);
  98.         ValuesBucket valuesBucket = new ValuesBucket();
  99.         valuesBucket.putString(DB_COLUMN_NAME, "ZhangSanPlus");
  100.         valuesBucket.putInteger(DB_COLUMN_AGE, 28);
  101.         try {
  102.             if (databaseHelper.update(Uri.parse(BASE_URI + DATA_PATH), valuesBucket, predicates) != -1) {
  103.                 HiLog.info(LABEL_LOG, "update successful");
  104.             }
  105.         } catch (DataAbilityRemoteException | IllegalStateException exception) {
  106.             HiLog.error(LABEL_LOG, "update: dataRemote exception | illegalStateException");
  107.         }
  108.     }

  110.     public void delete(int id) {
  111.         DataAbilityPredicates predicates = new DataAbilityPredicates()
  112.                 .equalTo(DB_COLUMN_PERSON_ID, id);
  113.         try {
  114.             if (databaseHelper.delete(Uri.parse(BASE_URI + DATA_PATH), predicates) != -1) {
  115.                 HiLog.info(LABEL_LOG, "delete successful");
  116.             }
  117.         } catch (DataAbilityRemoteException | IllegalStateException exception) {
  118.             HiLog.error(LABEL_LOG, "delete: dataRemote exception | illegalStateException");
  119.         }
  120.     }
  121. }
复制代码

5.查看结果
在虚拟机上运行后，打开Hilog，搜索查看输出的内容。




完整代码地址：
https://gitee.com/jltfcloudcn/jump_to/tree/master/HarmonyOS%E5%85%B3%E7%B3%BB%E5%9E%8B%E6%95%B0%E6%8D%AE%E5%BA%93%E7%BB%83%E4%B9%A0/HarmonyOS%E5%85%B3%E7%B3%BB%E5%9E%8B%E6%95%B0%E6%8D%AE%E5%BA%93%E7%BB%83%E4%B9%A0
附件：
HarmonyOS应用开发--关系型数据库案例练习.docx
(260.51 KB, 下载次数: 1)


举报

回帖

声明：本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人，不代表电子发烧友网立场。文章及其配图仅供工程师学习之用，如有内容图片侵权或者其他问题，请联系本站作侵删。 侵权投诉
链接复制成功，分享给好友