我可以給妳看看我做的。。呵呵，不要見笑。我也是初學者！
------BaseDao---------
package dao;
import java.sql.*;
public class BaseDao
{
private static final String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; //
private static final String CONNSTR = "jdbc:microsoft:sqlserver://localhost:1433;DataBaseName=PIMS"; //
private static final String LOGINID = "sa"; //
private static final String LOGINPWD = "sa"; //
Connection con=null;
PreparedStatement pStatement=null;
ResultSet resultset=null;
/**
* 得到連接對象
* @return
*/
private Connection getCon()
{
try
{
Class.forName(DRIVER); ////////////////
}
catch(ClassNotFoundException e)
{
System.out.println("加載驅動類出錯");
System.out.println(e.getMessage());
}
try
{
con=DriverManager.getConnection(CONNSTR, LOGINID, LOGINPWD);
}
catch(SQLException e)
{
System.out.println("連接數據庫出錯");
System.out.println(e.getMessage());
}
return con;
}
/**
* 獲得執行SQL語句的PreparedStatement對象
* @param sql SQL語句
* @param param 參數數組
* @return
*/
private PreparedStatement getPreparedStatement(String sql,String [] param)
{
try
{
pStatement=getCon().prepareStatement(sql);
if(param!=null&¶m.length>0)
{
for(int i=0;i<param.length;i++)
{
pStatement.setString(i+1, param[i]);
}
}
}
catch(SQLException e)
{
System.out.println("得到PreparedStatement出錯");
System.out.println(e.getMessage());
}
return pStatement;
}
/**
* 執行所有的查詢語句
* @param sql
* @param param
* @return
*/
public ResultSet excuteQuery(String sql,String [] param)
{
try
{
resultset=getPreparedStatement(sql,param).executeQuery();
}
catch(SQLException e)
{
System.out.println("執行查詢出錯");
System.out.println(e.getMessage());
}
return resultset;
}
/**
* 執行所有非查詢（增刪改的操作）
* @param sql
* @param param
* @return 返回受影響的行數
*/
public int executeUpdate(String sql,String [] param)
{
try
{
return getPreparedStatement(sql,param).executeUpdate();
}
catch(SQLException e)
{
System.out.println("執行非查詢出錯");
System.out.println(e.getMessage());
}
return 0;
}
/**
* 釋放資源
*/
public void colseAll()
{
try
{
if(resultset!=null)
{
resultset=null;
}
if(pStatement!=null)
{
pStatement=null;
}
if(con!=null&&!con.isClosed())
{
con.close();
con=null;
}
}
catch(SQLException e)
{
System.out.println("釋放資源出錯");
System.out.println(e.getMessage());
}
}
}
------------------------------------------------------------------------------------------------------
package dao;
import java.util.ArrayList;
import entity.Users;
public class UsersDao extends BaseDao
{
private static final String SQL_ADD_USERS = "INSERT Users VAULES(?,?,?,?,?,?)"; //
private static final String SQL_DEL_USERS = "DELETE Users WHERE User_ID = ?"; //
private static final String SQL_UPD_USERS = "UPDATE Users SET User_Name=?,User_Sex=? WHERE User_ID=?"; //
private static final String SQL_SEL_USERS_ALL = "SELECT * FROM Users"; //
private static final String SQL_SEL_USERS_BY_ID = "SELECT * FROM Users WHERE User_ID=?"; //
private static final String SQL_SEL_USERS_BY_LOGIN= "SELECT * FROM Users WHERE User_Name=? AND User_Pwd=?"; //
/**
* 增加用戶
* @param user
* @return
*/
public int addUsers(Users user)
{
//定義參數數組
String [] param=
{
user.getName(),
user.getPwd(),
user.getSex(),
user.getScore(),
user.getEmail(),
user.getUserTypeId()
};
try
{
return super.executeUpdate(SQL_ADD_USERS, param);
}
catch(Exception e)
{
System.out.println("增加用戶出錯");
System.out.println(e.getMessage());
}
finally
{
super.colseAll();
}
return 0;
}
/**
* 刪除用戶
* @param UID
* @return
*/
public int delUsers(String UID)
{
String [] param={UID};
try
{
return super.executeUpdate(SQL_DEL_USERS, param);
}
catch(Exception e)
{
System.out.println("刪除用戶出錯");
System.out.println(e.getMessage());
}
finally
{
super.colseAll();
}
return 0;
}
/**
* 修改用戶信息
* @param user
* @return
*/
public int updUsers(Users user)
{
String [] param=
{
user.getId(),
user.getPwd(),
user.getName(),
user.getScore(),
user.getSex(),
user.getEmail(),
user.getUserTypeId()
};
try
{
return super.executeUpdate(SQL_UPD_USERS, param);
}
catch(Exception e)
{
System.out.println("修改用戶出錯");
System.out.println(e.getMessage());
}
finally
{
super.colseAll();
}
return 0;
}
/**
* 查詢所有用戶
* @return
*/
public ArrayList<Users> selUsersAll()
{
return selComm(SQL_SEL_USERS_ALL,null);
}
/**
* 根據編號查詢單個用戶
* @param UID
* @return
*/
public Users selUsersByID(String UID)
{
String [] param={UID};
ArrayList<Users> list=selComm(SQL_SEL_USERS_BY_ID,param);
if(list!=null&&list.size()>0)
return list.get(0);
return null;
}
/**
* 根據編號查詢單個用戶
* @param UID
* @return
*/
public Users selUsersByID(String uName,String uPwd)
{
String [] param={uName,uPwd};
ArrayList<Users> list=selComm(SQL_SEL_USERS_BY_LOGIN,param);
if(list!=null&&list.size()>0)
return list.get(0);
return null;
}
/**
* 查詢用戶的公***方法
* @param sql
* @param param
* @return
*/
private ArrayList<Users> selComm(String sql ,String[]param)
{
ArrayList<Users> list=new ArrayList<Users>();
try
{
resultset=super.excuteQuery(sql, param);
while(resultset.next())
{
Users user=new Users();
user.setId(resultset.getString("User_ID"));
user.setName(resultset.getString("User_Name"));
user.setPwd(resultset.getString("User_Pwd"));
user.setScore(resultset.getString("User_Score"));
user.setSex(resultset.getString("User_Sex"));
user.setEmail(resultset.getString("User_Email"));
user.setUserTypeId(resultset.getString("UserType_ID"));
list.add(user);
}
}
catch(Exception e)
{
System.out.println("查詢用戶出錯");
System.out.println(e.getMessage());
}
finally
{
super.colseAll();
}
return list;
}
}
希望對樓主有所幫助····