增加Dao和SQL管理的使用范例

ipu-cache-example/pom.xml

@@ -8,6 +8,21 @@
	<artifactId>ipu-cache-example</artifactId>
	<version>1.0</version>
	<repositories>
		<repository>
			<id>ipu</id>
			<name>ipu repository</name>
			<url>http://114.215.100.48:9090/nexus/content/groups/public/</url>
			<releases>
				<enabled>true</enabled>
			</releases>
			<snapshots>
				<enabled>true</enabled>
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
	</repositories>
	<properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <ipu>3.1-SNAPSHOT</ipu>

ipu-db-example/.gitignore

@@ -0,0 +1,3 @@
/target/
/.classpath
/.settings/

ipu-db-example/pom.xml

@@ -7,24 +7,48 @@
    <groupId>com.ai.ipu</groupId>
    <artifactId>ipu-db-example</artifactId>
    <version>1.0-SNAPSHOT</version>
    
    <repositories>
		<repository>
			<id>ipu</id>
			<name>ipu repository</name>
			<url>http://114.215.100.48:9090/nexus/content/groups/public/</url>
			<releases>
				<enabled>true</enabled>
			</releases>
			<snapshots>
				<enabled>true</enabled>
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
	</repositories>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <ipu>3.1-SNAPSHOT</ipu>
        <jdk>1.8</jdk>
        <junit>4.12</junit>
    </properties>
    <dependencies>
    	<!-- 数据库持久层引入依赖 -->
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-database</artifactId>
            <version>${ipu}</version>
        </dependency>
        <!-- 数据库SQL管理引入依赖 -->
        <dependency>
            <groupId>com.ai.ipu</groupId>
            <artifactId>ipu-sql-mgmt</artifactId>
            <version>${ipu}</version>
        </dependency>
        <dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>${junit}</version>
			<scope>test</scope>
		</dependency>
    </dependencies>
</project>

ipu-db-example/src/test/java/com/ai/ipu/example/db/dao/SqlDaoExample.java

@@ -0,0 +1,48 @@
package com.ai.ipu.example.db.dao;
import java.util.List;
import java.util.Map;
import org.junit.Test;
import com.ai.ipu.database.conn.SqlSessionManager;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.database.dao.impl.SqlDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年10月12日下午5:40:57
 * @desc 基于SQL的数据库操作
 */
public class SqlDaoExample {
    private String connName = "db_druid";
    private String tableName = "ipu_db_demo";
    
    /**
     * 测试无参数的DQL语句
     */
    @Test
    public void testExecuteSelect() throws Exception{
        try{
            SqlDao dao = IpuDaoManager.takeDao(SqlDao.class, connName);
            String sql = "select * from " + tableName;
            List<Map<String, Object>>  result = dao.executeSelect(sql);
            System.out.println("查询结果：" + result);
        }catch(Exception e){
            System.err.println("查询失败：" + e.getMessage());
            e.printStackTrace();
        }finally{
            SqlSessionManager.closeAll();
        }
    }
    
    @Test
    public void testExecuteInsert() throws Exception{}
    
    @Test
    public void testExecuteUpdate() throws Exception{}
    
    @Test
    public void testExecuteDelete() throws Exception{}
}

ipu-db-example/src/test/java/com/ai/ipu/example/db/dao/TableDaoExample.java

@@ -0,0 +1,69 @@
package com.ai.ipu.example.db.dao;
import java.util.Map;
import org.junit.Test;
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.conn.SqlSessionManager;
import com.ai.ipu.database.dao.IpuDaoManager;
import com.ai.ipu.database.dao.impl.SqlDao;
import com.ai.ipu.database.dao.impl.TableDao;
/**
 * @author huangbo@asiainfo.com
 * @team IPU
 * @date 2019年10月12日下午6:05:21
 * @desc 基于单表的数据库操作
 */
public class TableDaoExample {
    private String connName = "db_druid";
    private String tableName = "ipu_db_demo";
    private boolean isCommit = true;
    @Test
    public void testSelect(){}
    @Test
    public void testInsert(){
        int result = 0;
        try {
            int pk = this.takePK();
            TableDao dao = IpuDaoManager.takeDao(TableDao.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());
            result = dao.insert(tableName, data);
            System.out.println("插入成功：" + result + "条数据");
            if (isCommit)
                SqlSessionManager.commit(connName);
        }
        catch (Exception e) {
            System.err.println("插入失败：" + e.getMessage());
        }
    }
    @Test
    public void testUpdate(){}
    @Test
    public void testDelete(){}
    
    public int takePK() throws Exception {
        SqlDao sqlDao = IpuDaoManager.takeDao(SqlDao.class, connName);
        String sql = "SELECT * FROM ipu_db_demo ORDER BY pk DESC";
        Map<String, Object> dataResult = sqlDao.executeSelectFirst(sql);
        int pk;
        if(dataResult==null||dataResult.isEmpty()){
            pk = 0;
        }else{
            pk = Integer.parseInt(dataResult.get("pk").toString());
            pk++;
        }
        return pk;
    }
}

ipu-db-example/src/test/java/com/ai/ipu/example/db/mgmt/SqlMgmtDaoExample.java

@@ -0,0 +1,28 @@
package com.ai.ipu.example.db.mgmt;
import java.util.List;
import java.util.Map;
import org.junit.Test;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.sql.mgmt.ISqlMgmtDao;
import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;
public class SqlMgmtDaoExample {
    private String connName = "db_druid";
    @Test
    public void testExecuteSelect() {
        try{
            JMap params = new JsonMap();
            ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
            List<Map<String, Object>> dataResult = dao.executeSelect("com.ai.ipu.example.db.ipu_db_demo","select_all_ipu_db_demo", params);
            System.out.println(dataResult);
        }catch(Exception e){
            e.printStackTrace();
        }
        
    }
}

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

@@ -0,0 +1,24 @@
<?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"></plugin> <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.ai.ipu.sql.mgmt.mybatis.SqlMgmtPlugin"></plugin>
	</plugins>
	<environments default="db_druid">
		<environment id="db_druid">
			<transactionManager type="jdbc" />
			<dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
				<property name="jdbcUrl" value="jdbc:log4jdbc:mysql://47.105.160.21:3307/test" />
				<property name="username" value="ipu" />
				<property name="password" value="ipu@321" />
			</dataSource>
		</environment>
	</environments>
</configuration>

ipu-db-example/src/test/resources/sql/com/ai/ipu/example/db/ipu_db_demo.xml

@@ -0,0 +1,10 @@
<?xml version="1.0" encoding="UTF-8"?>
<sqls>
	<sql name="select_all_ipu_db_demo">
		<![cdata[
		<select id="select" resultType="java.util.Map" useCache="true">
	        select * from ipu_db_demo
		</select>
		]]>
	</sql>
<sqls>

ipu-db-example/src/test/resources/sql_mgmt_mybatis.xml

@@ -0,0 +1,28 @@
<?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">
<!-- <!DOCTYPE configuration SYSTEM "mybatis-ipu-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="ipu_sql_mgmt">
		<environment id="ipu_sql_mgmt">
			<transactionManager type="JDBC" />
			<dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/ipu_sql_mgmt" />
				<property name="username" value="ipu" />
				<property name="password" value="ipumysql" />
			</dataSource>
		</environment>
	</environments>
</configuration>