dboperatorbean.java

酒店管理系统后台数据库存储过程

package entity;

import java.sql.*;

//创建数据库操作的实体类
public class DBOperatorBean {
    public DBOperatorBean() {
        try {
            jbInit();
        } catch (Exception ex) {
            ex.printStackTrace();
        }
    }

    private Connection con = null;
    private  Statement s = null;
    private ResultSet rs = null;

    //获得数据库连接
    private void getConnection()
    {
        try {

            Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
           con = DriverManager.getConnection("jdbc:microsoft:sqlserver://localhost:1433;databaseName=rummery;","sa","sa");
           // Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
           // con  = DriverManager.getConnection("jdbc:odbc:accp");
            if(con!=null)
            {
                System.out.println("数据库连接成功!");
            }
        } catch (Exception ex) {
            ex.printStackTrace();
        }

    }
    //执行没有返回结果的数据库操作,数据的增加,删除,修改
    public boolean updateNoReturn(String sql)
    {      boolean  flag = false;
         getConnection();
        try {
            s = con.createStatement();
            s.executeUpdate(sql);
            flag = true;
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        close();
        return flag;
    }
      //执行有查询返回结果的数据查询
    public ResultSet returnQuery(String sql)
    {
        getConnection();
        try {
            s = con.createStatement();
            rs = s.executeQuery(sql);
        } catch (SQLException ex) {
            ex.printStackTrace();
        }
        return rs;
    }

    private void close()
    {
        if(s!=null)
        {
            try {
                s.close();
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        }

        if(con!=null)
        {
            try {
                con.close();
            } catch (SQLException ex1) {
                ex1.printStackTrace();
            }
        }
    }

    private void jbInit() throws Exception {
    }
}