连接mysql用的JavaBean
import java.sql.*; public class MysqlBean { private Connection con = null; private ResultSet rs; private String driverName = "com.mysql.jdbc.Driver"; private String serverName = "localhost"; private String mydatabase = "user"; private String username = "root"; private String password = "138717"; public MysqlBean() { try { String url = "jdbc:mysql://" + serverName + "/" + mydatabase; // a Class.forName(driverName); // con = DriverManager.getConnection(url, username, password); con = DriverManager.getConnection("jdbc:mysql://" + serverName + ":3306/" + mydatabase + "?user=" + username + "&password=" + password + "&useUnicode=true&characterEncoding=UTF-8"); // con.setAutoCommit(false); } catch (ClassNotFoundException e) { // Could not find the database driver System.out.println("Could not find the database driver"); } catch (SQLException e) { // Could not connect to the database System.out.println("Could not connect to the database"); } } public Connection getCon() { return con; } public ResultSet getRs(String sql) throws Exception { try { Statement stmt = con.createStatement( ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY); rs = stmt.executeQuery(sql); } catch (Exception e) { e.printStackTrace(); } return rs; } public int executeUpdate(String sql) { int count = 0; try { Statement stmt = con .createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_UPDATABLE); count = stmt.executeUpdate(sql); if (count != 0) ; // con.commit(); else ; // con.rollback(); } catch (SQLException ex) { ex.printStackTrace(); } return count; } public void Close() { try { if (con != null) con.close(); } catch (Exception e) { e.printStackTrace(); } } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。