ipu-database的示例

ipu-db-example/pom.xml

@@ -4,6 +4,12 @@
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.ai.ipu</groupId>
        <artifactId>ipu-aggregator</artifactId>
        <version>3.1-SNAPSHOT</version>
    </parent>
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-db-example</artifactId>
    <version>1.0-SNAPSHOT</version>
@@ -15,15 +21,25 @@
    </properties>
    <dependencies>
        <!-- ipu-database -->
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-database</artifactId>
            <version>${ipu}</version>
        </dependency>
        <!-- ipu-sql-mgmt(内部依赖了ipu-database，所有上面的ipu-database依赖实际可去掉) -->
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-sql-mgmt</artifactId>
            <version>${ipu}</version>
            <version>3.2-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>

ipu-db-example/src/main/java/com/ai/ipu/example/db/IpuDatabaseExample.java

@@ -0,0 +1,86 @@
package com.ai.ipu.example.db;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import com.ai.ipu.example.db.service.IpuDbDemoService;
import org.junit.Before;
import org.junit.Test;
import java.math.BigDecimal;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 16:05
 */
public class IpuDatabaseExample {
    private IpuDbDemoService service;
    @Before
    public void before() throws Exception {
        service = new IpuDbDemoService();
    }
    /**
     * 普通查询
     */
    @Test
    public void testSelect() throws Exception {
        System.out.println(service.select());
    }
    /**
     * 条件查询
     */
    @Test
    public void testSelectById() throws Exception {
        System.out.println(service.selectById(0));
    }
    /**
     * 新增
     */
    @Test
    public void testInsert() throws Exception {
        int pk = 999;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
        ipuDbDemoDto.setPk(pk);
        ipuDbDemoDto.setString_type("测试新增");
        ipuDbDemoDto.setInt_type(10);
        ipuDbDemoDto.setDecimal_type(new BigDecimal(10.10));
        ipuDbDemoDto.setDate_type(new Date());
        ipuDbDemoDto.setDatetime_type(new Date());
        ipuDbDemoDto.setNull_type("");
        System.out.println(service.insert(ipuDbDemoDto));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
    /**
     * 条件删除
     */
    @Test
    public void testDeleteById() throws Exception {
        int pk = 1;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        System.out.println(service.deleteById(pk));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
    /**
     * 条件更新
     */
    @Test
    public void testUpdateString_typeById() throws Exception {
        int pk = 1;
        System.out.println(service.selectById(pk));
        System.out.println("--------------------");
        System.out.println(service.updateString_typeById(pk, "测试修改"));
        System.out.println("--------------------");
        System.out.println(service.selectById(pk));
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/dao/IpuDbDemoDao.java

@@ -0,0 +1,87 @@
package com.ai.ipu.example.db.dao;
import com.ai.ipu.database.dao.impl.AbstractBizDao;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import java.io.IOException;
import java.math.BigDecimal;
import java.util.*;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 16:10
 * @desc dao层，根据sql调用ipu-database的execute方法连接数据库
 */
public class IpuDbDemoDao extends AbstractBizDao {
    public IpuDbDemoDao(String connName) throws IOException {
        super(connName);
    }
    public List<IpuDbDemoDto> select() throws Exception {
        String sql = "select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo";
        List<Map<String, Object>> result = dao.executeSelect(sql);
        List<IpuDbDemoDto> list = new ArrayList<IpuDbDemoDto>();
        for (Map<String, Object> obj : result) {
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setDecimal_type((BigDecimal) obj.get("decimal_type"));
            ipuDbDemoDto.setDate_type((Date) obj.get("date_type"));
            ipuDbDemoDto.setDatetime_type((Date) obj.get("datetime_type"));
            ipuDbDemoDto.setNull_type((String) obj.get("null_type"));
            list.add(ipuDbDemoDto);
        }
        return list;
    }
    public IpuDbDemoDto selectById(int id) throws Exception {
        String sql = "select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo where pk=#{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk" ,id);
        List<Map<String, Object>> result = dao.executeSelect(sql, param);
        if (result == null || result.size() != 1) {
            return null;
        } else {
            Map<String, Object> obj = result.get(0);
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setDecimal_type((BigDecimal) obj.get("decimal_type"));
            ipuDbDemoDto.setDate_type((Date) obj.get("date_type"));
            ipuDbDemoDto.setDatetime_type((Date) obj.get("datetime_type"));
            ipuDbDemoDto.setNull_type((String) obj.get("null_type"));
            return ipuDbDemoDto;
        }
    }
    public int insert(IpuDbDemoDto ipuDbDemoDto) throws Exception {
        String sql = "insert into ipu_db_demo(pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type) values (#{pk}, #{string_type}, #{int_type}, #{decimal_type}, #{date_type}, #{datetime_type}, #{null_type})";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", ipuDbDemoDto.getPk());
        param.put("string_type", ipuDbDemoDto.getPk());
        param.put("int_type", ipuDbDemoDto.getInt_type());
        param.put("decimal_type", ipuDbDemoDto.getDecimal_type());
        param.put("date_type", ipuDbDemoDto.getDate_type());
        param.put("datetime_type", ipuDbDemoDto.getDatetime_type());
        param.put("null_type", ipuDbDemoDto.getNull_type());
        return dao.executeInsert(sql, param);
    }
    public int deleteById(int id) throws Exception {
        String sql = "delete from ipu_db_demo where pk = #{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", id);
        return dao.executeDelete(sql, param);
    }
    public int updateString_typeById(int id, String value) throws Exception {
        String sql = "update ipu_db_demo set string_type = #{string_type} where pk = #{pk}";
        Map<String, Object> param = new HashMap<String, Object>();
        param.put("pk", id);
        param.put("string_type", value);
        return dao.executeDelete(sql, param);
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/model/IpuDbDemoDto.java

@@ -0,0 +1,96 @@
package com.ai.ipu.example.db.model;
import java.math.BigDecimal;
import java.util.Date;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/16 17:16
 * @desc ipu_db_demo表的dto
 */
public class IpuDbDemoDto {
    private int pk;
    private String string_type;
    private int int_type;
    private BigDecimal decimal_type;
    private Date date_type;
    private Date datetime_type;
    private String null_type;
    public void setPk(int pk) {
        this.pk = pk;
    }
    public void setString_type(String string_type) {
        this.string_type = string_type;
    }
    public void setInt_type(int int_type) {
        this.int_type = int_type;
    }
    public void setDecimal_type(BigDecimal decimal_type) {
        this.decimal_type = decimal_type;
    }
    public void setDate_type(Date date_type) {
        this.date_type = date_type;
    }
    public void setDatetime_type(Date datetime_type) {
        this.datetime_type = datetime_type;
    }
    public void setNull_type(String null_type) {
        this.null_type = null_type;
    }
    public int getPk() {
        return pk;
    }
    public String getString_type() {
        return string_type;
    }
    public int getInt_type() {
        return int_type;
    }
    public BigDecimal getDecimal_type() {
        return decimal_type;
    }
    public Date getDate_type() {
        return date_type;
    }
    public Date getDatetime_type() {
        return datetime_type;
    }
    public String getNull_type() {
        return null_type;
    }
    @Override
    public String toString() {
        StringBuilder stringBuilder = new StringBuilder("{")
                .append("pk").append(":").append(pk).append(",")
                .append("string_type").append(":").append(string_type).append(",")
                .append("int_type").append(":").append(int_type).append(",")
                .append("decimal_type").append(":").append(decimal_type).append(",")
                .append("date_type").append(":").append(date_type).append(",")
                .append("datetime_type").append(":").append(datetime_type).append(",")
                .append("null_type").append(":").append(null_type)
                .append("}");
        return stringBuilder.toString();
    }
}

ipu-db-example/src/main/java/com/ai/ipu/example/db/service/IpuDbDemoService.java

@@ -0,0 +1,44 @@
package com.ai.ipu.example.db.service;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.example.db.dao.IpuDbDemoDao;
import com.ai.ipu.example.db.model.IpuDbDemoDto;
import java.util.List;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/15 17:02
 * @desc service层，绑定dao
 */
public class IpuDbDemoService {
    private IpuDbDemoDao dao;
    /**
     * 获取test的dao
     */
    public IpuDbDemoService() throws Exception {
        dao = IpuDaoManager.takeDao(IpuDbDemoDao.class, "test");
    }
    public List<IpuDbDemoDto> select() throws Exception {
        return dao.select();
    }
    public IpuDbDemoDto selectById(int id) throws Exception {
        return dao.selectById(id);
    }
    public int insert(IpuDbDemoDto ipuDbDemoDto) throws Exception {
        return dao.insert(ipuDbDemoDto);
    }
    public int deleteById(int id) throws Exception {
        return dao.deleteById(id);
    }
    public int updateString_typeById(int id, String value) throws Exception {
        return dao.updateString_typeById(id, value);
    }
}

ipu-db-example/src/main/resources/ipu-mybatis-config.xml

@@ -0,0 +1,39 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor">
	        <!-- config params as the following -->
		</plugin>
	</plugins>
	<environments default="test">
        <environment id="test">
            <transactionManager type="JDBC" />
            <dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
                <property name="driverClass" value="com.mysql.jdbc.Driver" />
                <property name="url" value="jdbc:mysql://47.105.160.21:3307/test" />
                <property name="username" value="iputest" />
                <property name="password" value="iputest@321" />
				<!-- 连接池用完时,等待获取新连接的时间 (毫秒) -->
				<property name="maxWait" value="5000" />
				<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
				<!--<property name="acquireRetryAttempts" value="5" />-->
				<!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
				<!--<property name="acquireRetryDelay" value="1000" />-->
				<property name="initialSize" value="3" />
				<property name="minIdle" value="3" />
				<property name="maxActive" value="3" />
				<!--<property name="maxIdleTime" value="600" />-->
				<!--<property name="idleConnectionTestPeriod" value="60" />-->
				<property name="validationQuery" value="SELECT 1" />
            </dataSource>
        </environment>
	</environments>
</configuration>