简单版开心农场实现（Flex+java）

package db; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.util.Date; import flexClass.UserBaseInfo; import flexClass.PackageInfo; public class DBControler { DBfactory df= new DBfactory(); DBpool dh = df.getInstance(); public ResultSet validateUser(String uId,String uPwd){ ResultSet rs=null; String sql="select count(*) from userInfo where userLoginId=? and userPwd=?"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, uId); ps.setString(2, uPwd); rs=ps.executeQuery(); dh.release(conn); }catch(Exception ex){ ex.printStackTrace(); } return rs; } public boolean AddUser(UserBaseInfo userBaseInfo){ //String sql="INSERT INTO userinfo VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)"; //检查该用户名是否已经存在 if(userNameValidate(userBaseInfo.userLoginId)) { String sql="INSERT INTO userinfo VALUES('"+userBaseInfo.userLoginId+"','"+userBaseInfo.userPwd+"','"+ userBaseInfo.userName+"','"+userBaseInfo.userSex +"','"+userBaseInfo.userBirthday +"',"+userBaseInfo.userState +","+userBaseInfo.userStatus +",'"+userBaseInfo.userPhoto +"','"+userBaseInfo.friendList +"',"+userBaseInfo.farmCoin +","+ userBaseInfo.usedCount +","+userBaseInfo.farmLuck +","+userBaseInfo.currentLevel +","+userBaseInfo.currentExperience +","+userBaseInfo.backgroundId+")"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.execute(sql); dh.release(conn); //初始化用户的土地信息 addFields(userBaseInfo.userLoginId); //初始化包裹信息 //种子 PackageInfo pack = new PackageInfo(); pack.userLoginId =userBaseInfo.userLoginId; pack.goodsNo = 1; pack.goodCount = 6; pack.goodsType =1; pack.BoughtDate =new java.sql.Date(new java.util.Date().getTime()); addPackageInfoInsert(pack); //化肥 PackageInfo packF = new PackageInfo(); packF.userLoginId =userBaseInfo.userLoginId; packF.goodsNo = 0; packF.goodCount = 3; packF.goodsType =2; packF.BoughtDate =new java.sql.Date(new java.util.Date().getTime()); addPackageInfoInsert(packF); return true; }catch(Exception ex){ ex.printStackTrace(); return false; } } else return false; } public ResultSet getUserById(String LoginId){ ResultSet rs=null; String sql="select * from userInfo where userLoginId=?"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, LoginId); rs=ps.executeQuery(); dh.release(conn); }catch(Exception ex){ ex.printStackTrace(); } return rs; } public ResultSet getFieldByLoginId(String LoginId){ ResultSet rs=null; String sql="select * from fieldInfo where userLoginId=? order by fieldNumber ASC"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, LoginId); rs=ps.executeQuery(); dh.release(conn); }catch(Exception ex){ ex.printStackTrace(); } return rs; } public ResultSet getDepotByLoginId(String LoginId){ ResultSet rs=null; String sql="select * from depotInfo where userLoginId=?"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, LoginId); rs=ps.executeQuery(); dh.release(conn); }catch(Exception ex){ ex.printStackTrace(); } return rs; } public ResultSet getPackageByLoginId(String LoginId){ ResultSet rs=null; String sql="select * from packageInfo where userLoginId=?"; try{ Connection conn = dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, LoginId); rs=ps.executeQuery(); dh.release(conn); }catch(Exception ex){ ex.printStackTrace(); } return rs; } //初始化用户土地 public void addFields(String userLoginId) { try{ Connection conn=dh.getConnection(); for(int i=0;i<6;i++) { String sql="insert into fieldinfo values(?,?,?,?,?,?,?,?,?,?,?)"; PreparedStatement ps=conn.prepareStatement(sql); ps.setInt(1, 0); ps.setString(2,userLoginId); ps.setInt(3, i+1); ps.setInt(4, 0); ps.setInt(5, 0); ps.setDate(6, new java.sql.Date(new java.util.Date().getTime())); ps.setInt(7, 0); ps.setInt(8, 0); ps.setInt(9, 0); ps.setInt(10, 0); ps.setInt(11, 0); ps.execute(); } dh.release(conn); } catch(Exception ex) { System.out.println("注册用户添加土地出错！"); ex.printStackTrace(); } } //初始化用户土地 public void addFieldByFieldNo(String userLoginId,int fieldNo) { try{ Connection conn=dh.getConnection(); String sql="insert into fieldinfo values(?,?,?,?,?,?,?,?,?,?,?)"; PreparedStatement ps=conn.prepareStatement(sql); ps.setInt(1, 0); ps.setString(2,userLoginId); ps.setInt(3, fieldNo); ps.setInt(4, 0); ps.setInt(5, 0); ps.setDate(6, new java.sql.Date(new java.util.Date().getTime())); ps.setInt(7, 0); ps.setInt(8, 0); ps.setInt(9, 0); ps.setInt(10, 0); ps.setInt(11, 0); ps.execute(); dh.release(conn); } catch(Exception ex) { System.out.println("用户开垦土地出错！"); ex.printStackTrace(); } } //验证该用户名是否已经存在 public boolean userNameValidate(String userLoginId) { String sql="select * from userinfo where userLoginId=?"; try{ Connection conn=dh.getConnection(); PreparedStatement ps=conn.prepareStatement(sql); ps.setString(1, userLoginId); ResultSet rs=ps.executeQuery(); dh.release(conn); if(rs.next()) return false; else return true; } catch(Exception e) { return false; } } public ResultSet hadBoughtGoods(PackageInfo pack) { try{ Connection conn=dh.getConnection(); String sqlValidate = "select count(*) from packageInfo where userLoginId=? and goodsType=? and goodsNo=?"; PreparedStatement ps=conn.prepareStatement(sqlValidate); ps.setString(1, pack.userLoginId); ps.setInt(2, pack.goodsType); ps.setInt(3, pack.goodsNo); ResultSet rs = ps.executeQuery(); dh.release(conn); return rs; }catch(Exception ex) { System.out.println("查询商品是否为已购买物品时出错"); ex.printStackTrace(); return null; } } public void addPackageInfoInsert(PackageInfo pack){ try{ Connection conn=dh.getConnection(); String sql="insert into packageInfo values(?,?,?,?,?,?)"; PreparedStatement ps=conn.prepareStatement(sql); ps.setInt(1, 0); ps.setInt(2,pack.goodsType); ps.setInt(3, pack.goodsNo); ps.setString(4, pack.userLoginId); ps.setInt(5, pack.goodCount); ps.setDate(6, new java.sql.Date(new java.util.Date().getTime())); ps.execute(); dh.release(conn); }catch(Exception ex) { System.out.println("购买商品添加包裹信息出错！"); ex.printStackTrace(); } } public void addPackageInfoupdate(PackageInfo pack){ try{ Connection conn=dh.getConnection(); String sql="update packageInfo set goodCount = goodCount + ? where userLoginId=? and goodsType=? and goodsNo=?"; PreparedStatement ps=conn.prepareStatement(sql); ps.setInt(1, pack.goodCount); ps.setString(2, pack.userLoginId); ps.setInt(3, pack.goodsType); ps.setInt(4, pack.goodsNo); ps.execute(); dh.release(conn); }catch(Exception ex) { System.out.println("购买商品添加包裹信息出错！"); ex.printStackTrace(); } } public void UpdateExperence(String u