[大数据]存储过程、Statement详解

序言

Statement接口以及他们的实现是JDBC API中比较重要的一部分，Statement接口中定义了执行SQL语句的方法，这些方法不支持入参，PreparedStatement接口增加了入参的方法，CallableStatement接口继承了PreparedStatement，在此基础上增加了调用存储过程以及检索存储过程调用结果的方法。

存储过程

先了解一下存储过程

what?

存储过程（Stored Procedure）是在大型数据库系统中，一组为了完成特定功能的SQL 语句集，它存储在数据库中，一次编译后永久有效，用户通过指定存储过程的名字并给出参数（如果该存储过程带有参数）来执行它。存储过程是数据库中的一个重要对象。在数据量特别庞大的情况下利用存储过程能达到倍速的效率提升。

why?

简化、提高效率、保证数据一致性、灵活

how?

创建存储过程

--创建存储过程（不带参数的）
CREATE PROCEDURE showAllData()
BEGIN
select * from blog;
END

调用存储过程

call showAllData()

带参数的

 CREATE PROCEDURE getDataByid
     (IN id INT)
     BEGIN
     SELECT name FROM blog
     WHERE bid=id;
     END 

call getDataByid(1)

这是简单的使用

java.sql.Statement接口

Statement是JDBC API惭怍数据库的核心接口，具体的实现由JDBC驱动完成。Statement比较简单，只调用Connection对象的createStatement方法就可以，例如：

	DataSource dataSource = (DataSource) ctx.lookup("java:TestCB");
	Connection connection = dataSource.getConnection();
	Statement statement = connection.createStatement();

每一个Connection可以创建多个Statement对象，Connection中的createStatement有多个重载实现。
Statement的主要作用是与数据库进行交互，这个接口中定义了一些数据库操作以及检索SQL执行结果相关的方法。

例如：
addBatch
clearBatch
executeBatch
…
提供了很多和数据库交互的方法，具体怎么用看场景和需求。
如果我们不确定SQL语句的类型，则可以调用excute()方法，改方法也有几个重载方法。可能返回多个结果，可以通过getMoreResult()来获得下一个结果，这个方法执行结果为true时，说明下一个结果为ResultSet，为false时，则下一个结果为执行的影响行数或者没有了。每次调用它的时候都会关闭上一个的ResultSet对象，但是我们可以通过重载方法的参数指定是否关闭ResultSet对象。

CLOSE_CURRENT_RESULT 关闭
KEEP_CURRENT_RESULT 不关闭
CLOSE_ALL_RESULTS 当返回下一个ResultSet的时候，当前所有的未关闭的ResultSet全部关闭

如果当前返回的是影响的行数的时候，则getMoreResults()方法将会被忽略。

批量执行

void addBatch(String sql); // 把一句sql语句添加到批量执行的SQL列表中
void clearBatch(); // 清空批量执行的sql语句
int[] executeBatch(); // 批量的执行SQL列表中的语句

DataSource dataSource = (DataSource) ctx.lookup("java:TestCB");
			Connection connection = dataSource.getConnection();
			Statement statement = connection.createStatement();
			statement.addBatch("insert into  " +
					                   "blog (bid, name, author_id) " +
					                   "values('3', '我测你们码', '1009');");
			statement.addBatch("insert into " +
					                   "blog (bid, name, author_id) " +
					                   "values('4', '做人不要太cj', '8848');");
			statement.executeBatch();
			statement.execute("select * from blog");

PreparedStatement

PreparedStatement接口继承自Statement接口，在Statement接口的基础上增加了参数占位符功能，PreparedStatement接口中增加了一些方法。可以为占位符设置值。PreparedStatement的实例表示可以被预编译的SQL语句，执行一次后，多次执行时执行效率会比较高。使用PreparedStatement实例执行SQL语句时，可以使用?作为参数占位符，然后使用PreparedStatement接口中提示的方法设置占位符。
PreparedStatement的创建

Connection connection = dataSource.getConnection();
Statement statement = connection.prepareStatement("insert into  " +
					                                                  "blog (bid, name, author_id) " +
					                                                  "values('3', '我测你们码', '1009');");

CallableStatement接口

可以看出这个接口继承自PreparedStatement，它是在PreparedStatement 中增加了调用存储过程并且检索调用结果的功能

public interface CallableStatement extends PreparedStatement {
  ..............................
}

使用：

Connection connection = dataSource.getConnection();
CallableStatement statement = connection.prepareCall("call getDataByid(?)");
statement.setString(1,"1");

获得自增长的键值

目前，大部分主流的数据库都支持自增长主键，当向表增加数据时，数据库引擎可以自动生成增长主键。Statement接口提供了getGeneratedKeys()方法，用于获得数据库自动生成的值，该方法返回一个ResultSet对象，我们可以从ResultSet对象中获取数据库中所有自增长的键值。

ResultSet genKeys = statement.getGeneratedKeys();
	if(genKeys.next()) {
				System.out.println("自增长主键：" + genKeys.getInt(1));
	}

还可以指定被检索的字段呢。

结束语

码字不易，请点个赞吧。谢谢！
下一章我们将一个ResultSet