memberdao.java

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

package com.dongfang.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

import com.dongfang.po.MemberPO;

public class MemberDAO {
	//根据姓名来查询会员
	public MemberPO getMember(String username)
	{
		MemberPO member = null;
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		conn = Tools.getConn();
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery("select * from member where username='"+username+"'");
			if(rs.next())
			{
				member = new MemberPO();
				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;
	}
	//自动获得id
	public int getNextId()
	{
		int myId = 0;
		Connection conn = null;
		Statement stm = null;
		ResultSet rs = null;
		conn = Tools.getConn();
		try {
			stm = conn.createStatement();
			rs = stm.executeQuery("select max(id) id from member");
		    if(rs.next())
		    {
		    	myId = rs.getInt("id");
		    }
		} 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 ++myId;
	}
	//保存一个会员信息
	public boolean save(Object object)
	{
		boolean isSave = false;
		Connection conn = null;
		PreparedStatement pstmt = null;
		String sql = "insert into member values(?,?,?,?,?,?,?,?)";
		
		if("com.dongfang.po.MemberPO".equals(object.getClass().getName()))
		{
			MemberPO member = (MemberPO)object;
			conn = Tools.getConn();
			try {
				pstmt = conn.prepareStatement(sql);
				System.out.println(member.getId());
				System.out.println(member.getUsername());
				System.out.println(member.getPassword());
				System.out.println(member.getAddress());
				System.out.println(member.getRealname());
				System.out.println(member.getTel());
				System.out.println(member.getZip());
				System.out.println(member.getEmail());
				pstmt.setInt(1,member.getId());
				pstmt.setString(2, member.getUsername());
				pstmt.setString(3, member.getPassword());
				
				pstmt.setString(4, member.getRealname());
				pstmt.setString(5, member.getTel());
				pstmt.setString(6, member.getAddress());
				pstmt.setString(7, member.getZip());
				pstmt.setString(8, member.getEmail());
				int temp = pstmt.executeUpdate();
				if(temp > 0)
				{
					isSave = true;
				}
				
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			finally
			{
					try {
						if(pstmt!=null)
							pstmt.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 isSave;
	}
	public boolean updateMember(MemberPO member)
	{
		boolean isUpdate = false;
		Connection conn = null;
		PreparedStatement pstmt = null;
		conn = Tools.getConn();
		String sql = "update member set username=?,password=?,realname=?,tel=?,address=?,zip=?,email=? where id=?";
		try {
			pstmt = conn.prepareStatement(sql);
			pstmt.setString(1, member.getUsername());
			pstmt.setString(2, member.getPassword());
			pstmt.setString(3, member.getRealname());
			pstmt.setString(4, member.getTel());
			pstmt.setString(5, member.getAddress());
			pstmt.setString(6, member.getZip());
			pstmt.setString(7, member.getEmail());
			int temp = pstmt.executeUpdate();
			if(temp>0)
			{
				isUpdate = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally
		{
				try {
					if(pstmt!=null)
						pstmt.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 isUpdate;
	}
}