userdaoimpl.java

可以把客户端的内容存入数据库中

package com.dao;


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


import java.util.ArrayList;
import java.util.List;

import com.conn.DatabaseConnection;

import com.model.User;

public class UserDAOImpl implements UserDAO 
{

	public List insertUsers(User user) throws Exception 
	{
		// TODO Auto-generated method stub
			List list=new ArrayList();
			Connection conn;
			try {
					conn = DatabaseConnection.getConnection();
					PreparedStatement st=null;
					st=conn.prepareStatement("insert into userinfo"+"(email,user_name,log_name,password,phone,fax)"+"  values(?,?,?,?,?,?)");
					st.setString(1,user.getEmail());
					st.setString(2,user.getUserName());
					st.setString(3,user.getLogName());
					st.setString(4,user.getPassword());
					st.setString(5, user.getPhone());
					st.setString(6, user.getFax());
					st.executeUpdate();
				} catch (ClassNotFoundException e1)
				{
				// TODO Auto-generated catch block
				e1.printStackTrace();
				}
		
	
		return list;
	}
	public List getUsers() throws SQLException
	{
		
		List list=new ArrayList();
		Connection conn;
		try {
				conn = DatabaseConnection.getConnection();
				Statement st=conn.createStatement();
				String sql="select * from userinfo";
				ResultSet rs=st.executeQuery(sql);
				while(rs.next())
				{
					User user=new User();
					user.setEmail(rs.getString(1));
					user.setUserName(rs.getString(2));
					user.setLogName(rs.getString(3));
					user.setPassword(rs.getString(4));
					user.setPhone(rs.getString(5));
					user.setFax(rs.getString(6));
					list.add(user);
					user=null;		
				}
		}catch (ClassNotFoundException e1)
		{
							// TODO Auto-generated catch block
					e1.printStackTrace();
		}
		return list;
	}
		
	}