junit的@Test读取的是test里面的配置文件。统一配置文件。

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

@@ -20,7 +20,7 @@ public class IpuSqlMgmtExample {
    @Test
    public void testGetSqlByDb() {
        try {
            String connName = "test";
            String connName = "db_druid";
            ISqlMgmtDao dao = SqlMgmtDaoFactory.createDbSqlMgmtDao(connName);
            JMap params = new JsonMap();
            params.put("pk", 0);
@@ -36,7 +36,7 @@ public class IpuSqlMgmtExample {
    @Test
    public void testGetSqlByFile() {
        try {
            String connName = "test";
            String connName = "db_druid";
            ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
            JMap params = new JsonMap();
            params.put("pk", 0);

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

@@ -29,7 +29,7 @@ public class IpuSqlParseExample {
     */
    @Test
    public void testParseWithConnName() {
        SqlParser sqlParser = new SqlParser("test", "select string_type, int_type from ipu_db_demo where pk = '1'");
        SqlParser sqlParser = new SqlParser("db_druid", "select string_type, int_type from ipu_db_demo where pk = '1'");
        System.out.println("sql语句类型：" + sqlParser.getType());
        System.out.println("查询的表是：" + sqlParser.getTableName());
        System.out.println("查询条件是：" + sqlParser.getWhere());

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

@@ -24,9 +24,9 @@ public class IpuDbDemoDao extends AbstractBizDao {
        List<IpuDbDemoDto> list = new ArrayList<IpuDbDemoDto>();
        for (Map<String, Object> obj : result) {
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setPk((Integer) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setInt_type((Integer) 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"));
@@ -46,9 +46,9 @@ public class IpuDbDemoDao extends AbstractBizDao {
        } else {
            Map<String, Object> obj = result.get(0);
            IpuDbDemoDto ipuDbDemoDto = new IpuDbDemoDto();
            ipuDbDemoDto.setPk((int) obj.get("pk"));
            ipuDbDemoDto.setPk((Integer) obj.get("pk"));
            ipuDbDemoDto.setString_type((String) obj.get("string_type"));
            ipuDbDemoDto.setInt_type((int) obj.get("int_type"));
            ipuDbDemoDto.setInt_type((Integer) 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"));

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

@@ -19,7 +19,7 @@ public class IpuDbDemoService {
     * 获取test的dao
     */
    public IpuDbDemoService() throws Exception {
        dao = IpuDaoManager.takeDao(IpuDbDemoDao.class, "test");
        dao = IpuDaoManager.takeDao(IpuDbDemoDao.class, "db_druid");
    }
    public List<IpuDbDemoDto> select() throws Exception {

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

@@ -1,41 +0,0 @@
<?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>
        <!--&lt;!&ndash; 分页插件，可根据参数定制化 &ndash;&gt;-->
	    <!--<plugin interceptor="com.github.pagehelper.PageInterceptor">-->
	        <!--&lt;!&ndash; config params as the following &ndash;&gt;-->
		<!--</plugin>-->
		<plugin interceptor="com.ai.ipu.sql.mgmt.mybatis.SqlMgmtPlugin">
        </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>

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

@@ -1,40 +0,0 @@
<?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="url" value="jdbc:mysql://47.105.160.21:3307/ipu_sql_mgmt" />
				<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>

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

@@ -18,7 +18,7 @@ public class SqlMgmtDaoExample {
        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);
            List<Map<String, Object>> dataResult = dao.executeSelect("com.ai.ipu.ipu-db-demo.ipu-db-demo","select", params);
            System.out.println(dataResult);
        }catch(Exception e){
            e.printStackTrace();

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

@@ -1,23 +1,40 @@
<?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">
		PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
		"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
    <settings>
	<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>
		<!-- 分页插件，可根据参数定制化 -->
		<plugin interceptor="com.github.pagehelper.PageInterceptor">
			<!-- config params as the following -->
		</plugin>
		<plugin interceptor="com.ai.ipu.sql.mgmt.mybatis.SqlMgmtPlugin">
		</plugin>
	</plugins>
	<environments default="db_druid">
		<environment id="db_druid">
			<transactionManager type="jdbc" />
			<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" />
				<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>

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

@@ -1,10 +0,0 @@
<?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/com/ai/ipu/ipu-db-demo/ipu-db-demo.xml

@@ -0,0 +1,219 @@
<?xml version="1.0" encoding="UTF-8"?>
<sqls>
	<sql name="select">
		<![CDATA[
		<select id="select" parameterType="ai.ipu.data.JMap" resultType="java.util.Map" useCache="true">
	        select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo
	        <where>
	            <if test="pk != null">
	                pk = #{pk}
	            </if>
	            <if test="string_type != null">
	                string_type = #{string_type}
	            </if>
	            <if test="int_type != null">
	                int_type = #{int_type}
	            </if>
	            <if test="decimal_type != null">
	                decimal_type = #{decimal_type}
	            </if>
	            <if test="date_type != null">
	                date_type = #{date_type}
	            </if>
	            <if test="datetime_type != null">
	                datetime_type = #{datetime_type}
	            </if>
	            <if test="null_type != null">
	            	<if test="null_type == true">
	                	null_type is null
	                </if>
	                <if test="null_type == false">
	                	null_type is not null
	                </if>
	            </if>
	        </where>
		</select>
		]]>
	</sql>
	<sql name="select_javabean">
		<![CDATA[
		<select id="select" parameterType="com.ai.ipu.sql.mgmt.IpuDbDemoBean" resultType="com.ai.ipu.sql.mgmt.IpuDbDemoBean" useCache="true" >
	        select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo
	        <where>
	            <if test="pk != null">
	                pk = #{pk}
	            </if>
	            <if test="string_type != null">
	                string_type = #{string_type}
	            </if>
	            <if test="int_type != null">
	                int_type = #{int_type}
	            </if>
	            <if test="decimal_type != null">
	                decimal_type = #{decimal_type}
	            </if>
	            <if test="date_type != null">
	                date_type = #{date_type}
	            </if>
	            <if test="datetime_type != null">
	                datetime_type = #{datetime_type}
	            </if>
	            <if test="null_type != null">
	            	<if test="null_type == true">
	                	null_type is null
	                </if>
	                <if test="null_type == false">
	                	null_type is not null
	                </if>
	            </if>
	        </where>
		</select>
		]]>
	</sql>
	<sql name="simple_select">
		<![CDATA[
        select pk, string_type, int_type, decimal_type, date_type, datetime_type, null_type from ipu_db_demo where
            1 = 1
            <if test="pk != null">
	            and pk = #{pk}
	        </if>
	        <if test="string_type != null">
                and string_type = #{string_type}
	        </if>
	        <if test="int_type != null">
                and int_type = #{int_type}
	        </if>
	        <if test="decimal_type != null">
                and decimal_type = #{decimal_type}
            </if>
            <if test="date_type != null">
                and date_type = #{date_type}
            </if>
            <if test="datetime_type != null">
                and datetime_type = #{datetime_type}
            </if>
            <if test="null_type != null">
            	<if test="null_type == true">
                	and null_type is null
                </if>
                <if test="null_type == false">
                	and null_type is not null
                </if>
            </if>
		]]>
	</sql>
	<sql name="update">
		<![CDATA[
		<update id="update" parameterType="ai.ipu.data.JMap">
		update ipu_db_demo
			<set>
				<if test="string_type != null">
					string_type = #{string_type},
				</if>
				<if test="int_type != null">
					int_type = #{int_type},
				</if>
				<if test="decimal_type != null">
					decimal_type = #{decimal_type},
				</if>
				<if test="date_type != null">
					date_type = #{date_type},
				</if>
				<if test="datetime_type != null">
					datetime_type = #{datetime_type},
				</if>
				<if test="null_type != null">
					<if test="null_type == true">
						null_type = null
					</if>
					<if test="null_type == false">
						null_type = ''
					</if>
				</if>
			</set>
			where
				pk = #{pk}
		</update>
		]]>
	</sql>
	<sql name="simple_update">
		<![CDATA[
		update ipu_db_demo
		<set>
			<if test="string_type != null">
					string_type = #{string_type},
				</if>
			<if test="int_type != null">
				int_type = #{int_type},
			</if>
			<if test="decimal_type != null">
				decimal_type = #{decimal_type},
			</if>
			<if test="date_type != null">
				date_type = #{date_type},
			</if>
			<if test="datetime_type != null">
				datetime_type = #{datetime_type},
			</if>
			<if test="null_type != null">
				<if test="null_type == true">
					null_type = null
				</if>
				<if test="null_type == false">
					null_type = ''
				</if>
			</if>
		</set>
		where
		pk = #{pk}
		]]>
	</sql>
	<sql name="insert">
		<![CDATA[
		<insert id="insert" parameterType="ai.ipu.data.JMap">
			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},
			<if test="null_type == true">
				null
			</if>
			<if test="null_type == false">
				''
			</if>
			)
		</insert>
		]]>
	</sql>
	<sql name="simple_insert">
		<![CDATA[
		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},
		<if test="null_type == true">
			null
		</if>
		<if test="null_type == false">
			''
		</if>
		)
		]]>
	</sql>
	<sql name="delete">
		<![CDATA[
		<delete id="delete" parameterType="ai.ipu.data.JMap">
			delete from ipu_db_demo where pk = #{pk}
		</delete>
		]]>
	</sql>
	<sql name="simple_delete">
		<![CDATA[
			delete from ipu_db_demo where pk = #{pk}
		]]>
	</sql>
</sqls>

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

@@ -19,9 +19,21 @@
			<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" />
				<property name="url" value="jdbc:mysql://47.105.160.21:3307/ipu_sql_mgmt" />
				<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>