浏览代码

增加基于文件的SQL管理范例。目前新增select和insert范例

huangbo 5 年之前
父节点
当前提交
6421e90de9

+ 22 - 3
ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/db/DbSqlMgmtController.java

@ -19,19 +19,38 @@ public class DbSqlMgmtController {
19 19
    private String connName = "test";
20 20
    
21 21
    @ResponseBody
22
    @RequestMapping("/selectByFile")
22
    @RequestMapping("/select")
23 23
    public JMap executeSqlByFileRepository(JMap param) throws Exception {
24 24
        // TODO Auto-generated method stub
25 25
        JMap params = new JsonMap();
26
        params.put("id", param.getInt("id", 1));
26
        params.put("pk", param.getInt("pk", 0));
27 27
        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
28
        List<Map<String, Object>> dataResult = dao.executeSelect("com.ai.ipu.user.user", "select", params);
28
        List<Map<String, Object>> dataResult = dao.executeSelect("com.ai.ipu.ipu-db-demo", "select", params);
29 29
        JMap result = new JsonMap();
30 30
        result.put("result", dataResult);
31 31
        return result;
32 32
    }
33 33
    
34 34
    @ResponseBody
35
    @RequestMapping("/insert")
36
    public JMap inertByDbRepository(JMap param) throws Exception {
37
        // TODO Auto-generated method stub
38
        JMap params = new JsonMap();
39
        params.put("pk", 99);
40
        params.put("string_type", "字符串123");
41
        params.put("int_type", 999);
42
        params.put("decimal_type", 9.99);
43
        params.put("date_type", "2019-09-09");
44
        params.put("datetime_type", "2019-07-09 15:10:24");
45
        params.put("null_type", "");
46
        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
47
        int num = dao.executeInsert("com.ai.ipu.ipu-db-demo", "insert", params);
48
        JMap result = new JsonMap();
49
        result.put("result", num);
50
        return result;
51
    }
52
    
53
    @ResponseBody
35 54
    @RequestMapping("/selectByDb")
36 55
    public JMap executeSqlByDbRepository(JMap param) throws Exception {
37 56
        // TODO Auto-generated method stub

+ 4 - 3
ipu-rest-demo/src/main/resources/dev/sql_mgmt_mybatis.xml

@ -17,11 +17,12 @@
17 17
	<environments default="ipu_sql_mgmt">
18 18
		<environment id="ipu_sql_mgmt">
19 19
			<transactionManager type="JDBC" />
20
			<dataSource type="com.ai.ipu.database.datasource.C3P0DataSourceFactory">
21
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
20
			<dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
22 21
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/ipu_sql_mgmt" />
23
				<property name="user" value="ipu" />
22
				<property name="username" value="ipu" />
24 23
				<property name="password" value="ipumysql" />
24
				<!-- 配置获取连接的等待超时时间 -->
25
				<property name="maxWait" value="5000" />
25 26
			</dataSource>
26 27
		</environment>
27 28
	</environments>

+ 4 - 15
ipu-rest-demo/src/main/resources/pro/ipu-mybatis-config.xml

@ -16,23 +16,12 @@
16 16
	<environments default="test">
17 17
		<environment id="test">
18 18
			<transactionManager type="JDBC" />
19
			<dataSource type="com.ai.ipu.database.datasource.C3P0DataSourceFactory">
20
				<property name="driverClass" value="com.mysql.jdbc.Driver" />
19
			<dataSource type="com.ai.ipu.database.datasource.DruidDataSourceFactory">
21 20
				<property name="jdbcUrl" value="jdbc:mysql://121.42.183.206:3307/test" />
22
				<property name="user" value="ipu" />
21
				<property name="username" value="ipu" />
23 22
				<property name="password" value="ipumysql" />
24
				<!-- 连接池用完时,等待获取连接的时间 (毫秒) -->
25
				<property name="checkoutTimeout" value="5000" />
26
				<!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
27
				<property name="acquireRetryAttempts" value="5" />
28
				<!--两次连接中间隔时间,单位毫秒。Default: 1000 -->
29
				<property name="acquireRetryDelay" value="1000" />
30
				<property name="initialPoolSize" value="3" />
31
				<property name="minPoolSize" value="3" />
32
				<property name="maxPoolSize" value="3" />
33
				<property name="maxIdleTime" value="600" />
34
				<property name="idleConnectionTestPeriod" value="60" />
35
				<property name="preferredTestQuery" value="SELECT 1" />
23
				<!-- 配置获取连接的等待超时时间 -->
24
				<property name="maxWait" value="5000" />
36 25
			</dataSource>
37 26
		</environment>
38 27
	</environments>

+ 26 - 0
ipu-rest-demo/src/main/resources/sql/com/ai/ipu/ipu-db-demo.xml

@ -0,0 +1,26 @@
1
<?xml version="1.0" encoding="UTF-8"?>
2
<sqls>
3
	<sql name="select">
4
		<![CDATA[
5
		<select id="select" resultType="java.util.Map">
6
	        SELECT * FROM  ipu_db_demo WHERE pk=#{pk}
7
		</select>
8
		]]>
9
	</sql>
10
	
11
	<sql name="insert">
12
		<![CDATA[
13
		<insert id="insert" resultType="java.util.Map">
14
	        INSERT INTO ipu_db_demo VALUES(
15
	        	#{pk},
16
				#{string_type},
17
				#{int_type},
18
				#{decimal_type},
19
				#{date_type},
20
				#{datetime_type},
21
				#{null_type}
22
	        )
23
		</insert>
24
		]]>
25
	</sql>
26
</sqls>

+ 0 - 16
ipu-rest-demo/src/main/resources/sql/com/ai/ipu/user/user.xml

@ -1,16 +0,0 @@
1
<?xml version="1.0" encoding="UTF-8"?>
2
<sqls>
3
	<sql name="select">
4
		<![cdata[
5
		<select id="select" resultType="java.util.Map" useCache="true">
6
	        select id, name from user 
7
	        <where>
8
	            <if test="id == 1">
9
	                id = #{id}
10
	            </if>
11
	        </where>
12
	        order by name
13
		</select>
14
		]]>
15
	</sql>
16
<sqls>