sqlaction: 自动生成JDBC代码的数据库持久层工具

原作者: [db:作者] 来自: 网络收藏邀请

开源软件名称：

sqlaction

开源软件地址：

https://gitee.com/calvinwilliams/sqlaction

开源软件介绍：

sqlaction - 自动生成JDBC代码的数据库持久层工具

1. 概述
2. 一个DEMO
3. 使用参考
4. 为什么这样设计？
5. 与MyBatis的开发量比较
6. 与MyBatis的性能比较
7. 后续开发
8. 关于本项目
9. 关于作者

1. 概述

厌烦了MyBatis和JPA(Hibernate)的冗余配置和繁琐使用，以及XML拷来拷去，写那么多Mapper要是直接用JDBC早就写完了，如果使用一个框架/工具比不使用而带来更多的心智负担，那还不如不用。其实，直接使用JDBC还是蛮干净和高性能的，只要解决其三个痛点：

手工编写数据库表实体类。
手工编写大量setString和getString代码，尤其还要人工保证字段序号递增。
因为直接写SQL，涉及不同DBMS的SQL方言时，移植性不好，比如分页查询。

能否造一个更好的轮子？

于是，我结合之前在C技术栈中的产品经验，结合JAVA特点，写了sqlaction。

sqlaction是自动生成JDBC代码的数据库持久层工具，它为应用提供了类似MyBatis和Hibernate操作数据库能力，但更轻量级和几乎消除了所有的手工冗余工作（编码和配置），提高开发效率，也最大化运行效率。

sqlaction只负责把配置的SQL规则转换为完整的JDBC代码，不干涉数据库连接池管理、数据库事务控制等，也就易于与其它框架搭配使用。

sqlaction核心工作原理是读取数据库中的表结构元信息和少量配置文件信息（SQL语法），自动生成数据库表实体类，自动生成基于JDBC的SQL动作方法代码，自动生成拦截器框架等代码，应用调用其自动生成的代码就能极其快捷的操作数据库，同时还拥有JDBC的高性能，更重要的是开发者能直接看到底层操作代码，增加自主可控，没有低效的反射，没有复杂的热修改字节码，没有庞大笨重的隐藏核心要学习。

sqlaction核心功能：

多数据库支持，目前支持有MySQL、PostgreSQL、Oracle、Sqlite、SqlServer。
抽象统一了自增字段和序列两大数据库阵营对主键值的赋值，不同数据库用一样的语法配置。
抽象统一了物理分页功能，原生自带通用分页能力，不同数据库用一样的语法配置。
执行效率比MyBatis快约20%。
高级模式支持任意复杂SQL。

sqlaction核心优势：

使用sqlaction比MyBatis减少一半的开发工作量，大幅提升开发效能。
sqlaction运行性能比MyBatis快20%，明显降低服务迟延。
抽象统一了不同数据库的SQL方言差异，真正做到开发与数据库无关。
完整覆盖联机型应用（TP）和分析型应用（AP）两大场景。

2. 一个DEMO

放一个DEMO感受一下：

2.1. 建表DDL

以MySQL为例

ddl.sql

CREATE TABLE `sqlaction_demo` (  `id` int(11) NOT NULL AUTO_INCREMENT COMMENT '编号',  `name` varchar(32) COLLATE utf8mb4_bin NOT NULL COMMENT '名字',  `address` varchar(128) COLLATE utf8mb4_bin DEFAULT NULL COMMENT '地址',  PRIMARY KEY (`id`),  KEY `sqlaction_demo` (`name`)) ENGINE=InnoDB AUTO_INCREMENT=6 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin

2.2. 新建JAVA项目

sqlaction只依赖数据库连接库和作者另一个JSON解析器okjson，引入mysql-connector-java-X.Y.Z.jar、okjson-0.0.9.0.jar文件或Maven坐标。

建立包目录，在包目录或上级某一级目录中创建数据库连接配置文件dbserver.conf.json，工具会从执行目录开始往上查找，只要某一级目录中存在这个配置文件即可。

{	"driver" : "com.mysql.jdbc.Driver" ,	"url" : "jdbc:mysql://127.0.0.1:3306/calvindb?serverTimezone=GMT" ,	"user" : "calvin" ,	"pwd" : "calvin"}

在包目录或上级某一级目录中创建SQL动作配置文件sqlaction.conf.json，工具会从执行目录开始往上查找，只要某一级目录中存在这个配置文件即可。

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "sqlaction_demo" ,			"sqlactions" : [				"SELECT * FROM sqlaction_demo" ,				"SELECT * FROM sqlaction_demo WHERE name=?" ,				"INSERT INTO sqlaction_demo" ,				"UPDATE sqlaction_demo SET address=? WHERE name=?" ,				"DELETE FROM sqlaction_demo WHERE name=?"			]		}	] ,	"javaPackage" : "xyz.calvinwilliams.sqlaction"}

