基于JSF的增删改查

/**
 *@（#）adminDAO.java 2012-5-9 
 * All right reserved.
 */
package com.zr.JSF_crud.model.DAO;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

import com.zr.JSF_crud.Servlet.AdminBean;
import com.zr.JSF_crud.model.DTO.adminDTO;
import com.zr.JSF_crud.util.C3p0_DataSource;



/**
 *copyRght Xiao_荣
 */
public class adminDAOMySqlImpl {

	public int login（adminDTO admin） {
		Connection con = null;
		Statement stmt = null;
		ResultSet rs = null;
		int i = 0;
		try {
			// //类加载，反射机制
			// Class.forName（driver）;
			// con = DriverManager.getConnection（url username password）;
			// 数据库连接池
			con = C3p0_DataSource.getConnection（）;
			String sql = “select * from admin where adminname=‘“
					+ admin.getAdminname（） + “‘ and pass=‘“ + admin.getPass（）
					+ “‘“;
			stmt = con.createStatement（）;
			rs = stmt.executeQuery（sql）;
			while （rs.next（）） {
				i = 1;
			}
		} catch （Exception sqlex1） {
			sqlex1.printStackTrace（）;
		} finally {
			if （con != null） {
				try {
					con.close（）;
				} catch （SQLException sqlex2） {
					sqlex2.printStackTrace（）;
				}
			}
		}
		return i;
	}

	// CreateByDTO------------------------------------------------
	public void createAdmin（adminDTO admin） {
		Connection conn = null;
		Statement stmt = null;
		try {
			// 数据库连接池
			conn = C3p0_DataSource.getConnection（）;
			String sql = “insert into admin （adminnamepass） values （“ + “‘“
					+ admin.getAdminname（） + “‘“ + ““ + “‘“ + admin.getPass（）
					+ “‘“ + “）“;
			stmt = conn.createStatement（）;
			stmt.execute（sql）;
		} catch （Exception sqlex1） {
			sqlex1.printStackTrace（）;
		} finally {
			if （conn != null） {
				try {
					conn.close（）;
				} catch （SQLException sqlex2） {
					sqlex2.printStackTrace（）;
				}
			}
		}
	}

	// RemoveByPrimaryKey------------------------------------------------
	public void removeByPrimaryKey（int id） {
		Connection con = null;
		Statement stmt = null;
		try {
			// 数据库连接池
			con = C3p0_DataSource.getConnection（）;
			String sql = “delete from admin where id =“ + id;
			stmt = con.createStatement（）;
			stmt.execute（sql）;

		} catch （Exception sqlex1） {
			sqlex1.printStackTrace（）;
		} finally {
			if （con != null） {
				try {
					con.close（）;
				} catch （SQLException sqlex2） {
					sqlex2.printStackTrace（）;
				}
			}
		}
	}

	// UpdateByDTO------------------------------------------------
	public void updateAdmin（adminDTO adminDTO） {
		Connection conn = null;
		Statement stmt = null;
		try {
			System.out.println（“---------000----------“）;
			// 数据库连接池
			conn = C3p0_DataSource.getConnection（）;
			String sql = “update admin set adminname=‘“ + adminDTO.getAdminname（）
					+ “‘pass=‘“ + adminDTO.getPass（） + “‘ where id=“
					+ adminDTO.getId（）;
			System.out.println（“--------