数据库持久层操作范例

ipu-rest-demo/sql/ipu_db_demo.sql

@@ -0,0 +1,30 @@
/*
Navicat MySQL Data Transfer
Source Server         : ipu测试-121.42.183.206
Source Server Version : 50625
Source Host           : 121.42.183.206:3307
Source Database       : test
Target Server Type    : MYSQL
Target Server Version : 50625
File Encoding         : 65001
Date: 2019-03-03 00:08:09
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for ipu_db_demo
-- ----------------------------
DROP TABLE IF EXISTS `ipu_db_demo`;
CREATE TABLE `ipu_db_demo` (
  `pk` int(255) NOT NULL COMMENT '主键',
  `string_type` varchar(255) NOT NULL COMMENT '字符串字段',
  `int_type` int(255) NOT NULL COMMENT '整型字段',
  `decimal_type` decimal(4,2) NOT NULL COMMENT '小数值字段',
  `date_type` date NOT NULL COMMENT '日期字段',
  `datetime_type` datetime NOT NULL COMMENT '日期时间字段',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbController.java

@@ -1,52 +0,0 @@
package com.ai.ipu.server.demo.control.db;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.DemoBizDao;
import com.ai.ipu.server.demo.dao.DemoDao;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
@Controller
@RequestMapping("/db")
public class DbController {
    @ResponseBody
    @RequestMapping("/insert")
    public IData insert(IData params) {
        return null;
    }
    
    @ResponseBody
    @RequestMapping("/delete")
    public IData delete(IData params) {
        return null;
    }
    
    @ResponseBody
    @RequestMapping("/update")
    public IData update(IData params) throws Exception {
        DemoDao dao = IpuDaoManager.takeDao(DemoDao.class, "test");
        int dbResult = dao.update();
        IData result = new DataMap();
        result.put("UPDATE_NUM", dbResult);
        return result;
    }
    
    @ResponseBody
    @RequestMapping("/select")
    public IData select(IData params) throws Exception {
        DemoBizDao dao = IpuDaoManager.takeDao(DemoBizDao.class, "test");
        List<Map<String, Object>> dbResult = dao.select();
        IData result = new DataMap();
        /*dbResult需要转化成json字符串*/
        result.put("IPU_MEMBERS", dbResult);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbSqlController.java

@@ -0,0 +1,40 @@
package com.ai.ipu.server.demo.control.db;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.BizSqlDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年3月2日下午8:35:22
 * @desc 基于SQL的操作范例
 */
@Controller
@RequestMapping("/db/sql")
public class DbSqlController {
    private String connName = "test";
    