2.3. 在包目录中执行sqlaction工具

此示例中我把执行命令行包装成批处理文件执行，欢迎懂Eclipse插件开发的同学帮我写个插件 :)

pp.bat

java -Dfile.encoding=UTF-8 -classpath "D:\Work\mysql-connector-java-8.0.15\mysql-connector-java-8.0.15.jar;%USERPROFILE%\.m2\repository\xyz\calvinwilliams\okjson\0.0.9.0\okjson-0.0.9.0.jar;%USERPROFILE%\.m2\repository\xyz\calvinwilliams\sqlaction\0.2.9.0\sqlaction-0.2.9.0.jar" xyz.calvinwilliams.sqlaction.SqlActionGencodepause

注意：使用Maven管理的项目，在pom.xml里添加sqlaction坐标后，maven会自动下载sqlaction以及其依赖okjson的jar到C:\User\用户名\.m2\repository\xyz\calvinwilliams\下，上面执行命令直接引用了Maven目录里的包。sqlaction坐标见最后面“关于本项目”章节。

执行pp.bat，工具sqlaction会从执行目录开始往上查找读入dbserver.conf.json和sqlaction.conf.json并自动生成所有代码。

///////////////////////////////////////////////////////////////////////////////// sqlaction v0.2.9.0/// Copyright by calvin<[email protected],[email protected]>//////////////////////////////////////////////////////////////////////////////--- dbserverConf ---  dbms[mysql]driver[com.mysql.jdbc.Driver]   url[jdbc:mysql://127.0.0.1:3306/calvindb?serverTimezone=GMT]  user[calvin]   pwd[calvin]--- sqlactionConf --- database[calvindb]        table[sqlaction_demo]                sqlaction[SELECT * FROM sqlaction_demo]                sqlaction[SELECT * FROM sqlaction_demo WHERE name=?]                sqlaction[INSERT INTO sqlaction_demo]                sqlaction[UPDATE sqlaction_demo SET address=? WHERE name=? @@METHOD(updateAddressByName)]                sqlaction[DELETE FROM sqlaction_demo WHERE name=?]SqlActionTable.getTableInDatabase[sqlaction_demo] ......*** NOTICE : Write SqlactionDemoSAO.java completed!!!

如果没有出现*** ERROR : ...说明工具执行成功，在执行所在目录中自动生成了两个JAVA源代码文件

SqlactionDemoSAO.java

// This file generated by sqlaction v0.2.9.0// WARN : DON'T MODIFY THIS FILEpackage xyz.calvinwilliams.sqlaction;import java.math.*;import java.util.*;import java.sql.Time;import java.sql.Timestamp;import java.sql.Connection;import java.sql.Statement;import java.sql.PreparedStatement;import java.sql.ResultSet;public class SqlactionDemoSAO {	int				id ; // 编号 // PRIMARY KEY	String			name ; // 名字	String			address ; // 地址	int				_count_ ; // defining for 'SELECT COUNT(*)'	// SELECT * FROM sqlaction_demo	public static int SELECT_ALL_FROM_sqlaction_demo( Connection conn, List<SqlactionDemoSAU> sqlactionDemoListForSelectOutput ) throws Exception {		Statement stmt = conn.createStatement() ;		ResultSet rs = stmt.executeQuery( "SELECT * FROM sqlaction_demo" ) ;		while( rs.next() ) {			SqlactionDemoSAU sqlactionDemo = new SqlactionDemoSAU() ;			sqlactionDemo.id = rs.getInt( 1 ) ;			sqlactionDemo.name = rs.getString( 2 ) ;			sqlactionDemo.address = rs.getString( 3 ) ;			sqlactionDemoListForSelectOutput.add(sqlactionDemo) ;		}		rs.close();		stmt.close();		return sqlactionDemoListForSelectOutput.size();	}	// SELECT * FROM sqlaction_demo WHERE name=?	public static int SELECT_ALL_FROM_sqlaction_demo_WHERE_name_E_( Connection conn, List<SqlactionDemoSAU> sqlactionDemoListForSelectOutput, String _1_SqlactionDemoSAU_name ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "SELECT * FROM sqlaction_demo WHERE name=?" ) ;		prestmt.setString( 1, _1_SqlactionDemoSAU_name );		ResultSet rs = prestmt.executeQuery() ;		while( rs.next() ) {			SqlactionDemoSAU sqlactionDemo = new SqlactionDemoSAU() ;			sqlactionDemo.id = rs.getInt( 1 ) ;			sqlactionDemo.name = rs.getString( 2 ) ;			sqlactionDemo.address = rs.getString( 3 ) ;			sqlactionDemoListForSelectOutput.add(sqlactionDemo) ;		}		rs.close();		prestmt.close();		return sqlactionDemoListForSelectOutput.size();	}	// INSERT INTO sqlaction_demo	public static int INSERT_INTO_sqlaction_demo( Connection conn, SqlactionDemoSAU sqlactionDemo ) throws Exception {		PreparedStatement prestmt ;		Statement stmt ;		ResultSet rs ;		prestmt = conn.prepareStatement( "INSERT INTO sqlaction_demo (name,address) VALUES (?,?)" ) ;		prestmt.setString( 1, sqlactionDemo.name );		prestmt.setString( 2, sqlactionDemo.address );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// UPDATE sqlaction_demo SET address=? WHERE name=?	public static int UPDATE_sqlaction_demo_SET_address_E_WHERE_name_E_( Connection conn, String _1_address_ForSetInput, String _1_name_ForWhereInput ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "UPDATE sqlaction_demo SET address=? WHERE name=?" ) ;		prestmt.setString( 1, _1_address_ForSetInput );		prestmt.setString( 2, _1_name_ForWhereInput );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// DELETE FROM sqlaction_demo WHERE name=?	public static int DELETE_FROM_sqlaction_demo_WHERE_name_E_( Connection conn, String _1_name ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "DELETE FROM sqlaction_demo WHERE name=?" ) ;		prestmt.setString( 1, _1_name );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}}

