增加单表增删改查的范例

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

package com.ai.ipu.server.demo.control.data;
package com.ai.ipu.server.demo.control.db;
import java.util.List;
import java.util.Map;

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

package com.ai.ipu.server.demo.control.db;
import java.util.HashMap;
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.common.date.TimeUtil;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.server.demo.dao.DemoTableBizDao;
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;
 */
@Controller
@RequestMapping("/db/table")
public class DbTableController {
    private String connName = "test";
    private String tableName = "ipu_db_test";
    
    @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>();
        data.put("pk", 0);
        
        Map<String, Object> re = dao.select(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
    
    @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");
        
        List<Map<String, Object>> re = dao.selectByCond(tableName, condition);
        IData result = new DataMap();
        result.put("RESULT", re);
        return result;
    }
    
    @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");
        
        int re = dao.insert(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
    
    @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>();
        data.put("pk", 0);
        data.put("int_type2", "111111");
        
        int re = dao.update(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
    
    @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");
        
        int re = dao.updateByCond(tableName, data, condition);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
    
    @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);
        
        int re = dao.delete(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
    
    @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");
        int re = dao.deleteByCond(tableName, data);
        IData result = new DataMap();
        result.put("result_number", re);
        return result;
    }
}

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

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年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;
 */
public class DemoTableBizDao extends AbstractBizDao{
    public DemoTableBizDao(String connName) throws IOException {
        super(connName);
    }
    public int insert(String tableName, Map<String, Object> data) throws Exception {
        return dao.insert(tableName, data);
    }
    public int delete(String tableName, Map<String, Object> data) throws Exception {
        return dao.delete(tableName, data);
    }
    
    public int deleteByCond(String tableName, Map<String, Object> condition) throws Exception {
        return dao.deleteByCond(tableName, condition);
    }
    public int update(String tableName, Map<String, Object> data) throws Exception {
        return dao.update(tableName, data);
    }
    
    public int updateByCond(String tableName, Map<String, Object> data, Map<String, Object> condition) throws Exception {
        return dao.updateByCond(tableName, data, condition);
    }
    public Map<String, Object> select(String tableName, Map<String, Object> data) throws Exception {
        return dao.select(tableName, data);
    }
    
    public List<Map<String, Object>> selectByCond(String tableName, Map<String, Object> condition) throws Exception {
        return dao.selectByCond(tableName, condition);
    }
}

ipu-rest-demo/src/main/resources/dev/application.properties

logging.file=target/logs/${project.artifactId}.log
spring.application.name=${project.artifactId}
######sba监控
#management.security.enabled=false
#spring.boot.admin.url=http://localhost:8888
#security.user.name=ipu
#security.user.password=ipu
#spring.boot.admin.client.metadata.user.name=${security.user.name}
#spring.boot.admin.client.metadata.user.password=${security.user.password}
######查看spring错误日志
#logging.level.org.springframework=DEBUG
######session使用redis
spring.session.store-type=redis
######redis集群和连接池相关配置
spring.redis.cluster.nodes=123.57.35.51:11001,123.57.35.51:11002,123.57.35.51:11003,123.57.35.51:11004,123.57.35.51:11005,123.57.35.51:11006
spring.redis.cluster.timeout=5
spring.redis.cluster.max-redirects=3
spring.redis.password=ipu
spring.redis.pool.max-active=8
spring.redis.pool.max-idle=8
spring.redis.pool.max-wait=-1
#默认0，不回收
spring.redis.pool.min-idle=8
  
######session使用默认
spring.session.store-type=none