    /**
     * @author huangbo@asiainfo.com
     * @title: executeSql
     * @desc: 执行SQL查询的范例
     */
    @ResponseBody
    @RequestMapping("/execute")
    public JMap executeSql(JMap param) throws Exception {
        BizSqlDao dao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        List<Map<String, Object>> dataResult = dao.executeSql();
        JMap result = new JsonMap();
        result.put("result", dataResult);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbTableController.java

@@ -1,6 +1,5 @@
package com.ai.ipu.server.demo.control.db;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -9,150 +8,190 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.ai.ipu.common.date.TimeUtil;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.DemoTableBizDao;
import com.ai.ipu.server.demo.dao.BizSqlDao;
import com.ai.ipu.server.demo.dao.CommonTableDao;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年9月13日下午4:14:55
 * @desc 单表快捷操作范例
 * 建表语句
 CREATE TABLE `ipu_db_test` (
  `pk` varchar(20) CHARACTER SET utf8 NOT NULL COMMENT '键主',
  `string_type1` varchar(255) CHARACTER SET utf8 DEFAULT NULL COMMENT '字符串(可为空)',
  `string_type2` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '字符串(不为空)',
  `int_type1` int(11) DEFAULT NULL COMMENT '整型(可为空)',
  `int_type2` int(11) NOT NULL COMMENT '整型(不为空)',
  `date_type1` datetime DEFAULT NULL COMMENT '日期(不为空)',
  `date_type2` datetime NOT NULL COMMENT '日期(不为空)',
  `decimal_type1` decimal(10,0) DEFAULT NULL COMMENT '小数(可为空)',
  `decimal_type2` decimal(10,0) NOT NULL COMMENT '小数(不为空)',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 * @desc 基于单表CRUD的操作范例
 */
@Controller
@RequestMapping("/db/table")
public class DbTableController {
    private String connName = "test";
    private String druidConnName = "test_druid";
    private String tableName = "ipu_db_test";
    private String tableName = "ipu_db_demo";
    
    /**
     * @author huangbo@asiainfo.com
     * @title: select
     * @desc: 基于主键查询数据的范例
     */
    @ResponseBody
    @RequestMapping("/select")
    public IData select(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap select(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        
        Map<String, Object> re = dao.select(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: selectByCond
     * @desc: 基于条件查询数据的范例
     */
    @ResponseBody
    @RequestMapping("/selectby")
    public IData selectByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> condition = new HashMap<String, Object>();
        condition.put("int_type1", "111111");
        
    public JMap selectByCond(IData param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap condition = new JsonMap();
        condition.put("int_type", "0");
        List<Map<String, Object>> re = dao.selectByCond(tableName, condition);
        IData result = new DataMap();
        result.put("RESULT", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: insert
     * @desc: 新增数据的范例
     */
    @ResponseBody
    @RequestMapping("/insert")
    public IData insert(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("pk", 0);
        data.put("string_type1", "字符串1");
        data.put("string_type2", "字符串2");
        data.put("int_type1", "111111");
        data.put("int_type2", "222222");
        data.put("date_type1", TimeUtil.getSysTime());
        data.put("date_type2", TimeUtil.getSysTime());
        data.put("decimal_type1", "9.99");
        data.put("decimal_type2", "99.9");
    public JMap insert(JMap param) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk);
        data.put("string_type", "字符串"+pk);
        data.put("int_type", pk);
        data.put("decimal_type", "10."+pk);
        data.put("date_type", TimeUtil.getSysDate());
        data.put("datetime_type", TimeUtil.getSysTime());
        int re = dao.insert(tableName, data);
        IData result = new DataMap();
        
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", dao.select(tableName, data));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: update
     * @desc: 基于主键修改数据的范例
     */
    @ResponseBody
    @RequestMapping("/update")
    public IData update(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap update(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        data.put("int_type2", "111111");
        
        data.put("int_type", System.currentTimeMillis()%100);
        int re = dao.update(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", dao.select(tableName, data));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: updateByCond
     * @desc: 基于条件修改数据的范例
     */
    @ResponseBody
    @RequestMapping("/updateby")
    public IData updateByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("string_type2", "字符串1");
        data.put("int_type2", "111111");
        Map<String, Object> condition = new HashMap<String, Object>();
        condition.put("int_type1", "111111");
    public JMap updateByCond(JMap param) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("int_type", System.currentTimeMillis()%100);
        JMap condition = new JsonMap();
        condition.put("string_type", "字符串0");
        
        int re = dao.updateByCond(tableName, data, condition);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        condition.put("pk", 0);
        result.put("content", dao.select(tableName, condition));
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: delete
     * @desc: 基于主键删除数据的范例
     */
    @ResponseBody
    @RequestMapping("/delete")
    public IData delete(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("pk", 0);
    public JMap delete(JMap params) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("pk", pk-1);
        
        Map<String, Object> content = dao.select(tableName, data);
        int re = dao.delete(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", content);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: deleteByCond
     * @desc: 基于条件删除数据的范例
     */
    @ResponseBody
    @RequestMapping("/deleteby")
    public IData deleteByCond(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, connName);
        Map<String, Object> data = new HashMap<String, Object>();
        data.put("string_type1", "字符串1");
        data.put("int_type1", "111111");
    public JMap deleteByCond(JMap params) throws Exception {
        BizSqlDao bizDao = IpuDaoManager.takeDao(BizSqlDao.class, connName);
        int pk = bizDao.takePK();
        
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, connName);
        JMap data = new JsonMap();
        data.put("string_type", "字符串"+(pk-1));
        List<Map<String, Object>> contents = dao.selectByCond(tableName, data);
        Map<String, Object> content = (contents!=null&&contents.size()>0)?contents.get(0):null;
        int re = dao.deleteByCond(tableName, data);
        IData result = new DataMap();
        JMap result = new JsonMap();
        result.put("result_number", re);
        result.put("content", content);
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: selectByDruid
     * @desc: 基于主键查询数据的范例，使用druid连接池
     */
    @ResponseBody
    @RequestMapping("druid/select")
    public IData selectByDruid(IData params) throws Exception {
        DemoTableBizDao dao = IpuDaoManager.takeDao(DemoTableBizDao.class, druidConnName);
        Map<String, Object> data = new HashMap<String, Object>();
    public JMap selectByDruid(JMap params) throws Exception {
        CommonTableDao dao = IpuDaoManager.takeDao(CommonTableDao.class, druidConnName);
        JMap data = new JsonMap();
        data.put("pk", 0);
        
        Map<String, Object> re = dao.select(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        JMap result = new JsonMap();
        result.put("result", re);
        return result;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/dubbo/DubboControl.java

@@ -10,10 +10,21 @@ import com.ai.ipu.restful.spring.SpringManager;
import com.ai.ipu.service.demo.IBizService;
import com.ailk.common.data.IData;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年10月24日上午00:13:37
 * @desc Dubbo客户端的使用范例
 */
@Controller
@RequestMapping("/dubbo")
public class DubboControl {
    /**
     * @author huangbo@asiainfo.com
     * @title: callBizService
     * @desc: Dubbo客户端调用服务范例
     */
    @ResponseBody
    @RequestMapping("/biz")
    public IData callBizService(IData params) {
@@ -23,6 +34,11 @@ public class DubboControl {
        return result;
    }
    
    /**
     * @author huangbo@asiainfo.com
     * @title: callCommonService
     * @desc: Dubbo客户端调用通用服务范例
     */
    @ResponseBody
    @RequestMapping("/common")
    public IData callCommonService(IData params) {

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/other/MsgFrameController.java

@@ -1,4 +1,4 @@
package com.ai.ipu.server.demo.control.other;
package com.ai.ipu.server.demo.control.mq;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
@@ -11,10 +11,21 @@ import com.ai.ipu.restful.util.IpuRestConstant;
import com.ailk.common.data.IData;
import com.ailk.common.data.impl.DataMap;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年4月30日下午3:17:49
 * @desc MsgFrame的使用范例
 */
@Controller
@RequestMapping("/msgframe")
public class MsgFrameController{
    /**
     * @author huangbo@asiainfo.com
     * @title: produceMessage
     * @desc: MsgFrame消息生产者范例
     */
    @ResponseBody
    @RequestMapping("/produce")
    public IData produceMessage(IData params){

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/BizSqlDao.java

@@ -0,0 +1,40 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:35
 * @desc 基于SQL的操作范例
 * 业务dao不暴露和业务无关的方法.
 */
public class BizSqlDao extends AbstractBizDao{
    public BizSqlDao(String connName) throws IOException {
        super(connName);
    }
    public List<Map<String, Object>> executeSql() throws Exception {
        String sql = "SELECT * FROM ipu_db_demo";
        List<Map<String, Object>> dataResult = getBasicDao().executeSelect(sql);
        return dataResult;
    }
    
    public int takePK() throws Exception {
        String sql = "SELECT * FROM ipu_db_demo order by datetime_type desc";
        Map<String, Object> dataResult = getBasicDao().executeSelectFirst(sql);
        int pk;
        if(dataResult==null||dataResult.isEmpty()){
            pk = 0;
        }else{
            pk = Integer.parseInt(dataResult.get("pk").toString());
            pk++;
        }
        return pk;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoTableBizDao.java

@@ -10,24 +10,11 @@ import com.ai.ipu.database.dao.impl.AbstractBizDao;
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年9月6日下午10:05:42
 * @desc 单表增删改查测试
 * 建表语句
 CREATE TABLE `ipu_db_test` (
  `pk` varchar(20) CHARACTER SET utf8 NOT NULL COMMENT '键主',
  `string_type1` varchar(255) CHARACTER SET utf8 DEFAULT NULL COMMENT '字符串(可为空)',
  `string_type2` varchar(255) CHARACTER SET utf8 NOT NULL COMMENT '字符串(不为空)',
  `int_type1` int(11) DEFAULT NULL COMMENT '整型(可为空)',
  `int_type2` int(11) NOT NULL COMMENT '整型(不为空)',
  `date_type1` datetime DEFAULT NULL COMMENT '日期(不为空)',
  `date_type2` datetime NOT NULL COMMENT '日期(不为空)',
  `decimal_type1` decimal(10,0) DEFAULT NULL COMMENT '小数(可为空)',
  `decimal_type2` decimal(10,0) NOT NULL COMMENT '小数(不为空)',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
 * @desc 通用基于单表CRUD的操作范例
 */
public class DemoTableBizDao extends AbstractBizDao{
public class CommonTableDao extends AbstractBizDao{
    public DemoTableBizDao(String connName) throws IOException {
    public CommonTableDao(String connName) throws IOException {
        super(connName);
    }

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoBizDao.java

@@ -1,40 +0,0 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:35
 * @desc 内置一个BasicDao,让业务dao不暴露和业务无关的方法.
 */
public class DemoBizDao extends AbstractBizDao{
    public DemoBizDao(String connName) throws IOException {
        super(connName);
    }
    public int insert() {
        return -1;
    }
    public int delete() {
        return -1;
    }
    public int update() throws Exception {
        String sql = "update TAB_IPU_MEMBER set PASSWORD='000002'";
        int result = dao.executeUpdate(sql, null);
        return result;
    }
    public List<Map<String, Object>> select() throws Exception {
        String sql = "SELECT * FROM tab_ipu_member";
        List<Map<String, Object>> dbResult = getBasicDao().executeSelect(sql);
        return dbResult;
    }
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/dao/DemoDao.java

@@ -1,42 +0,0 @@
package com.ai.ipu.server.demo.dao;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.ai.ipu.database.conn.SqlSessionManager;
import com.ai.ipu.database.dao.impl.BasicDao;
import com.ai.ipu.database.dao.impl.SqlDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2018年1月26日下午5:27:43
 * @desc 继承BasicDao,让每个业务dao具备全量方法.
 */
public class DemoDao extends BasicDao {
    public DemoDao(String connName) throws IOException {
        super(connName);
    }
    public int insert() {
        return -1;
    }
    public int delete() {
        return -1;
    }
    public int update() throws Exception {
        String sql = "update TAB_IPU_MEMBER set PASSWORD='000002'";
        int result = executeUpdate(sql, null);
        return result;
    }
    public List<Map<String, Object>> select() throws Exception {
        String sql = "SELECT * FROM tab_ipu_member";
        List<Map<String, Object>> dbResult = executeSelect(sql);
        return dbResult;
    }
}