datacontrol.java

来自「这是一个简单的办公管理系统」· Java 代码 · 共 117 行

package admin;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;


public class DataControl {
    private Connection con = null;
    private ResultSet rs = null;
    private PreparedStatement ps = null;

    public DataControl() {
        try {
        	
        	Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver").newInstance();
            String url = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=office";
            con = java.sql.DriverManager.getConnection(url,"office","281213");
        } catch (Exception e) {
            System.out.println("连接数据库失败");
            e.printStackTrace();
        }
    }

    /** 锟斤拷锟斤拷锟斤拷锟斤拷 */
    public Connection getCon() {
        return this.con;
    }

    public ResultSet getResulSet(String sql) {

        try {
            ps = con.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_UPDATABLE);
            rs = ps.executeQuery();
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("查询失败");
        }

        return rs;
    }

    public int getInsert(String sql) {
        try {
            ps = con.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,
                                          ResultSet.CONCUR_UPDATABLE);
            ps.executeUpdate();
            return 1;
        } catch (Exception e) {
            System.out.println("插入失败");
            e.printStackTrace();
            return 0;
        }
    }

    public int getUpdate(String sql) {
        try {
            ps = con.prepareStatement(sql);
            ps.executeUpdate();
            return 1;
        } catch (Exception e) {
            System.out.println("更新失败");
            e.printStackTrace();
            return 0;
        }
    }

    public int getDelete(String sql) {
        try {
            ps = con.prepareStatement(sql);
            ps.executeUpdate();
            return 1;
        } catch (Exception e) {
            System.out.println("删除失败");
            e.printStackTrace();
            return 0;
        }
    }

    public void closePs() {
        try {
            if (ps != null) {
                ps.close();
            }
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void closeRs() {
        try {
            if (rs != null) {
                rs.close();
            }
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void closeCon() {
        try {
            if (con != null) {
                con.close();
            }
        }catch (Exception e) {
            e.printStackTrace();
        }
    }

    public void close() {
        this.closeRs();
        this.closePs();
        this.closeCon();
    }
}