JDBC編程：使用 Statement 修改數據庫

　　獲取數據連接后，即可對數據庫中的數據進行修改和查看。使用 Statement 接口可以對數據庫中的數據進行修改，下面是程序演示。

 

/**
 * 獲取數據庫連接，並使用SQL語句，向數據庫中插入記錄
 */
package com.pack03;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class TestStatement {

    //***************************該方法用於獲取數據庫連接*****************************
    public static Connection getConnection() throws Exception {
        // 1.將配置文件中的連接信息獲取到Properties對象中
        InputStream is = 
                TestStatement.class.getClassLoader().getResourceAsStream("setting.properties");

        Properties setting = new Properties();
        setting.load(is);

        // 2.從Properties對象中讀取需要的連接信息
        String driverName = setting.getProperty("driver");
        String url = setting.getProperty("url");
        String user = setting.getProperty("user");
        String password = setting.getProperty("password");

        // 3.加載驅動程序，即將數據庫廠商提供的Driver接口實現類加載進內存；
        // 該驅動類中的靜態代碼塊包含有注冊驅動的程序，在加載類時將被執行
        Class.forName(driverName);

        // 4.通過DriverManager類的靜態方法getConnection獲取數據連接
        Connection conn = DriverManager.getConnection(url, user, password);
        
        return conn;
    }
    
    
    //************************該方法用於執行SQL語句，修改數據庫內容*************************
    public static void testStatement( String sqlStatement ) {
        
        Connection conn = null;
        Statement statement = null;
        
        try {
            //1.獲取到數據庫的連接
            conn = getConnection();
            
            //2.用Connection中的 createStatement()方法獲取 Statement 對象
            statement = conn.createStatement();
            
            //3.調用 Statement 對象的 executeUpdate()方法，執行SQL語句並修改數據庫
            statement.executeUpdate( sqlStatement );
            
        } catch (Exception e) {
            
            e.printStackTrace();
            
        } finally {
            
            //4.關閉Statement對象
            if(statement != null) {
                try {
                    statement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            
            //5.關閉 Connection對象
            if(conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    
    public static void main(String[] args) {
        
        
        String sqlInsert = "insert into tab001 values( 3, '小明3' )"; //插入語句
        String sqlUpdate = "update tab001 set name='王凱' where id=1"; //修改語句
        String sqlDelete = "delete from tab001 where id=2"; //刪除語句
        //對於Statement對象，不能執行select語句
        
        testStatement( sqlInsert );
        testStatement( sqlUpdate );
        testStatement( sqlDelete );
    }
}

 

注：希望與各位讀者相互交流，共同學習進步。