userdao.java

用mysql

package com.wenhua.ser.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.wenhua.ser.base.Dbcon;
import com.wenhua.ser.vo.UserVo;

public class UserDao {

	private Dbcon dbcon;

	private Connection con;

	private PreparedStatement ps;

	private String sql;
	
	private String sql1;

	private ResultSet rs;

	public boolean checkUser(String userName, String password) {
		boolean flag = false;
		sql = "select count(*) as myCount from user where username= ? and password = ?";

		// 第一步，获得数据库连接对象
		dbcon = new Dbcon();
		con = dbcon.getCon();

		// 第二步，获得操作数据库SQL语句的 对象
		try {

			ps = con.prepareStatement(sql);

			ps.setString(1, userName);
			ps.setString(2, password);

			// 第三步，执行SQL语句
			rs = ps.executeQuery();

			//
			while (rs.next()) {
				int num = rs.getInt("myCount");
				if (num == 1) {
					flag = true;
				}
			}

		} catch (SQLException e) {
			e.printStackTrace();
		} finally {
			dbcon.closeCon(con);
			dbcon = null;
		}
		return flag;
	}

	public List findAll() {
		List list = new ArrayList();

		sql = "select u.username, m.content,m.time  from message m,user u where u.userName = m.userName";
		
		UserVo userVo = null;
		// 第一步，获得数据库连接对象
		dbcon = new Dbcon();
		con = dbcon.getCon();
		
		

		// 第二步，获得操作数据库SQL语句的 对象

		try {
			ps = con.prepareStatement(sql);

			// 第三步，执行SQL语句
			rs = ps.executeQuery();
			
			while(rs.next())
			{
				userVo = new UserVo();
				userVo.setUserName(rs.getString("userName"));
				userVo.setContent(rs.getString("content"));
				userVo.setTime(rs.getString("time"));
				
				list.add(userVo);
			}

		} catch (SQLException e) {

			e.printStackTrace();
		}finally{
			dbcon.closeCon(con);
			dbcon = null;
		}

		return list;
	}
	
	
	public void insert(String userName, String content,String time) {
		
		
		
		// 第一步，获得数据库连接对象
		dbcon = new Dbcon();
		sql = "insert into message(userName,content,time) values(?,?,?)";
		con = dbcon.getCon();
		
		
		
		

		// 第二步，获得操作数据库SQL语句的 对象

		try {
			
			ps = con.prepareStatement(sql);
			ps.setString(1,userName);
			ps.setString(2,content);
			ps.setString(3,time);
			
			// 第三步，执行SQL语句
			 ps.executeUpdate();
		} catch (SQLException e) {

			e.printStackTrace();
		}finally{
			dbcon.closeCon(con);
			dbcon = null;
		}
	}

public void insert2(String userName, String password) {
		
		
		
		// 第一步，获得数据库连接对象
		dbcon = new Dbcon();
		sql = "insert  into user values(?,?)";
		con = dbcon.getCon();
		
		
		
		

		// 第二步，获得操作数据库SQL语句的 对象

		try {
			
			ps = con.prepareStatement(sql);
			ps.setString(1,userName);
			ps.setString(2,password);
			
			
			
			// 第三步，执行SQL语句
			 ps.executeUpdate();
		} catch (SQLException e) {

			e.printStackTrace();
		}finally{
			dbcon.closeCon(con);
			dbcon = null;
		}
	}
	public static void main(String[] args) {
		UserVo userVo = new UserVo();
		userVo.setUserName("cccc");
		userVo.setPassword("123");
		
		UserDao userDao = new UserDao();
		userDao.insert2("e","123");
	}
//	public static void main(String[] args) {
//		List  list = new ArrayList();
//		
//		UserVo vo = null;
//		UserDao dao = new UserDao();
//		
//		list = dao.findAll();
//		
//		for(int i = 0; i < list.size(); i++)
//		{
//			vo = (UserVo) list.get(i);
//			
//			System.out.println(vo.getUserName() + " " + vo.getContent());
//		}
//	}
//	
}