ipu-sql-mgmt的示例

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

@@ -0,0 +1,51 @@
package com.ai.ipu.example.db;
import com.ai.ipu.data.JMap;
import com.ai.ipu.data.impl.JsonMap;
import com.ai.ipu.database.conn.SqlSessionManager;
import com.ai.ipu.sql.mgmt.ISqlMgmtDao;
import com.ai.ipu.sql.mgmt.SqlMgmtDaoFactory;
import org.junit.Test;
import java.util.List;
import java.util.Map;
/**
 * @author liutong3
 * @team IPU
 * @date 2019/10/12 14:44
 */
public class IpuSqlMgmtExample {
    //通过数据库获取sql并查询
    @Test
    public void testGetSqlByDb() {
        try {
            String connName = "test";
            ISqlMgmtDao dao = SqlMgmtDaoFactory.createDbSqlMgmtDao(connName);
            JMap params = new JsonMap();
            params.put("pk", 0);
            List<Map<String, Object>> result = dao.executeSelect("com.ai.ipu.ipu-db-demo.ipu-db-demo", "select", params);
            System.out.println("查询结果：" + result);
        }catch (Exception e) {
            e.printStackTrace();
        } finally {
            SqlSessionManager.closeAll();
        }
    }
    @Test
    public void testGetSqlByFile() {
        try {
            String connName = "test";
            ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
            JMap params = new JsonMap();
            params.put("pk", 0);
            List<Map<String, Object>> result = dao.executeSelect("com.ai.ipu.ipu-db-demo.ipu-db-demo", "select", params);
            System.out.println("查询结果：" + result);
        }catch (Exception e) {
            e.printStackTrace();
        } finally {
            SqlSessionManager.closeAll();
        }
    }
}

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

@@ -8,10 +8,12 @@
		<setting name="defaultFetchSize" value="1000" /> <!-- 结果集获取数量提示值，分批传输 -->
	</settings>
    <plugins>
        <!-- 分页插件，可根据参数定制化 -->
	    <plugin interceptor="com.github.pagehelper.PageInterceptor">
	        <!-- config params as the following -->
		</plugin>
        <!--&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">

ipu-db-example/src/main/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/main/resources/sql_mgmt_mybatis.xml

@@ -0,0 +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">
<!-- <!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>