Windows下Java程序实现对Mysql数据库的插入，删除，修改和查询

运行环境：Windows7，Eclipse，MySql，JDK1.7，mysql-connector-java-5.1.17-bin.jar

//import java.io.*;
import java.util.*;
import java.sql.*;

/**
 * 
 * @date 2014-05-20
 * @author asif
 * @作用  java实现对mysql数据库的增减删查 
 *
 */

public class ZGSC {
    public static void main(String args[])
    {
        try
        {
            //连接数据库
            Connection conn = MysqlConnection();
            //conn.close();
            System.out.println("Connect database success,Please select :");
            System.out.println("1.(list)	 2.(insert)	 3.(delete)	 4.(update)	 0.(exit)");
            System.out.println("----------------------------------------------------------------------------------");
            Scanner in = new Scanner(System.in);
            while(in.hasNext())
            {
                int Case = in.nextInt();
                switch(Case)
                {
                case 1:
                    Listsql(conn);
                    break;
                case 2:
                    Insertsql(conn);
                    break;
                case 3:
                    Deletesql(conn);
                    break;
                case 4:
                    Updatesql(conn);
                    break;
                case 0:
                    conn.close();    //退出时关闭数据库
                    System.out.println("Program exit,goodbye!");
                    return;
                default:
                    System.out.println("Your input error,Please input again");
                }
            }
            in.close();
        }
        catch(Exception e)
        {
            System.out.println("Cant't connect mysql database!");
            e.getStackTrace();
        }
    }
    
    //连接数据库函数
    public static Connection MysqlConnection()
    {
        String username = "root";
        String userpasswd = "123456";
        String url = "jdbc:mysql://127.0.0.1:3306/test";
        try
        {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            try
            {
                Connection contemp = DriverManager.getConnection(url, username, userpasswd);
                return contemp;
            }
            catch (SQLException e)
            {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        catch (InstantiationException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IllegalAccessException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }
        return null;
    }
    
    //查询数据库里面所有的元素
    public static void Listsql(Connection conn) throws SQLException
    {
        //Connection conn = MysqlConnection();    //每次打开一次数据库效率较低
        PreparedStatement pstmt;
        ResultSet rset;
        String sql = "select * from student";
        pstmt = conn.prepareStatement(sql);
        //获取结果
        rset = pstmt.executeQuery();
        while (rset.next())
        {
            System.out.println(rset.getString("sno")+"	"+rset.getString("sname")+"	"+rset.getString("sex")); // Print col 1
        }
        //conn.close();
    }
    
    //向数据库里面插入元素
    public static void Insertsql(Connection conn) throws SQLException
    {
        //Connection conn = MysqlConnection();
        PreparedStatement pstmt;
        String sql = "insert student(sno,sname,sex) values(?,?,?)";
        pstmt = conn.prepareStatement(sql);
        Scanner in = new Scanner(System.in);
        System.out.println("输入你要插入的数据:(依次为: sno（学号）,sname（姓名）,sex（性别）)");
        String name,no,se;
        no = in.next();
        name = in.next();
        se = in.next();
        pstmt.setString(1, no);
        pstmt.setString(2,name);
        pstmt.setString(3, se);
        //获得结果
        pstmt.executeUpdate();
        System.out.println("Insert success.Your insert data is:");
        System.out.printf("no = %s, name = %s, se = %s
",no,name,se);
        //conn.close();
        //in.close();
    }
    
    //从数据库里面删除元素
    public static void Deletesql(Connection conn) throws SQLException
    {
        //Connection conn = MysqlConnection();
        PreparedStatement pstmt;
        String sql = "delete from student where sname = ?";
        pstmt = conn.prepareStatement(sql);
        Scanner in =new Scanner(System.in);
        System.out.println("输入你要删除人的姓名");
        String name;
        name = in.next();
        pstmt.setString(1,name);
        //获得结果
        pstmt.executeUpdate();
        System.out.println("Delete success.Your Delete data is:");
        System.out.printf("name = %s
",name);
        //conn.close();
        //in.close();
    }
    
    //修改数据库里面的元素
    public static void Updatesql(Connection conn) throws SQLException
    {
        //Connection conn = MysqlConnection();
        PreparedStatement pstmt;
        String sql = "update student set sex=? where sno=?";
        pstmt = conn.prepareStatement(sql);
        Scanner in = new Scanner(System.in);
        String no,se;
        System.out.println("输入要修改的人的学号和对应的性别");
        no = in.next();
        se = in.next();
        pstmt.setString(1, se);
        pstmt.setString(2, no);
        //获得结果
        pstmt.executeUpdate();
        System.out.println("Update success.Your Update data is:");
        System.out.printf("sno %s sex change to %s
",no,se);
        //conn.close();
        //in.close();
    }
}