Mysql数据库的连接以及数据的增删改查……

8:Mysql数据库的连接以及数据的增删改查……

导入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();

// 增删改都是利用一个相同的方法，只是不同的ＳＱＬ语句就可以；

//     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数据库

     * */

    public static void connectMysql() {

       String JDriver = "com.mysql.jdbc.Driver"; // MySQL提供的JDBC驱动，要保证它在CLASSPATH里可见

       String conURL = "jdbc:mysql://localhost/test"; // 本地计算机上的MySQL数据库Company的URL

       try {

           Class.forName(JDriver);

       } catch (ClassNotFoundException cnf_e) { // 如果找不到驱动类[一定要导入包mysql-connector-java-5.1.0-bin慎之慎之]

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

       }

       try {

           con = DriverManager.getConnection(conURL, "root", "root"); // 连接数据库 name  pass

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

           System.out.println("无法连接数据库!!!!!!");

       }

    }

    /**

     * @param 关闭Mysql服务器

     */

    public static void closeSql() {

       try {

           con.close();// 关闭到MySQL服务器的连接

       } catch (SQLException e) {

           e.printStackTrace();

           System.out.println("关闭数据库出错!!!!!!");

       }

    }

   

    /**

     * @param 数据库的查询；

     * @select_sql_str 查询语句代码String

     * */

    public static ResultSet selectSql(String select_sql_str) {

       ResultSet rs = null;

       Statement s = null;

       try {

           s = con.createStatement(); // Statement类用来提交SQL语句

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

           while (rs.next()) { // ResultSet指针指向下一个“行”

              System.out.println(rs.getInt("id") + // 获取员工号

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

              );

           }

           s.close(); // 释放Statement对象

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

           System.out.println(sql_e);

       }

       return rs;

    }

    /**

     * @param  数据库的增删改

     * */

    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();

       }

    }

   

   

 

}