说明

数据库操作，数据库操作助码支持两种，一种是使用实体，第二种是使用原生sql查询

使用实体方式

只要软件中建立了表实体，那么就自动会有实体的三层结构，主要使用 service,和 entity

需要导入相关包：

import com.zhumadev.startzhuma.iservice.IDemoSingleTableService;

import com.zhumadev.startzhuma.entity.DemoSingleTable;

注入service对象

@IServiceAutowired

private IDemoSingleTableService demoSingleTableService;

示例中试用到的方法

createData 插入实体对象

modifyData 更新实体对象

selectByIdWithFill 根据主键查询实体对象 查询外会填充实体关联信息

selectListKeyEqValue 根据字段名称和字段值查询数据列表

deleteData 根据主键删除实体对象，添加删除消息

更多方法参考 ZmServiceBase 服务(Service)的基类的说明

示例 

    

    2. 

  2.     //实体操作测试
    3. 

  3.                             public ZmHash TestEntity()
    4. 

  4.                             {
    5. 

  5.                                     ZmHash log=new ZmHash();
    6. 

    7. 

  7.                                     ZmReturnMsg msg=new ZmReturnMsg();
    8. 

  8.                                     DemoSingleTable data=new DemoSingleTable();
    9. 

  9.                                     data.TableName = "实体测试";
    10. 

  10.                                     data.TableNum = 5;
    11. 

  11.                                     //实体添加数据
    12. 

  12.                                     this.demoSingleTableService.createData(data,msg);
    13. 

  13.                                     int newAddId=data.TableId;
    14. 

  14.                                     log.Add("添加了一条数据,数据id为:",newAddId);
    15. 

    16. 

  16.                                       //查询刚刚添加的数据
    17. 

  17.                                       DemoSingleTable selectdata=this.demoSingleTableService.selectByIdWithFill(newAddId,true,true);
    18. 

  18.                                       log.Add("查询刚刚添加的数据TableName",selectdata.TableName );
    19. 

    20. 

  20.                                       
    21. 

  21.                                       //修改数据名称为 实体测试修改
    22. 

  22.                                       selectdata.TableName= "实体测试修改";
    23. 

  23.                                        this.demoSingleTableService.modifyData(selectdata,msg);
    24. 

    25. 

  25.                                         //重新查询
    26. 

  26.                                        selectdata=this.demoSingleTableService.selectByIdWithFill(newAddId,true,true);
    27. 

  27.                                       log.Add("查询修改后的数据的数据TableName",selectdata.TableName );
    28. 

    29. 

  29.                                       List list = this.demoSingleTableService.selectListKeyEqValue("TableId",newAddId);
    30. 

  30.                                        log.Add("删除前数据条数",list.GetCount());
    31. 

  31.                                       //删除刚刚添加的数据
    32. 

  32.                                       this.demoSingleTableService.deleteData(newAddId,msg);
    33. 

    34. 

  34.                                       list = this.demoSingleTableService.selectListKeyEqValue("TableId",newAddId);
    35. 

  35.                                        log.Add("删除后数据条数",list.GetCount());
    36. 

    37. 

    38. 

  38.                                         return log;
    39. 

  39.                             }
    40. 

    41. 

    42. 

    43.

使用原生sql查询 弱类型方式

需要先找到数据库查询对象，在控制器、服务层、作业等等地方都可以通过下面语句找到数据库查询对象

BaseProvider curDb = base.GetCurDb();

示例中试用到的方法

InsertIntIdentityByParamList 根据sql参数列表插入数据并返回自增列id整型，sql参数名称就是列(col)名称

UpdateByConditions 根据参数列表更新符合条件列表的数据

SelectHashWhere 根据传入表数据和where条件生成并执行sql语句，并返回hash结构

SelectHashListWhere 根据传入表数据和where条件生成并执行sql语句，并返回hashlist结构

Delete 删除符合条件列表的数据

更多方法参考 BaseProvider说明

本方式可以通过可视化码流/微流的方式生成

