新增SQL管理的使用范例

ipu-rest-scaffold/pom.xml

@@ -13,7 +13,7 @@
	<name>restful脚手架服务</name>
	
	<repositories>
		<!-- IPU相关仓库 -->
		<!-- IPU仓库 -->
		<repository>
			<id>ipu</id>
			<name>ipu repository</name>
@@ -26,89 +26,28 @@
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
		<!-- AFI私服，内网私服 -->
		<repository>
			<id>aif_group</id>
			<url>http://10.11.20.81:8080/nexus/content/groups/aif_group/</url>
		</repository>
		<repository>
			<id>msgframe</id>
			<name>msgframe</name>
			<url>http://10.11.20.81:8080/nexus/content/repositories/msgframe/</url>
		</repository>
	</repositories>
	<properties>
		<start-class>com.ai.ipu.server.RestScaffoldStart</start-class>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<msgframe>2.0.0</msgframe>
		<ipu>3.1-SNAPSHOT</ipu>
	</properties>
	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>javax.servlet-api</artifactId>
			<scope>provided</scope>
		</dependency>
		<!-- 由于重写了spring的部分类，需要置前引入，提高优先级 -->
		<dependency>
			<groupId>com.ai.ipu.server</groupId>
			<artifactId>ipu-restful</artifactId>
		</dependency>
		<!-- spring监听,admin-client会引入actuator -->
		<dependency>  
		    <groupId>de.codecentric</groupId>  
		    <artifactId>spring-boot-admin-starter-client</artifactId>
		</dependency>
		<dependency>
			<groupId>com.ai.wade</groupId>
			<artifactId>wade-data</artifactId>
		</dependency>
		<dependency>
			<groupId>com.ai.ipu</groupId>
			<artifactId>ipu-server-web</artifactId>
		</dependency>
		
		<!-- msgframe相关依赖 -->
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-client</artifactId>
			<version>${msgframe}</version>
		</dependency>
		<dependency>
			<groupId>msgframe</groupId>
			<artifactId>msgframe-common</artifactId>
			<version>${msgframe}</version>
			<artifactId>ipu-sql-mgmt</artifactId>
			<version>${ipu}</version>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>1.8</source>
					<target>1.8</target>
					<encoding>UTF-8</encoding>
					<!-- 这里添加本地jar -->
					<compilerArguments>
 					<bootclasspath>${JAVA_HOME}/jre/lib/rt.jar</bootclasspath>
 					<extdirs>${project.basedir}/libs</extdirs>
					</compilerArguments>
				</configuration>
			</plugin>
			
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
		<finalName>${project.artifactId}</finalName>
	</build>
</project>

ipu-rest-scaffold/sql/ipu_db_demo.sql

@@ -0,0 +1,30 @@
/*
Navicat MySQL Data Transfer
Source Server         : ipu测试-121.42.183.206
Source Server Version : 50625
Source Host           : 121.42.183.206:3307
Source Database       : test
Target Server Type    : MYSQL
Target Server Version : 50625
File Encoding         : 65001
Date: 2019-03-03 00:08:09
*/
SET FOREIGN_KEY_CHECKS=0;
-- ----------------------------
-- Table structure for ipu_db_demo
-- ----------------------------
DROP TABLE IF EXISTS `ipu_db_demo`;
CREATE TABLE `ipu_db_demo` (
  `pk` int(255) NOT NULL COMMENT '主键',
  `string_type` varchar(255) NOT NULL COMMENT '字符串字段',
  `int_type` int(255) NOT NULL COMMENT '整型字段',
  `decimal_type` decimal(4,2) NOT NULL COMMENT '小数值字段',
  `date_type` date NOT NULL COMMENT '日期字段',
  `datetime_type` datetime NOT NULL COMMENT '日期时间字段',
  PRIMARY KEY (`pk`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

ipu-rest-scaffold/src/main/java/com/ai/ipu/server/control/DbSqlMgmtController.java

@@ -0,0 +1,51 @@
package com.ai.ipu.server.control;
import java.util.List;
import java.util.Map;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
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;
@Controller
@RequestMapping("/db/mgmt")
public class DbSqlMgmtController {
    private String connName = "test";
    @ResponseBody
    @RequestMapping("/select")
    public JMap executeSqlByFileRepository(JMap param) throws Exception {
        // TODO Auto-generated method stub
        JMap params = new JsonMap();
        params.put("pk", param.getInt("pk", 0));
        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
        List<Map<String, Object>> dataResult = dao.executeSelect("ipu.demo.ipu-db-demo", "select", params);
        JMap result = new JsonMap();
        result.put("result", dataResult);
        return result;
    }
    @ResponseBody
    @RequestMapping("/insert")
    public JMap inertByDbRepository(JMap param) throws Exception {
        // TODO Auto-generated method stub
        JMap params = new JsonMap();
        params.put("pk", 99);
        params.put("string_type", "字符串123");
        params.put("int_type", 999);
        params.put("decimal_type", 9.99);
        params.put("date_type", "2019-09-09");
        params.put("datetime_type", "2019-07-09 15:10:24");
        params.put("null_type", "");
        ISqlMgmtDao dao = SqlMgmtDaoFactory.createFileSqlMgmtDao(connName);
        int num = dao.executeInsert("ipu.demo.ipu-db-demo", "insert", params);
        JMap result = new JsonMap();
        result.put("result", num);
        return result;
    }
}

ipu-rest-scaffold/src/main/resources/sql/ipu/demo/ipu-db-demo.xml

@@ -0,0 +1,26 @@
<?xml version="1.0" encoding="UTF-8"?>
<sqls>
	<sql name="select">
		<![CDATA[
		<select id="select" resultType="java.util.Map">
	        SELECT * FROM  ipu_db_demo WHERE pk=#{pk}
		</select>
		]]>
	</sql>
	
	<sql name="insert">
		<![CDATA[
		<insert id="insert" resultType="java.util.Map">
	        INSERT INTO ipu_db_demo VALUES(
	        	#{pk},
				#{string_type},
				#{int_type},
				#{decimal_type},
				#{date_type},
				#{datetime_type},
				#{null_type}
	        )
		</insert>
		]]>
	</sql>
</sqls>