jdbcutil.java

来自「一个简单ssh+extjs的人力资源管理系统（转载）」· Java 代码 · 共 68 行

package com.idealab.util;

import java.sql.DriverManager;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class JdbcUtil {
	private final String driver = "com.mysql.jdbc.Driver";
	private final String url="jdbc:mysql://localhost:3306/ehr?autoReconnect=true&useUnicode=true&characterEncoding=utf-8";
	private final String user = "root";
	private final String pwd = "ideal";
	private Connection conn = null;
	private Statement st = null;

	public void openConn(){
		try{
			Class.forName(driver);
			conn = DriverManager.getConnection(url,user,pwd);
			conn.setAutoCommit(true);
		}catch(SQLException e){
			e.printStackTrace();
			System.out.println("数据库连接失败!");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	public boolean executeUpdate(String sql)throws SQLException{ 
        try {
            /*判断必需的属性是否为空*/  
        	if(conn==null || sql == null||sql.equals("")){   
                return true;   
            }
        	st = conn.createStatement();
            int i = st.executeUpdate(sql); 
            System.out.println(i+"行受影响");
            return true;
        } catch (SQLException e) { 
            e.printStackTrace();
            System.out.println("更新失败!");
            return false;
        } 
    } 

    public ResultSet executeQuery(String sql){ 
    	ResultSet rs = null;
        try { 
        	st = conn.createStatement();
            rs = st.executeQuery(sql);
        } catch (SQLException e) { 
            e.printStackTrace(); 
            System.out.println("查询数据失败.未获得ResultSet!");
        }
        return rs;
    } 

    public void closeConn() { 
        try { 
            st.close(); 
            conn.close(); 
        } catch (Exception e) { 
            e.printStackTrace(); 
            System.out.println("关闭数据库连接失败!");
        } 
    } 
}