股票交易项目源码

package com.ambow.vsts.dao.imp; import java.sql.Connection; import java.sql.Date; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import com.ambow.vsts.dao.UserDao; import com.ambow.vsts.entity.Users; import com.ambow.vsts.util.DBFactory; public class UserDaoImp implements UserDao { //所有 SQL 语句写在类的开头 private String addsql = "insert into users(" + "name,passwd,email,phone,trueName," + "address,reg_date) values(?,?,?,?,?,?,?)"; private String modifysql = "update users set name=?,passwd=?"; private String loginsql = "select * from users where name=? and passwd=?"; public boolean add(Users user) { boolean b =false; Connection conn = null; PreparedStatement stmt = null; try { //1 得到数据库连接对象 conn = DBFactory.getConnection(); //2 得到 SQL 执行对象 stmt = conn.prepareStatement(this.addsql); //给SQL中的 ? 赋值 ,按照 ? 出现的位置赋值，从 1 开始 stmt.setString(1, user.getName()); stmt.setString(2, user.getPasswd()); stmt.setString(3, user.getEmail()); stmt.setString(4, user.getPhone()); stmt.setString(5, user.getTrueName()); stmt.setString(6, user.getAddress()); //把当前系统的时间 util.Date ，转化为能够存入数据库的时间 Date sqldate = new Date(new java.util.Date().getTime()); stmt.setDate(7, sqldate); //3 执行 SQL int row = stmt.executeUpdate(); //4 处理结果 if(row > 0){ b = true; } //5 关闭连接 conn.close(); } catch (Exception e) { // TODO: handle exception } return b; } public boolean modify(Users user) { // TODO Auto-generated method stub return false; } public boolean checkName(String name) { // TODO Auto-generated method stub return false; } public Users login(String name, String password) { Users user = null; Connection conn = null; PreparedStatement stmt = null; try { //1 得到数据库连接对象 conn = DBFactory.getConnection(); //2 得到 SQL 执行对象 stmt = conn.prepareStatement(this.loginsql); //给SQL中的 ? 赋值 ,按照 ? 出现的位置赋值，从 1 开始 stmt.setString(1, name); stmt.setString(2, password); //3 执行 SQL ResultSet rs = stmt.executeQuery(); //4 处理结果 while(rs.next()){ user = new Users(); //给 null 对象赋值 //封装 每个单元格中的数据，到一个完整的对象中 int id = rs.getInt("user_id"); user.setId(id); user.setName(rs.getString("name")); user.setPasswd(rs.getString("passwd")); user.setEmail(rs.getString("email")); user.setPhone(rs.getString("phone")); user.setTrueName(rs.getString("truename")); user.setAddress(rs.getString("address")); user.setReg_date(rs.getDate("reg_date")); } //5 关闭连接 conn.close(); } catch (Exception e) { System.out.println("查询错误，检查你的 SQL 语句......"); } return user; } }