YREC.rar_ajax

package com.wmj.dao; import java.sql.*; import dianyingpiao.Person; /* * 对用户信息进行操作的数据库类 */ public class OperatorUser { public ResultSet queryData(Connection con, String sSQL) { ResultSet rResult = null; try { Statement stmt = con.createStatement(); rResult = stmt.executeQuery(sSQL); } catch (Exception e) { } finally { return rResult; } } /* * 用户的插入，若插入成功，返回true，否则返回false //user为需要插入的用户 */ public boolean insertUser(Person user) { boolean result = false; Connection con = null; PreparedStatement pmt = null; try { String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=DYP"; String users = "sa"; String userpassword = "9659"; /* 建立连接 */ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); con = DriverManager.getConnection(url, users, userpassword); /* 完成注册 */ pmt = con .prepareStatement("INSERT INTO LOGIN (NAME,PASS,RANK,TELNUM,ADDRESS) values(?,?,?,?,?)"); pmt.setString(1, user.getName()); pmt.setString(2, user.getPassword()); pmt.setInt(3, 0); pmt.setString(4, user.getTelnumber()); pmt.setString(5, user.getAddress()); pmt.executeUpdate(); result = true; } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } finally { // 关闭连接 try { if (pmt != null) pmt.close(); if (con != null) con.close(); } catch (SQLException e) { e.printStackTrace(); } } return result; } // 判断用户名密码是否正确，如果正确，返回用户姓名。 public String isUserPasswordCorrect(String userName, String userPassword, int userRank) { String result = ""; Connection con = null; ResultSet rs = null; PreparedStatement pmt = null; try { /* 设置所需变量 */ String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=DYP"; String users = "sa"; String userpassword = "9659"; /* 建立连接 */ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); con = DriverManager.getConnection(url, users, userpassword); /* 完成查询 */ pmt = con .prepareStatement("select * from LOGIN where NAME = ? and PASS = ? and RANK=?"); pmt.setString(1, userName); pmt.setString(2, userPassword); pmt.setInt(3, userRank); rs = pmt.executeQuery(); /* 如果查询结果不为空，则登陆成功；否则，登陆失败 */ if (rs.next()) { result = rs.getString(1); } } catch (ClassNotFoundException e) { // 声明驱动程序时报错 e.printStackTrace(); } catch (SQLException e) { // 数据库操作出错 e.printStackTrace(); } finally { // 关闭连接 try { if (rs != null) rs.close(); if (pmt != null) pmt.close(); if (con != null) con.close(); } catch (SQLException e) { e.printStackTrace(); } } return result; } /* 根据用户姓名获得用户的信息。 */ public Person getUserByName(String userName) { Person user = new Person(); /* 设置所需变量 */ Connection con = null; ResultSet rs = null; PreparedStatement pmt = null; try { String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=DYP"; String users = "sa"; String userpassword = "9659"; /* 建立连接 */ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); con = DriverManager.getConnection(url, users, userpassword); /* 完成查询 */ pmt = con.prepareStatement("select * from LOGIN where NAME= ?"); pmt.setString(1, userName); rs = pmt.executeQuery(); /* 如果查询结果不为空，设置用户信息 */ if (rs.next()) { user.setName(rs.getString(1)); user.setPassword(rs.getString(2)); user.setTelnumber(rs.getString(4)); user.setAddress(rs.getString(5)); } } catch (ClassNotFoundException e) { // 声明驱动程序时报错 e.printStackTrace(); } catch (SQLException e) { // 数据库操作出错 e.printStackTrace(); } finally { // 关闭连接 try { if (rs != null) rs.close(); if (pmt != null) pmt.close(); if (con != null) con.close(); } catch (SQLException e) { e.printStackTrace(); } } return user; } // 修改用户信息 public int updata(String sql) { Connection con = null; Statement smt = null; int result = 0; try { String url = "jdbc:sqlserver://127.0.0.1:1433;DatabaseName=DYP"; String users = "sa"; String userpassword = "9659"; /* 建立连接 */ Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); con = DriverManager.getConnection(url, users, userpassword); smt = con.createStatement(); result = smt.executeUpdate(sql); } catch (ClassNotFoundException e) { // 声明驱动程序时报错 e.printStackTrace(); } catch (SQLException e) { // 数据库操作出错 e.printStackTrace(); } finally { // 关闭连接 try { if (smt != null) smt.close(); if (con != null) con.close(); } catch (SQLException e) { e.printStackTrace(); } } return result; } }