自习室管理系统

package room.javabean; import java.sql.*; import javax.swing.JTable; import javax.swing.table.DefaultTableModel; public class SqlExecute { public Connection conn; //数据库连接对象 public Statement stmt; //语句执行对象 public ResultSet rset; //结果集 public void getStatement() throws Exception { try { Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver").newInstance(); Connection conn=DriverManager.getConnection("jdbc:sqlserver://SHUAI-PC:1433;DatabaseName=studyroom","sa", "as"); Statement stmt=conn.createStatement(); //Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); //conn = DriverManager.getConnection( // "jdbc:sqlserver://localhost:1433;DatabaseName=studyroom;user=sa;password=as;"); //stmt = conn.createStatement(); } catch(Exception e) { throw e; } } //关闭使用完的数据库连接，当完成数据库操作后应该调用此方法关闭连接 public void closeAll() throws SQLException { try { //检查连接是否已关闭，如果没有关闭，则关闭 //没有使用 isClosed()方法判断，使用受限制 //如果已对连接调用 close 方法，或出现一些错误，则连接关闭。仅在调用了 close 方法后调用此方法时，它才返回 true。 if( stmt != null ) { stmt.close(); stmt = null; } if( conn != null ) { conn.close(); conn = null; } } catch(SQLException se) { throw se; } } public int executeSql(String sql) throws Exception { //记录受影响的记录数 int recoders = 0; //设置 Statement类型的成员变量 stmt getStatement(); //执行数据库操作 recoders = stmt.executeUpdate(sql); //关闭所有打开的数据库对象 closeAll(); return recoders; } public JTable getTable(String sql) throws Exception{ //设置 Statement类型的成员变量 stmt getStatement(); //执行数据库查询，获得结果集 rset = stmt.executeQuery(sql); ResultSetMetaData rsmd=rset.getMetaData(); //返回元数据对象 //获得列数，注意这个值后面多处用到 int columns = rsmd.getColumnCount(); String columntitle[] = new String[columns]; //创建列名数组 for (int j=1; j<=columns; j++) columntitle[j-1] = rsmd.getColumnLabel(j); //获得列名填充表格标题数组 DefaultTableModel tm = new DefaultTableModel(columntitle, 0); //根据结果集的列数创建数组，保存数据结果集中的一条记录 String results[]= new String[columns]; //迭代遍历结果集，每次将一行记录添加到 table 中 //这里由于使用了模板，只进行了一次遍历 while (rset.next()){ for(int i=0; i<columns; i++){ //将当前行的值存到数组，这里都用了字符串格式，注意 rset 的计数是从 1 开始 //另外这里直接用了字段的顺序来赋值。没有用字段名的方式，这样可以和具体表结构无关 results[i] = rset.getString(i+1); } //将一行记录添加到表模板中，注意是加到了模板里，而不是表格 tm.addRow(results); } JTable tb = new JTable(); //用模板填充表格，则选择表格中的数据就是模板中的 tb.setModel(tm); //需要自己手动关闭 ResultSet rset.close(); //关闭所有其它打开的数据库对象 closeAll(); //返回表格 return tb; } public ResultSet getResultSet(String sql)throws Exception{ getStatement(); //执行数据库查询，获得结果集 rset = stmt.executeQuery(sql); return rset; } }