数据库工具类(UserDao)
2016-06-22 23:14
232 查看
public interface InUserDao {
public boolean findUser(String name,String password);
public void addUser(User user);
public void del(int id);
public User getUserByid(int id);
public User getUserByid(String id);
public void upDataUser(User user);
public List<User> getAllUser();
}
public class userDao implements InUserDao{
@Override
public boolean findUser(String name, String password) {
JdbcHelper helo=JdbcHelper.getInstance();
boolean isexist=false;
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user where name=? and password=?", new String[]{name,password});
try {
isexist=reset.next();
} catch (SQLException e) {
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return isexist;
}
@Override
public void addUser(User user) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("insert into test_user values(test_user_seq.nextval,?,?)", new String[]{user.getUsername(),user.getPassword()});
}
@Override
public void del(int id) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("delete test_user where id=?", new String[]{String.valueOf(id)});
}
封装好的数据库及user类方法以供外界查询:
@Override
public User getUserByid(String id) {
User user=new User();
JdbcHelper helo=JdbcHelper.getInstance();
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user where id=?", new String[]{id});
try {
while(reset.next()){
user.setId(reset.getInt(1));
user.setUsername(reset.getString(2));
user.setPassword(reset.getString(3));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return user;
}
@Override
public void upDataUser(User user) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("update test_user set name=?,password=? where id=?", new String[]{user.getUsername(), user.getPassword(),String.valueOf(user.getId())});
}
public List<User> getAllUser(){
List<User> users=new ArrayList<User>();
JdbcHelper helo=JdbcHelper.getInstance();
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user", null);
try {
while(reset.next()){
User user=new User();
user.setId(reset.getInt(1));
user.setUsername(reset.getString(2));
user.setPassword(reset.getString(3));
users.add(user);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return users;
}
@Override
public User getUserByid(int id) {
return getUserByid(String.valueOf(id));
}
}
public boolean findUser(String name,String password);
public void addUser(User user);
public void del(int id);
public User getUserByid(int id);
public User getUserByid(String id);
public void upDataUser(User user);
public List<User> getAllUser();
}
public class userDao implements InUserDao{
@Override
public boolean findUser(String name, String password) {
JdbcHelper helo=JdbcHelper.getInstance();
boolean isexist=false;
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user where name=? and password=?", new String[]{name,password});
try {
isexist=reset.next();
} catch (SQLException e) {
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return isexist;
}
@Override
public void addUser(User user) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("insert into test_user values(test_user_seq.nextval,?,?)", new String[]{user.getUsername(),user.getPassword()});
}
@Override
public void del(int id) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("delete test_user where id=?", new String[]{String.valueOf(id)});
}
封装好的数据库及user类方法以供外界查询:
@Override
public User getUserByid(String id) {
User user=new User();
JdbcHelper helo=JdbcHelper.getInstance();
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user where id=?", new String[]{id});
try {
while(reset.next()){
user.setId(reset.getInt(1));
user.setUsername(reset.getString(2));
user.setPassword(reset.getString(3));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return user;
}
@Override
public void upDataUser(User user) {
JdbcHelper helo=JdbcHelper.getInstance();
helo.executeDml("update test_user set name=?,password=? where id=?", new String[]{user.getUsername(), user.getPassword(),String.valueOf(user.getId())});
}
public List<User> getAllUser(){
List<User> users=new ArrayList<User>();
JdbcHelper helo=JdbcHelper.getInstance();
Connection conn=helo.getConnection();
ResultSet reset=helo.executeQuery(conn,"select * from test_user", null);
try {
while(reset.next()){
User user=new User();
user.setId(reset.getInt(1));
user.setUsername(reset.getString(2));
user.setPassword(reset.getString(3));
users.add(user);
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}finally{
helo.closeResult(reset);
helo.closeConn(conn);
}
return users;
}
@Override
public User getUserByid(int id) {
return getUserByid(String.valueOf(id));
}
}
相关文章推荐
- jdbc中的Statement和PreparedStatement接口对象
- Android之获取手机上的图片和视频缩略图thumbnails
- 基于 Red Hat 的发行版 Oracle Linux 正式发布Oracle Linux 7.1
- 数据库链接字符串查询网站
- Oracle Containers for J2EE远程安全漏洞(CVE-2014-0413)
- Oracle 10g R2不能使用EM的问题
- 表空间操作
- PreparedStatement中in子句的处理
- VMware下RedHat4.8_64位安装Oracle 10g RAC--简略脚本
- oracle sql日期比较
- 基于 Red Hat 的发行版 Oracle Linux 正式发布Oracle Linux 7.1
- DB2实例管理
- DB2实例管理
- OS block size和Oracle block size,查找OS Blocksize的方法
- 保障MySQL数据安全的14个最佳方法
- mysql问答汇集
- oracle中创建数据库和表空间的几点总结
- 数据库自动备份脚本