userserviceimpl.java

网上购物系统的简易代码

package com.tarena.develop.service.impl;

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

import com.tarena.develop.common.JDBCUtil;
import com.tarena.develop.entity.User;

public class UserServiceImpl implements UserService {

	public User getUser(String username, String password) {
		Connection conn = null;
		PreparedStatement pstm = null;
		ResultSet rs = null;
		User user = null;
		String sql = "select id,username,passwd,addr,phone,email from t_user where username=? and passwd=?";
		conn = JDBCUtil.getConnection();
		try {
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, username);
			pstm.setString(2, password);
			rs = pstm.executeQuery();
			if(rs.next()){
				user = new User();
				user.setId(rs.getInt(1));
				user.setUsername(rs.getString(2));
				user.setPassword(rs.getString(3));
				user.setAddr(rs.getString(4));
				user.setPhone(rs.getString(5));
				user.setEmail(rs.getString(6));
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			JDBCUtil.relese(rs, pstm, conn);
		}
		
		return user;
	}

	public void add(User user) {
		Connection con = null;
		PreparedStatement ps = null;

		try {
			con =JDBCUtil.getConnection();
			
			String sql = "insert into t_user values(?,?,?,?,?,?)";
			System.out.println(sql);
			ps = con.prepareStatement(sql);
			int index = 1;
			int i=1;
			ps.setInt(index++, i++);
			ps.setString(index++, user.getUsername());
			ps.setString(index++, user.getPassword());
			ps.setString(index++, user.getAddr());
			ps.setString(index++, user.getPhone());
			ps.setString(index++, user.getEmail());
			
			ps.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
			throw new RuntimeException();
		} finally {
			JDBCUtil.relese(null, ps, con);
		}
	}


}