8:Mysql數(shù)據(jù)庫(kù)的連接以及數(shù)據(jù)的增刪改查……

導(dǎo)入Mysql包mysql-connector-java-5.1.0-bin

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.List;

public class test {

    public test() {

       // TODO Auto-generated constructor stub

    }

    public static Connection con;

    /**

     * @param args

     */

    public static void main(String[] args) {

       connectMysql();

// 增刪改都是利用一個(gè)相同的方法，只是不同的ＳＱＬ語(yǔ)句就可以；

//     dealwithSql("insert into testgql values(4,'gql4');");

//     dealwithSql("delete from testgql where id='4'");

//     dealwithSql("update testgql set name='ggqqll' where id='2'");

       selectSql("select * from testgql");

       closeSql();

    }

    /**

     * @param 連接Mysql數(shù)據(jù)庫(kù)

     * */

    public static void connectMysql() {

       String JDriver = "com.mysql.jdbc.Driver"; // MySQL提供的JDBC驅(qū)動(dòng)，要保證它在CLASSPATH里可見(jiàn)

       String conURL = "jdbc:mysql://localhost/test"; // 本地計(jì)算機(jī)上的MySQL數(shù)據(jù)庫(kù)Company的URL

       try {

           Class.forName(JDriver);

       } catch (ClassNotFoundException cnf_e) { // 如果找不到驅(qū)動(dòng)類(lèi)[一定要導(dǎo)入包mysql-connector-java-5.1.0-bin慎之慎之]

           System.out.println("Driver Not Found: " + cnf_e);

       }

       try {

           con = DriverManager.getConnection(conURL, "root", "root"); // 連接數(shù)據(jù)庫(kù) name  pass

       } catch (SQLException sql_e) { // 都是SQLException

           System.out.println("無(wú)法連接數(shù)據(jù)庫(kù)!!!!!!");

       }

    }

    /**

     * @param 關(guān)閉Mysql服務(wù)器

     */

    public static void closeSql() {

       try {

           con.close();// 關(guān)閉到MySQL服務(wù)器的連接

       } catch (SQLException e) {

           e.printStackTrace();

           System.out.println("關(guān)閉數(shù)據(jù)庫(kù)出錯(cuò)!!!!!!");

       }

    }

    /**

     * @param 數(shù)據(jù)庫(kù)的查詢；

     * @select_sql_str 查詢語(yǔ)句代碼String

     * */

    public static ResultSet selectSql(String select_sql_str) {

       ResultSet rs = null;

       Statement s = null;

       try {

           s = con.createStatement(); // Statement類(lèi)用來(lái)提交SQL語(yǔ)句

           rs = s.executeQuery(select_sql_str); // 提交查詢，返回的表格保存在rs中

           while (rs.next()) { // ResultSet指針指向下一個(gè)“行”

              System.out.println(rs.getInt("id") + // 獲取員工號(hào)

                     "\t" + rs.getString("name") // 獲得name

              );

           }

           s.close(); // 釋放Statement對(duì)象

       } catch (SQLException sql_e) { // 都是SQLException

           System.out.println(sql_e);

       }

       return rs;

    }

    /**

     * @param  數(shù)據(jù)庫(kù)的增刪改

     * */

    public static void dealwithSql(String add_sql_str) {

       Statement st;

       try {

           st = con.createStatement();

           st.executeUpdate(add_sql_str);

           st.close();

       } catch (SQLException e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       }

    }

}