userdao.java

来自「图书商城系统」· Java 代码 · 共 128 行

package com.tang.admin.foruse;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;

public class UserDAO {
	Connection conn = null;

	PreparedStatement pstm = null;

	ResultSet rs = null;

	public void open() {
		try {
			Class.forName("com.mysql.jdbc.Driver");
			conn = DriverManager
					.getConnection("jdbc:mysql://localhost/mydata?user=root&password=124853047");
		} catch (ClassNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public ArrayList select(String sqlurl)
	{
		ArrayList al = new ArrayList();
		try {
			pstm = conn.prepareStatement(sqlurl);
			rs = pstm.executeQuery();
			while(rs.next())
			{
				UserBean userbean = new UserBean();
				userbean.setId(rs.getInt(1));
				userbean.setUsername(rs.getString(2));
				userbean.setPassword(rs.getString(3));
				userbean.setMoney(rs.getDouble(4));
				userbean.setEmail(rs.getString(5));
				userbean.setAddress(rs.getString(6));
				userbean.setZipcode(rs.getLong(7));
				userbean.setPhonenum(rs.getLong(8));
				al.add(userbean);
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally
		{
			this.close();
		}
		return al;
	}

	public boolean delete(String sqlurl) {
		boolean b = false;
		try {
			pstm = conn.prepareStatement(sqlurl);
			int i = pstm.executeUpdate();
			if (i != 0) {
				b = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			this.close();
		}
		return b;
	}

	public boolean insert(String sqlurl) {
		boolean b = false;
		try {
			pstm = conn.prepareStatement(sqlurl);
			int i = pstm.executeUpdate();
			if (i != 0) {
				b = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			this.close();
		}
		return b;
	}

	public boolean jdbcUpdate(String sqlurl) {
		boolean b = false;
		try {
			pstm = conn.prepareStatement(sqlurl);
			int i = pstm.executeUpdate();
			if (i != 0) {
				b = true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			this.close();
		}
		return b;
	}

	public void close() {
		try {
			if (rs != null) {
				rs.close();
			}
			if (pstm != null) {
				pstm.close();
			}
			if (conn != null) {
				conn.close();
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}