userdao.java

网上书店后台管理源码基于struts1.2+oracle数据库

package com.dongfang.dao;

import java.sql.*;
import java.util.*;

import com.dongfang.po.Admin;
import com.dongfang.po.Member;

public class UserDAO {
	//管理员登陆
	public Admin Login(Admin admin)
	{
		Admin myAdmin = null;
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		conn = DBTools.getConn();
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery("select * from adminuser where username='"+admin.getUsername()+"' and password='"+admin.getPassword()+"'");
			if(rs.next())
			{
				myAdmin = new Admin();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs!=null)
						rs.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(stm!=null)
						stm.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(conn!=null)
						conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return myAdmin;
	}
	//过的所有用户
	public List getAllMember(String keyword)
	{
		List memberList = new ArrayList();
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		Member member = null;
		conn = DBTools.getConn();
		String sql = "";
		
		if(keyword.equalsIgnoreCase(""))
		{
			sql = "select * from member";
		}
		else
		{
			sql = "select * from member where username like'%"+keyword+"%'";
		}
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery(sql);
			while(rs.next())
			{
				member = new Member();
				member.setId(rs.getInt("id"));
				member.setUsername(rs.getString("username"));
				member.setPassword(rs.getString("password"));
				member.setRealname(rs.getString("realname"));
				member.setTel(rs.getString("tel"));
				member.setAddress(rs.getString("address"));
				member.setZip(rs.getString("zip"));
				member.setEmail(rs.getString("email"));
				memberList.add(member);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs!=null)
						rs.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(stm!=null)
						stm.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(conn!=null)
						conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return memberList;
	}
	//根据id来查询member
	public Member getMemberById(int id)
	{
		Member member = null;
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		conn = DBTools.getConn();
		String sql = "select * from member where id="+id+"";
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery(sql);
			if(rs.next())
			{
				member = new Member();
				member.setId(rs.getInt("id"));
				member.setUsername(rs.getString("username"));
				member.setPassword(rs.getString("password"));
				member.setRealname(rs.getString("realname"));
				member.setTel(rs.getString("tel"));
				member.setAddress(rs.getString("address"));
				member.setZip(rs.getString("zip"));
				member.setEmail(rs.getString("email"));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs!=null)
						rs.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(stm!=null)
						stm.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(conn!=null)
						conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return member;
	}
	//删除一个member
	public boolean delOneMember(Member member)
	{
		boolean isDel = false;
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		conn = DBTools.getConn();
		String sql = "delete member where id="+member.getId()+"";
        try {
			stm = conn.createStatement();
			int temp = stm.executeUpdate(sql);
			if(temp>0)
			{
				isDel = true;
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(rs!=null)
						rs.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(stm!=null)
						stm.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}

				try {
					if(conn!=null)
						conn.close();
				} catch (SQLException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
		}
		return isDel;
	}
	
}