示例 

    

    2. 

  2.     //数据库弱类型操作测试
    3. 

  3.                             public ZmHash TestDbProvide()
    4. 

  4.                             {
    5. 

  5.                                     ZmHash log=new ZmHash();
    6. 

  6.                                     BaseProvider curDb = base.GetCurDb();
    7. 

    8. 

  8.                                     ZmReturnMsg msg=new ZmReturnMsg();
    9. 

  9.                                     ZmHash data=new ZmHash();
    10. 

  10.                                     ZmSqlParamList editParamList=new ZmSqlParamList();
    11. 

  11.                                     editParamList.AddStringParam("table_name", "弱类型测试",50);
    12. 

  12.                                     editParamList.AddIntParam("table_num", 5);
    13. 

  13.                                     //弱类型添加数据
    14. 

  14.                                     int newAddId=curDb.InsertIntIdentityByParamList("demo_single_table",editParamList);
    15. 

    16. 

  16.                                     log.Add("添加了一条数据,数据id为:",newAddId);
    17. 

    18. 

  18.                                       //查询刚刚添加的数据
    19. 

  19.                                      ZmHash selectdata= curDb.SelectHashWhere("demo_single_table", " table_id="+newAddId, "*");
    20. 

  20.                                       log.Add("查询刚刚添加的数据TableName",selectdata.GetStringValue("table_name") );
    21. 

    22. 

  22.                                       
    23. 

  23.                                       //修改数据名称为 实体测试修改
    24. 

  24.                                       ZmQueryConditionList queryConditions = new ZmQueryConditionList();
    25. 

  25.                                       queryConditions.Add("table_id", "Equal", newAddId, false);
    26. 

  26.                                       editParamList=new ZmSqlParamList();
    27. 

  27.                                        editParamList.AddStringParam("table_name", "弱类型测试修改",50);
    28. 

  28.                                       curDb.UpdateByConditions("demo_single_table", editParamList, queryConditions);
    29. 

  29.                                     
    30. 

  30.                                         //重新查询
    31. 

  31.                                        selectdata= curDb.SelectHashWhere("demo_single_table", " table_id="+newAddId, "*");
    32. 

  32.                                       log.Add("查询修改后的数据的数据TableName",selectdata.GetStringValue("table_name") );
    33. 

    34. 

  34.                                       ZmHashList list = curDb.SelectHashListWhere("demo_single_table", " table_id="+newAddId, "*");
    35. 

  35.                                        log.Add("删除前数据条数",list.GetCount());
    36. 

  36.                                       
    37. 

  37.                                       //删除刚刚添加的数据
    38. 

  38.                                       curDb.Delete("demo_single_table",queryConditions);
    39. 

    40. 

  40.                                       list = curDb.SelectHashListWhere("demo_single_table", " table_id="+newAddId, "*");
    41. 

  41.                                        log.Add("删除后数据条数",list.GetCount());
    42. 

    43. 

    44. 

  44.                                         return log;
    45. 

  45.                             }
    46. 

    47. 

    48.

使用存储过程示例 

    

    2. 

  2.              BaseProvider curDb = base.GetCurDb();
    3. 

  3.             if(curDb.isSupportProcedure()){
    4. 

  4.                 //判断当前数据库提供者是否支持存储过程
    5. 

  5.                 ZmSqlParamList paramlist = new ZmSqlParamList();
    6. 

  6.                 paramlist.AddIntParam("id", 0);
    7. 

  7.                 ZmSqlParam countParam = paramlist.AddIntParam("count", 2);
    8. 

  8.                 //inout 参数的用法
    9. 

  9.                 countParam.setInOutTypeInOut();
    10. 

  10.                     ZmSqlParam ocParam = paramlist.AddIntParam("oc", 0);
    11. 

  11.                     // out参数用法
    12. 

  12.                     ocParam.setInOutTypeOut();
    13. 

  13.                     //调用存储过程并返回ZmHashList
    14. 

  14.                     ZmHashList hashlist = curDb.ExecProcHashListParams("my_test_proc", paramlist);
    15. 

  15.                     //参数返回以后的类型转换
    16. 

  16.                 int newCount = ZmUtil.toInt(countParam.getParamValue());
    17. 

  17.                 int newoc =ZmUtil.toInt(ocParam.getParamValue());
    18. 

  18.             }
    19. 

  19.             else{
    20. 

  20.              //对于不支持存储过程的数据处理
    21. 

  21.             }
    22. 

    23. 

    24.

示例视频包含的内容

使用实体方式的操作数据库

使用数据库原生sql方式的操作