Java操作Mysql笔记

第一步，需要下载JDBC驱动, 点我。然后选择合适的版本即可。

下载完成之后解压，然后将mysql-connector-java-5.1.6-bin.jar文件放到java的安装目录下面。

这里每个人的安装路径不同，需要找到自己的路径。

第二步，需要在mysql下新建一个数据库，这个很简单，比如create database test;　

然后use test;来切换当前正在使用的数据库。

还需要新建一张表，因为下面我们的一些操作是在表上进行的。

第三步，加载JDBC驱动，连接数据库。

下面代码仅供参考，在我的机器上可以执行。

import java.sql.*;
import java.util.jar.JarException;

public class DBManager {
    // 用户名
    private String user = "";
    // 密码
    private String password = "";
    // 主机
    private String host = "";
    // 数据库名字
    private String database = "";
    /*
     * 
     * private String
     * url="jdbc:mysql://"+host+"/"+"useUnicode=true&characterEncoding=GB2312";
     */
    private String url = "";
    private Connection con = null;
    Statement stmt;
    /**
     * 
     * 根据主机、数据库名称、数据库用户名、数据库用户密码取得连接。
     * 
     * @param host
     *            String
     * 
     * @param database
     *            String
     * 
     * @param user
     *            String
     * 
     * @param password
     *            String
     */
    public DBManager(String host, String database, String user, String password) {
        this.host = host;
        this.database = database;
        this.user = user;
        this.password = password;
        // 显示中文
        this.url = "jdbc:mysql://" + host + "/" + database;
        try {
            Class.forName("com.mysql.jdbc.Driver");
        } catch (ClassNotFoundException e) {
            System.err.println("class not found:" + e.getMessage());
        }
        try {
            con = DriverManager.getConnection(this.url, this.user,
                    this.password);
            // 连接类型为ResultSet.TYPE_SCROLL_INSENSITIVE,
            // ResultSet.CONCUR_READ_ONLY
            stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                    ResultSet.CONCUR_READ_ONLY);
        } catch (SQLException a) {
            System.err.println("sql exception:" + a.getMessage());
        }
    }
    /**
     * 
     * 返回取得的连接
     */
    public Connection getCon() {
        return con;
    }
    /**
     * 
     * 执行一条简单的查询语句
     * 
     * 返回取得的结果集
     */
    public ResultSet executeQuery(String sql) {
        ResultSet rs = null;
        try {
            rs = stmt.executeQuery(sql);
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return rs;
    }
    /**
     * 
     * 执行一条简单的更新语句
     * 
     * 执行成功则返回true
     */
    public boolean executeUpdate(String sql) {
        boolean v = false;
        try {
            v = stmt.executeUpdate(sql) > 0 ? true : false;
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            return v;
        }
    }
    public static void main(String[] args) throws java.lang.NullPointerException{
        ResultSet rs;
        DBManager exe = new DBManager("127.0.0.1", "test", "root", "118118");

        rs = exe.executeQuery("SELECT * FROM student");
        
        try {
            ResultSetMetaData meta_data = rs.getMetaData();//列名
            for (int i_col = 1; i_col <= meta_data.getColumnCount(); i_col++) {
                System.out.print(meta_data.getColumnLabel(i_col) + "   ");
            }
            System.out.println();
            while (rs.next()) {
                for (int i_col = 1; i_col <= meta_data.getColumnCount(); i_col++) {
                    System.out.print(rs.getString(i_col) + "  ");
                }
                System.out.println();
            }
        } catch (Exception e) {

        }
    }
}