memberdaoimpl.java

JSP的网上商城的代码。只是小部分。希望大家能够多看看。一起学习。

package com.eshop.daoImpl;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Vector;

import com.eshop.database.dbconn;
import com.eshop.dao.MemberDao;
import com.eshop.dto.Member;
/*
 * Vector 元素为goods对象
 * */
public class MemberDaoImpl implements MemberDao {
	
	public int updateOrder(Member m) throws SQLException{
		String sql = "update member set trueName = '"+m.getTrueName()+"',address ='"+m.getAddress()+
		"',postcode ='"+m.getPostcode()+"',tel='"+m.getTel()+"',email ='"+m.getEmail()
		+"' where userName ='"+m.getUserName()+"'";
        dbconn conn = new dbconn();
        int flag = 0;
        flag = conn.excuteUpdate(sql);
        return flag;
		
	}
	
	public String selectPasswd(String name) throws SQLException{
		String passwd = "";
		dbconn conn = new dbconn();
		String sql = "select passwd from member where userName='"+name+"'";
		ResultSet rs = null;
		rs = conn.executeQuery(sql);
		while(rs.next())
		{
			passwd = rs.getString(1);
		}
		return passwd;
	}
	
	public Vector selectAll() throws SQLException{
		Vector list = new Vector();
		dbconn conn = new dbconn();
		String sql = "select * from member ";
		ResultSet rs = null;
		rs = conn.executeQuery(sql);
		while(rs.next())
		{
			Member one = new Member();
			one.setAddress(rs.getString("address"));
			one.setEmail(rs.getString("email"));
			one.setFreeze(rs.getString("freeze"));
			one.setMoney(rs.getDouble("money"));
			one.setPasswd(rs.getString("passwd"));
			one.setPostcode(rs.getString("postcode"));
			one.setTel(rs.getString("tel"));
			one.setTrueName(rs.getString("truename"));
			one.setUserName(rs.getString("username"));
			list.add(one);
		}
		return list;
	}

    //按用户名查询
	public Member FindbyUserName(String userName) throws SQLException{
		Member one = new Member();
		dbconn conn = new dbconn();
		String sql = "select * from member where userName ='"+userName+"'";
		ResultSet rs = null;
		rs = conn.executeQuery(sql);
		while(rs.next())
		{
			one.setAddress(rs.getString("address"));
			one.setEmail(rs.getString("email"));
			one.setFreeze(rs.getString("freeze"));

			one.setMoney(rs.getDouble("money"));
			one.setPasswd(rs.getString("passwd"));
			one.setPostcode(rs.getString("postcode"));
			one.setTel(rs.getString("tel"));
			one.setTrueName(rs.getString("truename"));
			one.setUserName(rs.getString("username"));
		}
		return one;
	}

	public int delete(String username) throws SQLException {
		String sql = "delete from member where userName ='"+username+"'";
		dbconn conn = new dbconn();
        int flag = 0;
		flag = conn.excuteUpdate(sql);
		return flag;
	}

	public int insert(Member m) throws SQLException {
	String sql = 
		    "insert into member (userName,trueName,passwd,address,postcode,tel,email)" 
			+" values ('"+m.getUserName()+"','"+m.getTrueName()+"','"+m.getPasswd()+"','"+m.getAddress()
		    +"','"+m.getPostcode()+"','"+m.getTel()+"','"+m.getEmail()+"')";
		dbconn conn = new dbconn();
        int flag = 0;
		flag = conn.excuteUpdate(sql);
		return flag;
	}

	public int update(Member m) throws SQLException {
		String sql = "update member set userName = '"+m.getUserName()+"', trueName = '"+m.getTrueName()+
		"', passwd = '"+m.getPasswd()+"',address ='"+m.getAddress()+"', postcode ='"+
		m.getPostcode()+"',tel='"+m.getTel()+"',email ='"+m.getEmail()+"' where userName='"+m.getUserName()+"'";
        dbconn conn = new dbconn();
        int flag = 0;
        flag = conn.excuteUpdate(sql);
        return flag;
	}
	public int updateMoney(String username,double money) throws SQLException{
		String sql = "update member set money =money+"+money+" where userName ='"+username+"'";
		dbconn conn = new dbconn();
        int flag = 0;
        flag = conn.excuteUpdate(sql);
        return flag;
	}

}