java實現(xiàn)mysql操作類分享 java連接mysql

更新時間：2014年01月19日 16:19:13 作者：

這篇文章主要介紹了java實現(xiàn)的mysql操作類示例，大家在連接數(shù)據(jù)的時候可以直接使用了

相關(guān)軟件和驅(qū)動：
Mysql下載版本：4.1.11
http://dev.mysql.com/downloads/mysql/4.1.html

JDBC驅(qū)動下載版本：3.1.8
http://dev.mysql.com/downloads/connector/j/3.1.html

代碼

Code highlighting produced by Actipro CodeHighlighter (freeware)http://www.CodeHighlighter.com/-->import java.sql.*;

public class mysql {
    public static String url = "jdbc:mysql://localhost:3306/test";//characterEncoding=GBK
    public static String username = "root";
    public static String password = "root";
    public static Connection con;
    public static Statement stmt;
    public static ResultSet rs;

    public static void main(String[] args) throws SQLException {
        connect();
        operation();
        stmt.close();
        con.close();
    }
    public static void test() {
        String sql_select = "select * from tablename where id=1";
        String sql_insert = "insert into tablename (col1,col2..) values('1','2'...)";
        String sql_update = "update tablename set colname='update' where id=1";
        //insert(sql_insert);
        //select(sql_select);
        //update(sql_update);
    }
    public static void connect() {
        // 定位驅(qū)動
        try {
            Class.forName("com.mysql.jdbc.Driver");
            System.out.println("加載驅(qū)動成功!");
        } catch (ClassNotFoundException e) {
            System.out.println("加載驅(qū)動失敗!");
            e.printStackTrace();
        }
        // 建立連接
        try {
            con = DriverManager.getConnection(url, username, password);
            stmt = con.createStatement();
            System.out.println("數(shù)據(jù)庫連接成功!");
        } catch(SQLException e) {
            System.out.println("數(shù)據(jù)庫連接失敗!");
        }
    }
    public static void select(String sql) {
        try {
            rs = stmt.executeQuery(sql);
            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();
            }
            rs.close();
        }catch (Exception e) {
            System.out.println("數(shù)據(jù)查詢失敗!");
        }
    }
    public static void insert(String sql) {
        try {
            stmt.clearBatch();
            stmt.addBatch(sql);
            stmt.executeBatch();
            System.out.println("數(shù)據(jù)插入成功!");
        }catch (Exception e) {
            System.out.println("數(shù)據(jù)插入失敗!");
        }

    }
    public static void update(String sql) {
        try {
            stmt.executeUpdate(sql);
            System.out.println("數(shù)據(jù)更新成功!");
        }catch (Exception e) {
            System.out.println("數(shù)據(jù)更新失敗!");
        }
    }
}