淺談通過使用JDBC的statement進行數據操作

作者：nbtlxx 2009-07-16 14:46:48
開發后端
本文將介紹如何通過使用JDBC的statement進行數據操作，Statement生成的自動生成鍵是否可用于獲取。希望本文對大家有所幫助。
使用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的五個精華功能
Tomcat5+MySQL JDBC連接池配置
在Weblogic中實現JDBC的功能
詳解JDBC與Hibernate區別
JDBC連接MySQL數據庫關鍵四步
淺談JDBC的概念理解與學習
責任編輯：彭凡來源： javaeye
jdbc statement
成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

淺談通過使用JDBC的statement進行數據操作
