java鏈接並操作數據庫

• 鏈接准備

1. MySQL數據庫驅動（連接器）。mysql-connector-java-x.x.xx.jar會在MySQL安裝時提供，若Mysql是默認安裝路徑，則連接器在：C:\Program Files (x86)\MySQL\Connector.J 5.1文件夾里，然后在項目中建立一個lib文件夾，拷貝連接器放進去：

 

　　2.將數據庫驅動導入至項目的工作空間中，使得其內部包含的包和類都加入到編譯環境中。（導入方式，選中上面一步的連接器，右鍵Buid path）

 

下面建立一個鏈接操作類來描述鏈接和操作方法：

• 建立一個類Test

public class Test {

    public static void main(String[] args) {
        
    }
}

 

• 第一步：在代碼中初始化數據庫驅動：Class.forName("com.mysql.jdbc.Driver").newInstance();,並添加異常處理塊。

 

//第一步，在代碼中初始化數據庫驅動：
Class.forName("com.mysql.jdbc.Driver").newInstance();//初始化數據庫驅動

 

• 第二步：使用DriverManager鏈接數據庫：

//第二步，使用DriverManager鏈接數據庫：
Connection con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydbone", "root", "199751hwl");

 

•  第三步：獲得一個會話：

//3.獲得一個會話：
statement = con.createStatement();

 

•  第四步：statement.execute執行SQL語句並返回結果：
  • 查操作

if (statement.execute("SELECT * from person")) {//查
            
     rs = statement.getResultSet();
     while( rs.next() ) {    //    依次獲得查詢結果，每次執行nest，換一行
          String name = rs.getString("persName");//獲取字段
          String sex = rs.getString("persSex");
          System.out.println(name+"\t"+sex);
     }                
}
else {
     System.out.println("沒有數據！");
}
            

 

• • 增操作

if (statement.execute("INSERT into person VALUE(7,'小發發','男','學習')")) {    
   System.out.println("異常！");//增操作這里沒有返回
}
else {
   System.out.println("增加成功！");
}

 

• 第五步，關閉結果獲取，關閉會話和鏈接

finally {
    try {
                //第五步，關閉結果獲取，關閉會話和鏈接
            statement.close();
            con.close();
            rs.close();
    } catch (SQLException e1) {
        e1.printStackTrace();
    }
}                            

• 一個完整的小栗子：

import java.sql.*;

public class TestOne {

    public static void main(String[] args) {
        
        ResultSet rs = null;
        Statement statement = null;
        Connection con = null;
        
        try {
            
            //第一步，在代碼中初始化數據庫驅動：
            Class.forName("com.mysql.jdbc.Driver").newInstance();//初始化數據庫驅動
            //第二步，使用DriverManager鏈接數據庫：指定鏈接數據庫的信息
            con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/mydbone?useUnicode=true&characterEncoding=UTF-8","root","199751hwl");
            //第三步，獲得一個會話：
            statement = con.createStatement();
            //第四步，執行SQL並查除結果集合
            if (statement.execute("SELECT * from person")) {//查
                rs = statement.getResultSet();
                while( rs.next() ) {    //    依次獲得查詢結果，每次執行nest，換一行
                    String name = rs.getString("persName");//獲取字段
                    String sex = rs.getString("persSex");
                    System.out.println(name+"\t"+sex);
                }
            }
            else {
                System.out.println("增加成功！");
            }
            
        } catch (InstantiationException | IllegalAccessException | ClassNotFoundException | SQLException e) {
            e.printStackTrace();
        }finally {
            try {
                //第五步，關閉結果獲取，關閉會話和鏈接
                statement.close();
                con.close();
                rs.close();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
        }
    }
}