SqlactionDemoSAU.java

// This file generated by sqlaction v0.2.9.0package xyz.calvinwilliams.sqlaction;import java.math.*;import java.util.*;import java.sql.Time;import java.sql.Timestamp;import java.sql.Connection;import java.sql.Statement;import java.sql.PreparedStatement;import java.sql.ResultSet;public class SqlactionDemoSAU extends SqlactionDemoSAO {}

2.4. 到目前为止，一行JAVA代码都没写，现在开始写应用代码

Demo.java

package xyz.calvinwilliams.sqlaction;import java.sql.Connection;import java.sql.DriverManager;import java.sql.SQLException;import java.util.LinkedList;import java.util.List;public class Demo {	public static void main(String[] args) {		Connection				conn = null ;		List<SqlactionDemoSAU>	sqlactionDemoList = null ;		SqlactionDemoSAU		sqlactionDemo = null ;		int						nret = 0 ;		// Connect to database		try {			Class.forName( "com.mysql.jdbc.Driver" );			conn = DriverManager.getConnection( "jdbc:mysql://127.0.0.1:3306/calvindb?serverTimezone=GMT", "calvin", "calvin" ) ;		} catch (ClassNotFoundException e1) {			e1.printStackTrace();		} catch (SQLException e) {			e.printStackTrace();		}				try {			conn.setAutoCommit(false);						// Delete records with name			nret = SqlactionDemoSAU.DELETE_FROM_sqlaction_demo_WHERE_name_E_( conn, "Calvin" ) ;			if( nret < 0 ) {				System.out.println( "SqlactionDemoSAU.DELETE_FROM_sqlaction_demo_WHERE_name_E_ failed["+nret+"]" );				conn.rollback();				return;			} else {				System.out.println( "SqlactionDemoSAU.DELETE_FROM_sqlaction_demo_WHERE_name_E_ ok , rows["+nret+"] effected" );			}						// Insert record			sqlactionDemo = new SqlactionDemoSAU() ;			sqlactionDemo.name = "Calvin" ;			sqlactionDemo.address = "My address" ;			nret = SqlactionDemoSAU.INSERT_INTO_sqlaction_demo( conn, sqlactionDemo ) ;			if( nret < 0 ) {				System.out.println( "SqlactionDemoSAU.INSERT_INTO_sqlaction_demo failed["+nret+"]" );				conn.rollback();				return;			} else {				System.out.println( "SqlactionDemoSAU.INSERT_INTO_sqlaction_demo ok" );			}						// Update record with name			nret = SqlactionDemoSAU.UPDATE_sqlaction_demo_SET_address_E_WHERE_name_E_( conn, "My address 2", "Calvin" ) ;			if( nret < 0 ) {				System.out.println( "SqlactionDemoSAU.UPDATE_sqlaction_demo_SET_address_E_WHERE_name_E_ failed["+nret+"]" );				conn.rollback();				return;			} else {				System.out.println( "SqlactionDemoSAU.UPDATE_sqlaction_demo_SET_address_E_WHERE_name_E_ ok , rows["+nret+"] effected" );			}						// Query records			sqlactionDemoList = new LinkedList<SqlactionDemoSAU>() ;			nret = SqlactionDemoSAU.SELECT_ALL_FROM_sqlaction_demo( conn, sqlactionDemoList ) ;			if( nret < 0 ) {				System.out.println( "SqlactionDemoSAO.SELECT_ALL_FROM_sqlaction_demo failed["+nret+"]" );				conn.rollback();				return;			} else {				System.out.println( "SqlactionDemoSAO.SELECT_ALL_FROM_sqlaction_demo ok" );				for( SqlactionDemoSAU r : sqlactionDemoList ) {					System.out.println( "    id["+r.id+"] name["+r.name+"] address["+r.address+"]" );				}			}						conn.commit();		} catch(Exception e) {			try {				conn.rollback();			} catch (Exception e2) {				return;			}		}				return;	}}

2.5. 执行

SqlactionDemoSAU.DELETE_FROM_sqlaction_demo_WHERE_name_E_ ok , rows[1] effectedSqlactionDemoSAU.INSERT_INTO_sqlaction_demo okSqlactionDemoSAU.UPDATE_sqlaction_demo_SET_address_E_WHERE_name_E_ ok , rows[1] effectedSqlactionDemoSAO.SELECT_ALL_FROM_sqlaction_demo ok    id[20] name[Calvin] address[My address 2]

总结：

对表的增删改查只需调用前面自动生成的SAU类中的方法即可，底层执行代码完全基于JDBC，可随时查看，没有什么秘密，没有什么高深的技术。

工具sqlaction只在开发阶段使用，与运行阶段无关，说到底只是在应用与JDBC之间自动生成了薄薄的一层代码而已，把大量手工冗余代码都通过自动化生成了，让开发者节省大量时间而去关注业务逻辑，减少大量机械操作减轻心智负担，提高生产力，早点做完工作回家抱女盆友/老婆 :)

3. 使用参考

3.1. 开发流程

                                        sqlactiondbserver.conf.json、sqlaction.conf.json ---------> XxxSao.java、XxxSau.java --\                                                                               ---> App.jar                                                                   App.java --/

sqlaction读取执行目录或上级目录中的数据库连接配置文件dbserver.conf.json和SQL动作配置文件sqlaction.conf.json，自动生成基于JDBC的SQL动作源代码的SAO类，以及继承SAO类的SAU类，应用直接调用SAU类就能操作数据库DML。

SAO类XXXSao.java在每次执行工具sqlaction时都会被覆盖刷新，所以不要手工修改。

SAU类XXXSau.java在首次执行工具sqlaction时创建，后续执行时不会被覆盖刷新，所以需要定制、扩展的方法和属性都加在这个类中，又因为SAU类继承自SAO类，如果存在相同的方法，应用调用的始终都是SAU类中的版本。

3.2. 配置文件dbserver.conf.json

{	"driver" : "com.mysql.jdbc.Driver" ,	"url" : "jdbc:mysql://127.0.0.1:3306/calvindb?serverTimezone=GMT" ,	"user" : "root" ,	"pwd" : "root" ,	"userDefineDataTypes" : [		{ "source":"decimal,*,12,2" , "redefine":"double,*,14,*" }	]}

数据库连接配置文件dbserver.conf.json配置了工具sqlaction执行所需数据库层面上的信息：

driver : DBMS驱动类。

url : DBMS连接配置串。

user : DBMS连接用户名。

pwd : DBMS连接密码。

userDefineDataTypes : 自定义字段类型转换，比如数据库中的类型DECIMAL(12,2)映射到JAVA变量类型是BigDecimal，但在某应用系统中希望是JAVA变量类型double，可以在这个配置集中在正式转换前把DECIMAL(12,2)强制转换成DOUBLE，那么正式转换时DOUBLE会映射成JAVA变量类型double。

数据库字段类型与sqlaction的JAVA变量类型映射表：

MySQL字段类型	sqlaction的JAVA变量类型
bit	boolean
tinyint	byte
smallint	short
mediumint	int
int	int
bigint	long
real	float
float	double
double	double
decimal	BigDecimal
numeric	BigDecimal
char	String
varchar	String
date	java.sql.Date
time	java.sql.Time
datetime	java.sql.Date
timestamp	timestamp
year	java.sql.Date
binary	byte[]
varbinary	byte[]
blob	byte[]
tinyblob	byte[]
mediumblob	byte[]
longblob	byte[]
(other)	String

注意：数据库连接配置文件dbserver.conf.json一般放在项目根目录里，以便于所有子模块都能使用到。

注意：读取JSON配置文件使用到了我的另一个开源项目：okjson，一个简洁易用的JSON解析器/生成器，只有一个类文件，可以很方便的融合到其它项目中。

dbms : 一般情况下sqlaction根据driver能猜对数据库类型，那么这个配置就不用写明，如果你用的driver实在太怪异导致猜不到，请显式配置。

3.3. 配置文件sqlaction.conf.json

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user_base" ,			"sqlactions" : [				"SELECT * FROM user_base" ,				"SELECT * FROM user_base WHERE name=?" ,				"SELECT name,address FROM user_base WHERE age<=? AND gender=?" ,				"SELECT * FROM user_base ORDER BY name DESC" ,				"SELECT gender,count(*) FROM user_base GROUP BY gender" ,				"INSERT INTO user_base @@SELECTSEQ(user_base_seq_id) @@SELECTKEY(id)" ,				"UPDATE user_base SET lvl=?" ,				"UPDATE user_base SET address='calvin address',lvl=10 WHERE name='Calvin'" ,				"UPDATE user_base SET lvl=? WHERE age>? AND gender=?" ,				"DELETE FROM user_base" ,				"DELETE FROM user_base WHERE name='Calvin'" ,				"DELETE FROM user_base WHERE age<>? AND gender<>?"			]		} ,		{			"table" : "user_order" ,			"sqlactions" : [				"SELECT /* blablabla~ */ * FROM user_order @@STATEMENT_INTERCEPTOR()" ,				"SELECT * FROM user_order WHERE user_id=?" ,				"SELECT * FROM user_order @@PAGEKEY(id)" ,				"SELECT * FROM user_order WHERE item_name<>'' @@PAGEKEY(id) @@PAGESORT(DESC)" ,				"SELECT user_base.name,user_base.address,user_order.item_name,user_order.amount,user_order.total_price					FROM user_base,user_order					WHERE user_base.name=? AND user_base.id=user_order.user_id					@@METHOD(queryUserAndOrderByName)" ,				"SELECT u.name,u.address,o.* FROM user_base u,user_order o WHERE u.name=? AND u.id=o.user_id @@STATEMENT_INTERCEPTOR(statementInterceptorForQueryUserAndOrderByName)" ,				"SELECT o.* #{UserOrderSAU.*} FROM user_order o #{user_order} @@ADVANCEDMODE" ,				"SELECT MIN(total_price) #{SqlActionTest.minTotalPrice:double}, MAX(total_price) #{SqlActionTest.maxTotalPrice:double}, COUNT(*) #{UserOrderSAU._count_}					FROM user_order #{user_order}					@@ADVANCEDMODE" ,				"SELECT user_base.name				#{UserBaseSAU.name}					,user_order.item_name			#{UserOrderSAU.itemName}					,SUM(user_order.amount)			#{UserOrderSAU.amount}					,SUM(user_order.total_price)	#{UserOrderSAU.totalPrice}					FROM user_base					#{user_base}						,user_order					#{user_order}					WHERE user_order.user_id IN (												SELECT id												FROM user_base												WHERE id>=?		#{UserOrderSAU.id}											)						AND user_order.user_id=user_base.id					GROUP BY user_base.name					ORDER BY user_base.name					@@ADVANCEDMODE @@METHOD(statUsersAmountAndTotalPrice)" ,				"INSERT INTO user_order @@SELECTSEQ(user_order_seq_id) @@SELECTKEY(id)" ,				"UPDATE user_order SET total_price=? WHERE user_id=?" ,				"DELETE FROM user_order" ,				"DELETE FROM user_order WHERE user_id=? #{UserOrderSAU.userId} @@ADVANCEDMODE @@METHOD(removeUserOrder)"			]		}	] ,	"javaPackage" : "xyz.calvinwilliams.test"}

SQL动作配置文件sqlaction.conf.json主要配置了数据库SQL动作列表，用于后续的自动生成JDBC代码。

database : 数据库名。

tables : 表列表。

table : 表名。

sqlactions : SQL语句列表。注意最后一条SQL后不带','以符合JSON规范。

javaPackage : JAVA包名，自动生成JAVA类文件时放在最上面。

目前sqlaction支持的SQL标准：

查询

SQL动作语法：

SELECT [*|[table_name.|table_alias_name.][column_name|*][,...][,COUNT(*)]]    [ /* hint */ ]    FROM table_name [table_alias_name],...    [ WHERE [table_name.|table_alias_name.]column_name [=|<>|>|>=|<|<=] [?|const|[table_name2.|table_alias_name2.]column_name2] [AND ...] ]    [ GROUP BY [table_name.|table_alias_name.]column[,[table_name2.|table_alias_name.]column2][,...] ]    [ HAVING ... ]    [ ORDER BY column[,...] [ASC|DESC] ]    ...

SQL动作语法示例：

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user_base" ,			"sqlactions" : [				"SELECT * FROM user_base" ,				"SELECT * FROM user_base WHERE name=?" ,				"SELECT name,address FROM user_base WHERE age<=? AND gender=?" ,				"SELECT * FROM user_base ORDER BY name DESC" ,				"SELECT gender,count(*) FROM user_base GROUP BY gender" ,

自动生成JDBC代码：

	// SELECT * FROM user_base	public static int SELECT_ALL_FROM_user_base( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput ) throws Exception {		Statement stmt = conn.createStatement() ;		ResultSet rs = stmt.executeQuery( "SELECT * FROM user_base" ) ;		while( rs.next() ) {			UserBaseSAU userBase = new UserBaseSAU() ;			userBase.id = rs.getInt( 1 ) ;			userBase.name = rs.getString( 2 ) ;			userBase.gender = rs.getString( 3 ) ;			userBase.age = rs.getShort( 4 ) ;			userBase.address = rs.getString( 5 ) ;			userBase.lvl = rs.getInt( 6 ) ;			userBaseListForSelectOutput.add(userBase) ;		}		rs.close();		stmt.close();		return userBaseListForSelectOutput.size();	}	// SELECT * FROM user_base WHERE name=?	public static int SELECT_ALL_FROM_user_base_WHERE_name_E_( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput, String _1_UserBaseSAU_name ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "SELECT * FROM user_base WHERE name=?" ) ;		prestmt.setString( 1, _1_UserBaseSAU_name );		ResultSet rs = prestmt.executeQuery() ;		while( rs.next() ) {			UserBaseSAU userBase = new UserBaseSAU() ;			userBase.id = rs.getInt( 1 ) ;			userBase.name = rs.getString( 2 ) ;			userBase.gender = rs.getString( 3 ) ;			userBase.age = rs.getShort( 4 ) ;			userBase.address = rs.getString( 5 ) ;			userBase.lvl = rs.getInt( 6 ) ;			userBaseListForSelectOutput.add(userBase) ;		}		rs.close();		prestmt.close();		return userBaseListForSelectOutput.size();	}	// SELECT name,address FROM user_base WHERE age<=? AND gender=?	public static int SELECT_name_j_address_FROM_user_base_WHERE_age_LE_AND_gender_E_( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput, short _1_UserBaseSAU_age, String _2_UserBaseSAU_gender ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "SELECT name,address FROM user_base WHERE age<=? AND gender=?" ) ;		prestmt.setShort( 1, _1_UserBaseSAU_age );		prestmt.setString( 2, _2_UserBaseSAU_gender );		ResultSet rs = prestmt.executeQuery() ;		while( rs.next() ) {			UserBaseSAU userBase = new UserBaseSAU() ;			userBase.name = rs.getString( 1 ) ;			userBase.address = rs.getString( 2 ) ;			userBaseListForSelectOutput.add(userBase) ;		}		rs.close();		prestmt.close();		return userBaseListForSelectOutput.size();	}	// SELECT * FROM user_base ORDER BY name DESC	public static int SELECT_ALL_FROM_user_base_ORDER_BY_name_DESC( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput ) throws Exception {		Statement stmt = conn.createStatement() ;		ResultSet rs = stmt.executeQuery( "SELECT * FROM user_base ORDER BY name DESC" ) ;		while( rs.next() ) {			UserBaseSAU userBase = new UserBaseSAU() ;			userBase.id = rs.getInt( 1 ) ;			userBase.name = rs.getString( 2 ) ;			userBase.gender = rs.getString( 3 ) ;			userBase.age = rs.getShort( 4 ) ;			userBase.address = rs.getString( 5 ) ;			userBase.lvl = rs.getInt( 6 ) ;			userBaseListForSelectOutput.add(userBase) ;		}		rs.close();		stmt.close();		return userBaseListForSelectOutput.size();	}	// SELECT gender,count(*) FROM user_base GROUP BY gender	public static int SELECT_gender_j_count_ALL_FROM_user_base_GROUP_BY_gender( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput ) throws Exception {		Statement stmt = conn.createStatement() ;		ResultSet rs = stmt.executeQuery( "SELECT gender,count(*) FROM user_base GROUP BY gender" ) ;		while( rs.next() ) {			UserBaseSAU userBase = new UserBaseSAU() ;			userBase.gender = rs.getString( 1 ) ;			userBase._count_ = rs.getInt( 2 ) ;			userBaseListForSelectOutput.add(userBase) ;		}		rs.close();		stmt.close();		return userBaseListForSelectOutput.size();	}

插入

SQL动作语法：

INSERT INTO table_name

SQL动作语法示例：

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user_base" ,			"sqlactions" : [				"INSERT INTO user_base @@SELECTSEQ(user_base_seq_id) @@SELECTKEY(id)" ,

自动生成JDBC代码：

	// INSERT INTO user_base @@SELECTSEQ(user_base_seq_id) @@SELECTKEY(id)	public static int INSERT_INTO_user_base( Connection conn, UserBaseSAU userBase ) throws Exception {		PreparedStatement prestmt ;		Statement stmt ;		ResultSet rs ;		prestmt = conn.prepareStatement( "INSERT INTO user_base (name,gender,age,address,lvl) VALUES (?,?,?,?,?)" ) ;		prestmt.setString( 1, userBase.name );		prestmt.setString( 2, userBase.gender );		prestmt.setShort( 3, userBase.age );		prestmt.setString( 4, userBase.address );		prestmt.setInt( 5, userBase.lvl );		int count = prestmt.executeUpdate() ;		prestmt.close();		if( count != 1 )			return count;				stmt = conn.createStatement() ;		rs = stmt.executeQuery( "SELECT LAST_INSERT_ID()" ) ;		rs.next();		userBase.id = rs.getInt( 1 ) ;		rs.close();		stmt.close();				return count;	}

更新

SQL动作语法：

UPDATE table_name    SET column_name = [?|const|column_name2] [,...]    [ WHERE column_name [=|<>|>|>=|<|<=] [const|column_name2] [AND ...] ]

SQL动作语法示例：

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user_base" ,			"sqlactions" : [				"UPDATE user_base SET lvl=?" ,				"UPDATE user_base SET address='calvin address',lvl=10 WHERE name='Calvin'" ,				"UPDATE user_base SET lvl=? WHERE age>? AND gender=?" ,

自动生成JDBC代码：

	// UPDATE user_base SET lvl=?	public static int UPDATE_user_base_SET_lvl_E_( Connection conn, int _1_lvl_ForSetInput ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "UPDATE user_base SET lvl=?" ) ;		prestmt.setInt( 1, _1_lvl_ForSetInput );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// UPDATE user_base SET address='calvin address',lvl=10 WHERE name='Calvin'	public static int UPDATE_user_base_SET_address_E_calvin_address_j_lvl_E_10_WHERE_name_E_Calvin_( Connection conn ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "UPDATE user_base SET address='calvin address',lvl=10 WHERE name='Calvin'" ) ;		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// UPDATE user_base SET lvl=? WHERE age>? AND gender=?	public static int UPDATE_user_base_SET_lvl_E_WHERE_age_GT_AND_gender_E_( Connection conn, int _1_lvl_ForSetInput, short _1_age_ForWhereInput, String _2_gender_ForWhereInput ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "UPDATE user_base SET lvl=? WHERE age>? AND gender=?" ) ;		prestmt.setInt( 1, _1_lvl_ForSetInput );		prestmt.setShort( 2, _1_age_ForWhereInput );		prestmt.setString( 3, _2_gender_ForWhereInput );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}

删除

SQL动作语法：

DELETE FROM table_name    [ WHERE column_name [=|<>|>|>=|<|<=] [const|column_name2] [AND ...] ]

SQL动作语法示例：

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user_base" ,			"sqlactions" : [				"DELETE FROM user_base" ,				"DELETE FROM user_base WHERE name='Calvin'" ,				"DELETE FROM user_base WHERE age<>? AND gender<>?"

自动生成JDBC代码：

	// DELETE FROM user_base	public static int DELETE_FROM_user_base( Connection conn ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "DELETE FROM user_base" ) ;		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// DELETE FROM user_base WHERE name='Calvin'	public static int DELETE_FROM_user_base_WHERE_name_E_Calvin_( Connection conn ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "DELETE FROM user_base WHERE name='Calvin'" ) ;		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}	// DELETE FROM user_base WHERE age<>? AND gender<>?	public static int DELETE_FROM_user_base_WHERE_age_NE_AND_gender_NE_( Connection conn, short _1_age, String _2_gender ) throws Exception {		PreparedStatement prestmt = conn.prepareStatement( "DELETE FROM user_base WHERE age<>? AND gender<>?" ) ;		prestmt.setShort( 1, _1_age );		prestmt.setString( 2, _2_gender );		int count = prestmt.executeUpdate() ;		prestmt.close();		return count;	}

注意：数据库连接配置文件sqlaction.conf.json一般放在JAVA包目录里，以便于自动生成的类打包。

3.4. 自动生成JDBC代码的规则

工具sqlaction读取数据库中的表结构元信息和SQL动作配置文件sqlaction.conf.json，在执行目录里自动生成JAVA类源代码文件XxxSao.java和XxxSau.java。类源代码文件XxxSao.java包含数据库表实体信息（字段映射属性）和SQL动作对应方法，每次运行sqlaction都会刷新该类源代码文件，所以不要修改此文件。类源代码文件XxxSau.java包含用户自定义代码，首次运行sqlaction会生成该类源代码文件，所以用户定制代码可写到此文件中。

数据库表字段映射属性由数据库中的表结构元信息映射生成，转换规则见前面的数据库字段类型与sqlaction的JAVA变量类型映射表。如果DDL中有comment，则在表实体类的对应属性后面加注释。

SQL动作对应缺省方法名为SQL转换而来，具体算法为所有非字母数字字符都转换为'_'，合并多个'_'为一个。

方法前的注释是原SQL，以便于对照和定位。

方法的第一个参数是数据库连接对象，可以和连接池框架结合使用。

如果SQL动作涉及输出，自动生成的代码在SQL执行后，根据解析出来的输出项（SELECT）自动生成getString等代码，方法参数中也要求给予以便于输出，按表实体类列表对象排列，SQL JOIN多表对应多个表实体类列表对象。

如果SQL动作涉及输入，自动生成的代码将使用JDBC的prepareStatement，并根据解析出来的输入项（SET、WHERE）自动生成setString等代码，方法参数中也要求给予以便于输入，按字段名排列。如果没有输入则使用createStatement。

如果是查询SQL，JAVA方法返回表实体类列表大小。如果是插入、更新、删除SQL，JAVA方法返回受影响记录条数。

表实体类属性列表中额外有"int count ;"，用于查询COUNT(*)时存储输出结果用。

插入方法中会自动识别忽略自增类型。

就这么简单！

3.5. 配置元

SQL动作的最后面可追加一些以"@@"开头的配置元以实现一些额外的功能。

3.5.1. 自定义SQL动作方法名

允许自定义SQL动作方法名，在SQL动作配置中追加元信息"@@METHOD(自定义方法名)"，如：

				"SELECT user_base.name,user_base.address,user_order.item_name,user_order.amount,user_order.total_price					FROM user_base,user_order					WHERE user_base.name=? AND user_base.id=user_order.user_id					@@METHOD(queryUserAndOrderByName)" ,

自动生成代码如下：

	public static int queryUserAndOrderByName( Connection conn, List<UserBaseSAU> userBaseListForSelectOutput, List<UserOrderSAU> userOrderListForSelectOutput, String _1_UserBaseSAU_name ) throws Exception {		...		return userBaseListForSelectOutput.size();	}

3.5.2. 抽象统一了自增字段和序列两大数据库阵营对主键值的赋值

在INSERT时对主键值的赋值，一些拥有自增类型的数据库如MySQL只要在DDL里指明AUTO_INCREMENT，插入时会自动取当前值自增一作为新记录该字段的插入值，插入成功后调用SELECT LAST_INSERT_ID()回取出来告知应用，另一些拥有序列（SEQUENCE）的数据库如Oracle在插入前获取序列的下一个值作为新记录该字段的插入值。sqlaction为了统一前面两种对主键值的赋值在使用层面的抽象，定义了两个配置元@@SELECTKEY(字段名)和@@SELECTSEQ(序列名)。

示例：

{	"database" : "calvindb" ,	"tables" : [		{			"table" : "user" ,			"sqlactions" : [				...				"INSERT INTO user_base @@SELECTKEY(id) @@SELECTSEQ(user_base_seq_id)" ,

当在MySQL等有自增功能的DBMS中，sqlaction处理sqlaction.conf.json自动生成的JDBC代码中，在INSERT操作完后，追加生成调用"SELECT LAST_INSERT_ID()"的代码，取得自增主键值，赋值到主键字段中：

	public static int INSERT_INTO_user_base( Connection conn, UserBaseSAU userBase ) throws Exception {		PreparedStatement prestmt ;		Statement stmt ;		ResultSet rs ;		prestmt = conn.prepareStatement( "INSERT INTO user_base (name,gender,age,address,lvl) VALUES (?,?,?,?,?)" ) ;		prestmt.setString( 1, userBase.name );		prestmt.setString( 2, userBase.gender );		prestmt.setShort( 3, userBase.age );		prestmt.setString( 4, userBase.address );		prestmt.setInt( 5, userBase.lvl );		int count = prestmt.executeUpdate() ;		prestmt.close();		if( count != 1 )			return count;				stmt = conn.createStatement() ; 
                       
                    
                     
                      



鲜花




握手




雷人




路过




鸡蛋