java连接mysql的实例程序

package test;

import java.sql.*;

import java.util.Scanner;

public class Test {

    //驱动

    privatefinal String driver = "com.mysql.jdbc.Driver";

    //后面的?号的东西消除warning

    privatefinal String url ="jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8&&useSSL=false";

    //用户名

    privatefinal String user = "root";

    //密码

    privatefinal String password = "haojunjie";

    privateResultSet rs = null;

    privateConnection conn = null;

    privateStatement statement = null;

    privateString sql = null;

    

    publicstatic void main(String[] args) {

      new Test().connect();

    }

    

    

    public voidchoice() {

      String choice = "";

      Scanner in = new Scanner(System.in);

      

      do {

         System.out.println("1..........查询");

         System.out.println("2..........插入");

         System.out.println("3..........删除");

         System.out.println("0..........退出");

         

         choice = in.nextLine();

         switch (choice) {

         case "1":

         case "查询":

            search();

            break;

         case "2":

         case "插入":

            insert();

            break;

         case "3":

         case "删除":

            delete();

            break;

         case "0":

         case "退出":

            disconnect();

            System.out.println("感谢你的使用");

            break;

         default:

            System.out.println("请输入正确的选择");

            break;

         }

      } while (!choice.equals("0") &&!choice.equals("退出"));

    }

    

    

    

    public voidconnect() {

      try {

         Class.forName(driver);

         conn = DriverManager.getConnection(url, user,password);

         if (!conn.isClosed()) {

            System.out.println("Succeeded connecting to theDatabase");

            choice();

         }

      } catch (ClassNotFoundException e) {

         System.out.println("没有mysql驱动");

      } catch (Exception e) {

         e.printStackTrace();

      }

    }

    

    

    public voidsearch() {

      try {

         statement = conn.createStatement();

         sql = "select * from 学生表";

         rs = statement.executeQuery(sql);

         while (rs.next()) {

            System.out.println(rs.getString(1) + "\t" +rs.getString(2) + "\t" + rs.getString(3) + "\t"

                  + rs.getString(4) + "\t" +rs.getString(5));

         }

      } catch (SQLException e) {

         e.printStackTrace();

      } catch (Exception e) {

         e.printStackTrace();

      }

    }

    

    

    

    public voidinsert() {

      try {

         statement = conn.createStatement();

         sql = "insert into 学生表values(3150,'hjj',null,null,null)";

         statement.executeUpdate(sql);

      } catch(SQLException e) {

         e.printStackTrace();

      }

    }

    

    

    

    public voiddelete() {

      try {

         statement = conn.createStatement();

         sql = "delete from 学生表 where 学号 = 3150";

         statement.executeUpdate(sql);

      } catch(SQLException e) {

         e.printStackTrace();

      }

    }

    

    

    

    public voiddisconnect() {

      try {

         if (rs != null) {

            rs.close();

         }

         if (conn != null) {

            conn.close();

         }

      } catch (Exception e) {

         e.printStackTrace();

      }

    }

}