通过Statement来执行SQL的Insert,Delete,Update操作
package xuezaipiao; /** * 通过JDBC向数据表中添加数据 * 1.获取数据库连接 * 2.Statement : 用于执行SQL的对象 * --通过 Connection 的createStatement() 方法来获取 * --通过executeUpdate(sql) 可以执行SQL语句 * --注意SQL 是INSERT、UPDATE、DELETE,不能是SELECT * 3.Connection 和 Statement 是应用程序和数据库服务器的连接资源,必须要关闭 * --使用try-catch-finally 来关闭,先关statement , 再关connection */ import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; public class UseStatement { public static void main(String[] args)throws Exception { Connection conn = null; Statement statement = null; try { conn = getConnection(); System.out.println(conn); statement = conn.createStatement(); String sql = "insert into customer(id,name,email) values(7,'x','[email protected]')"; //String sql = "update customer set name = 'bbb' where id = 3"; //String sql = "delete from customer where id = 2"; System.out.println(statement.executeUpdate(sql)); } catch (SQLException e) { e.printStackTrace(); }finally{ try { if(statement!=null) statement.close(); } catch (Exception e) { e.printStackTrace(); }finally{ if(conn!=null) conn.close(); } } }
遇到一个特别蛋疼的事,手贱,把plsql dev也打开了,操作customer表,结果忘记commit,eclipse死命的等待,一上午光差错,线程啊、线程,注:insert操作不受影响,其他必须commit
整合代码
合成一个工具类,方便使用
package xuezaipiao; /** * JDBC工具类 * 封装一些简单的JDBC操作方法 * version 1 */ import java.io.FileInputStream; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; import java.util.Properties; public class JDBC_Tools { /** * 用来释放资源,参数是 Connection 、 Statement * @param conn * @param statement */ public static void relaseSource(Connection conn ,Statement statement){ if(statement!=null){ try { statement.close(); } catch (SQLException e) { e.printStackTrace(); } } //使用两个 if ,这样即使中间出现异常,程序还是继续执行下去 if(conn!=null){ try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } /** * 用来获取数据库连接 * @return Connection * @throws Exception */ public static Connection getConnection() throws Exception { Properties properties = new Properties(); try { // InputStream in = getClass().getClassLoader().getResourceAsStream("jdbc.properties"); // properties.load(in); properties.load(new FileInputStream( "D://LearnJava//learnJDBC//Lesson2_UseStatement//src//jdbc.properties")); } catch (FileNotFoundException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } String user = properties.getProperty("user"); String password = properties.getProperty("password"); String jdbcUrl = properties.getProperty("jdbcUrl"); String dirverName = properties.getProperty("driver"); try { Class.forName(dirverName); } catch (ClassNotFoundException e1) { e1.printStackTrace(); } Connection connection = null; try { connection = DriverManager.getConnection(jdbcUrl, user, password); } catch (SQLException e) { e.printStackTrace(); } return connection; } }
package xuezaipiao; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; public class UseStatement { public static void main(String[] args)throws Exception { String sql = "insert into customer(id,name,email) values(7,'x','[email protected]')"; //String sql = "update customer set name = 'bbb' where id = 6"; //String sql = "delete from customer where id = 7"; System.out.println(updateSQL(sql)); } public static int updateSQL(String sql) throws Exception{ Connection conn = null; Statement statement = null; int num = 0; try { conn = JDBC_Tools.getConnection(); statement = conn.createStatement(); num = statement.executeUpdate(sql); } catch (SQLException e) { e.printStackTrace(); }finally{ JDBC_Tools.relaseSource(conn, statement); } return num; } }
关于execute、executeQuery和executeUpdate之间的区别
JDBCTM中Statement接口提供的execute、executeQuery和executeUpdate之间的区别
Statement 接口提供了三种执行 SQL 语句的方法:executeQuery、executeUpdate 和 execute。使用哪一个方法由 SQL 语句所产生的内容决定。
方法executeQuery
用于产生单个结果集的语句,例如 SELECT 语句。 被使用最多的执行 SQL 语句的方法是 executeQuery。这个方法被用来执行 SELECT 语句,它几乎是使用最多的 SQL 语句。
方法executeUpdate
用于执行 INSERT、UPDATE 或 DELETE 语句以及 SQL DDL(数据定义语言)语句,例如 CREATE TABLE 和 DROP TABLE。INSERT、UPDATE 或 DELETE 语句的效果是修改表中零行或多行中的一列或多列。executeUpdate 的返回值是一个整数,指示受影响的行数(即更新计数)。对于 CREATE TABLE 或 DROP TABLE 等不操作行的语句,executeUpdate 的返回值总为零。
使用executeUpdate方法是因为在 createTableCoffees 中的 SQL 语句是 DDL (数据定义语言)语句。创建表,改变表,删除表都是 DDL 语句的例子,要用 executeUpdate 方法来执行。你也可以从它的名字里看出,方法 executeUpdate 也被用于执行更新表 SQL 语句。实际上,相对于创建表来说,executeUpdate 用于更新表的时间更多,因为表只需要创建一次,但经常被更新。
方法execute:
用于执行返回多个结果集、多个更新计数或二者组合的语句。因为多数程序员不会需要该高级功能
execute方法应该仅在语句能返回多个ResultSet对象、多个更新计数或ResultSet对象与更新计数的组合时使用。当执行某个已存储过程或动态执行未知 SQL 字符串(即应用程序程序员在编译时未知)时,有可能出现多个结果的情况,尽管这种情况很少见。
因为方法 execute 处理非常规情况,所以获取其结果需要一些特殊处理并不足为怪。例如,假定已知某个过程返回两个结果集,则在使用方法 execute 执行该过程后,必须调用方法 getResultSet 获得第一个结果集,然后调用适当的 getXXX 方法获取其中的值。要获得第二个结果集,需要先调用 getMoreResults 方法,然后再调用 getResultSet 方法。如果已知某个过程返回两个更新计数,则首先调用方法 getUpdateCount,然后调用 getMoreResults,并再次调用
getUpdateCount。
对于不知道返回内容,则情况更为复杂。如果结果是 ResultSet 对象,则方法 execute 返回 true;如果结果是 Java int,则返回 false。如果返回 int,则意味着结果是更新计数或执行的语句是 DDL 命令。在调用方法 execute 之后要做的第一件事情是调用 getResultSet 或 getUpdateCount。调用方法 getResultSet 可以获得两个或多个 ResultSet 对象中第一个对象;或调用方法 getUpdateCount 可以获得两个或多个更新计数中第一个更新计数的内容。
当 SQL 语句的结果不是结果集时,则方法 getResultSet 将返回 null。这可能意味着结果是一个更新计数或没有其它结果。在这种情况下,判断 null 真正含义的唯一方法是调用方法 getUpdateCount,它将返回一个整数。这个整数为调用语句所影响的行数;如果为 -1 则表示结果是结果集或没有结果。如果方法 getResultSet 已返回 null(表示结果不是 ResultSet 对象),则返回值 -1 表示没有其它结果。也就是说,当下列条件为真时表示没有结果(或没有其它结果):
((stmt.getResultSet() == null) && (stmt.getUpdateCount() == -1))
如果已经调用方法 getResultSet 并处理了它返回的 ResultSet 对象,则有必要调用方法 getMoreResults 以确定是否有其它结果集或更新计数。如果 getMoreResults 返回 true,则需要再次调用 getResultSet 来检索下一个结果集。如上所述,如果 getResultSet 返回 null,则需要调用 getUpdateCount 来检查 null 是表示结果为更新计数还是表示没有其它结果。
当 getMoreResults 返回 false 时,它表示该 SQL 语句返回一个更新计数或没有其它结果。因此需要调用方法 getUpdateCount 来检查它是哪一种情况。在这种情况下,当下列条件为真时表示没有其它结果:
((stmt.getMoreResults() == false) && (stmt.getUpdateCount() == -1))
下面的代码演示了一种方法用来确认已访问调用方法 execute 所产生的全部结果集和更新计数:
stmt.execute(queryStringWithUnknownResults); while (true) { int rowCount = stmt.getUpdateCount(); if (rowCount > 0) { // 它是更新计数 System.out.println("Rows changed = " + count); stmt.getMoreResults(); continue; } if (rowCount == 0) { // DDL 命令或 0 个更新 System.out.println(" No rows changed or statement was DDL command"); stmt.getMoreResults(); continue; } // 执行到这里,证明有一个结果集 // 或没有其它结果 ResultSet rs = stmt.getResultSet; if (rs != null) { . . . // 使用元数据获得关于结果集列的信息 while (rs.next()) { . . . // 处理结果 stmt.getMoreResults(); continue; } break; // 没有其它结果