小編給大家分享一下如何通過使用JDBC的statement進行數據操作,相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!
創新互聯專注于企業營銷型網站、網站重做改版、道里網站定制設計、自適應品牌網站建設、H5網站設計、商城網站建設、集團公司官網建設、成都外貿網站建設、高端網站制作、響應式網頁設計等建站業務,價格優惠性價比高,為道里等各大城市提供網站開發制作服務。
使用JDBC的statement進行數據的查詢,基本步驟如下:
1. 初始化simpleDbSource對象
2. 獲得getconnection
3. createStatement 獲得查詢語句
4. executeUpdate, 執行更新語句
5. 關閉使用的statement, connection, 注意次序不要弄錯
注意:更新語句,執行過一次后,column需要遞增,否則報錯
Java代碼
/** * */ package db; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; /** * @author sean * * 1. 初始化simpleDbSource對象 * 2. 獲得getconnection * 3. createStatement 獲得查詢語句 * 4. executeUpdate, 執行更新語句 * 5. 關閉使用的statement, connection, 注意次序不要弄錯 * * 注意:更新語句,執行過一次后,column需要遞增,否則報錯 */ public class StatementDemo { private static String insertSql="insert into user values('7','sean','sean@mail.com','hellofromsean')"; private static String querySql ="select * from user"; /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub DBSource dbSource; Connection conn = null; java.sql.Statement stmt = null; try { dbSource = new SimpleDBSource(); conn = dbSource.getConnect(); stmt = conn.createStatement(); //數據庫更新工作,包括create, drop, update, insert etc. stmt.executeUpdate(insertSql); System.out.println("執行成功"+ insertSql); //進行數據庫查詢 ResultSet rs = stmt.executeQuery(querySql); //進行遍歷 while(rs.next()){ System.out.println(rs.getInt(1)+ "\t"); System.out.println(rs.getString(2)+ "\t"); System.out.println(rs.getString(3)+ "\t"); System.out.println(rs.getString(4)+ "\t"); System.out.println("**********************"); } } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } //依次關閉statement和conn數據庫連接對象,清空資源 finally{ if(stmt!= null){ try { stmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } stmt= null; } if(conn!=null){ try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } conn= null; } } } } /** * */ package db; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; /** * @author sean * * 1. 初始化simpleDbSource對象 * 2. 獲得getconnection * 3. createStatement 獲得查詢語句 * 4. executeUpdate, 執行更新語句 * 5. 關閉使用的statement, connection, 注意次序不要弄錯 * * 注意:更新語句,執行過一次后,column需要遞增,否則報錯 */ public class StatementDemo { private static String insertSql="insert into user values('7','sean','sean@mail.com','hellofromsean')"; private static String querySql ="select * from user"; /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub DBSource dbSource; Connection conn = null; java.sql.Statement stmt = null; try { dbSource = new SimpleDBSource(); conn = dbSource.getConnect(); stmt = conn.createStatement(); //數據庫更新工作,包括create, drop, update, insert etc. stmt.executeUpdate(insertSql); System.out.println("執行成功"+ insertSql); //進行數據庫查詢 ResultSet rs = stmt.executeQuery(querySql); //進行遍歷 while(rs.next()){ System.out.println(rs.getInt(1)+ "\t"); System.out.println(rs.getString(2)+ "\t"); System.out.println(rs.getString(3)+ "\t"); System.out.println(rs.getString(4)+ "\t"); System.out.println("**********************"); } } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } //依次關閉statement和conn數據庫連接對象,清空資源 finally{ if(stmt!= null){ try { stmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } stmt= null; } if(conn!=null){ try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } conn= null; } } } } /** * */ package db; import java.io.FileNotFoundException; import java.io.IOException; import java.sql.Connection; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; /** * @author sean * * 1. 初始化simpleDbSource對象 * 2. 獲得getconnection * 3. createPreparedStatement 獲得查詢語句 * 4. 設置具體更新內容,setInt(colIndex, value), setString(colIndex,value) * 4. executeUpdate, 執行更新語句 * 5. 關閉使用的PreparedStatementstatement, connection, 注意次序不要弄錯 * * 注意:更新語句,執行過一次后,column需要遞增,否則報錯 */ public class PreparedStatementDemo { private static String querySql ="select * from user"; private static String pstmtSql = "insert into user values(?,?,?,?)"; Connection conn1; static Statement stmt; /** * @param args */ public static void main(String[] args) { // TODO Auto-generated method stub DBSource dbSource; Connection conn = null; java.sql.PreparedStatement pstmt = null; try { dbSource = new SimpleDBSource(); conn = dbSource.getConnect(); pstmt = conn.prepareStatement(pstmtSql); pstmt.setInt(1, 9); pstmt.setString(2, "sean"); pstmt.setString(3, "my@hotmail.com"); pstmt.setString(4, "add some comments"); //數據庫更新工作,包括create, drop, update, insert etc. pstmt.executeUpdate(); //清空設置的參數,為后續更新準備 pstmt.clearParameters(); System.out.println("執行成功"+ pstmtSql); //進行數據庫查詢 Connection conn1 = dbSource.getConnect(); Statement stmt = conn1.createStatement(); ResultSet rs = stmt.executeQuery(querySql); //進行遍歷 while(rs.next()){ System.out.println(rs.getInt(1)+ "\t"); System.out.println(rs.getString(2)+ "\t"); System.out.println(rs.getString(3)+ "\t"); System.out.println(rs.getString(4)+ "\t"); System.out.println("**********************"); } } catch (FileNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } //依次關閉jdbc的statement和conn數據庫連接對象,清空資源 finally{ if(stmt!= null){ try { stmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } stmt= null; } if(pstmt!= null){ try { pstmt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } pstmt= null; } if(conn!=null){ try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } conn= null; } } } }
以上是“如何通過使用JDBC的statement進行數據操作”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注創新互聯行業資訊頻道!