MyQQ 项目 (未完…)

模拟QQ软件,实现用户注册、登录、修改个人资料、修改密码、添加删除好友、查询好友、显示头像、聊天等功能。

dao层 操作数据库

1 package com.etc.dao; java.sql.Connection; DBHelper { 6 7 Connection conn; 8 PreparedStatement ps; 9 ResultSet rs; 10 Statement st; n; getN() { 14return n; 15 }setN(int n) { 18this.n = n; 19 } DBHelper() { 22/*try { 23 Class.forName(“com.microsoft.sqlserver.jdbc.SQLServerDriver”); 24 } catch (ClassNotFoundException e) { 25 e.printStackTrace(); }* 插入用户信息 31 * regFrame SQLExceptioninsertUsers(RegisterFrame regFrame) throws SQLException { 36try { 37String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”; 38conn = DriverManager.getConnection(url, “sa”, “251860”); 39String sql = ” insert into Users values (?,?,?,?,?,?,?,?,?,?)”; 40ps = conn.prepareStatement(sql); 41 42ps.setString(1, regFrame.getLoginPwd()); 43ps.setInt(2, regFrame.getFriendshipPolicyId()); 44ps.setString(3, regFrame.getNickName()); 45ps.setInt(4, regFrame.getFaceId()); 46ps.setString(5, regFrame.getSex()); 47ps.setInt(6, regFrame.getAge()); 48ps.setString(7, regFrame.getName()); 49ps.setInt(8, regFrame.getStarId()); 50ps.setInt(9, regFrame.getBloodTypeId()); 51ps.setBoolean(10, regFrame.isRemberPwd()); 52 ps.execute(); 53 54} catch (SQLException e) { 55 e.printStackTrace(); 56} finally { 57 ps.close(); 58 conn.close(); 59 } 60 }* 返回星座信息 64 * ArrayList<String> getSatrs() { 68ArrayList<String> stars = new ArrayList<String>(); { 71String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”; 72conn = DriverManager.getConnection(url, “sa”, “251860”); 73st = conn.createStatement(); 74String sql = “select star from star”; 75rs = st.executeQuery(sql); 76while (rs.next()) { 77stars.add(rs.getString(“star”)); 78 } 79 rs.close(); 80 st.close(); 81 conn.close(); 82} catch (SQLException e) { 83 e.printStackTrace(); 84 } 85return stars; 86 }* 返回血型信息 90 * ArrayList<String> getBloodTypes() { 94ArrayList<String> bloodTypes = new ArrayList<String>(); { 97String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”; 98conn = DriverManager.getConnection(url, “sa”, “251860”); 99st = conn.createStatement();100String sql = “select BloodType from BloodType”;101rs = st.executeQuery(sql);102while (rs.next()) {103bloodTypes.add(rs.getString(“BloodType”));104 }105 rs.close();106 st.close();107 conn.close();108} catch (SQLException e) {109 e.printStackTrace();110 }111return bloodTypes;112 }* 返回用户QQ号116 * SQLExceptiongetUserId() throws SQLException {121int id = 0;122String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;123try {124conn = DriverManager.getConnection(url, “sa”, “251860”);125String sql = “select ident_current(‘Users’)”;126st = conn.createStatement();127rs = st.executeQuery(sql);128if (rs.next()) {129id = rs.getInt(1);130 }131} catch (SQLException e) {132 e.printStackTrace();133} finally {134 rs.close();135 st.close();136 conn.close();137 }138return id;139 }* 取得用户QQ密码143 * qqIdString getPwdQQ(String qqId) throws SQLException{148String pwdQQ = “”;149String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;conn = DriverManager.getConnection(url, “sa”, “251860”);152st = conn.createStatement();153String sql = “select LoginPwd from Users where”;154rs = st.executeQuery(sql);155if (rs.next()) {156pwdQQ = rs.getString(1);157 }158/*} catch (SQLException e) {159 e.printStackTrace();rs.close();162 st.close();163 conn.close();164return pwdQQ;165 }* 返回标签头部信息169 * qqIdArrayList<String> getHead(String qqId) {174 175ArrayList<String> head = new ArrayList<String>();176String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;177try {178conn = DriverManager.getConnection(url, “sa”, “251860”);179String sql = “select FaceId,NickName from Users where Id = ?”;180ps = conn.prepareStatement(sql);181ps.setString(1, qqId);182rs = ps.executeQuery();183if (rs.next()) {184head.add(rs.getInt(“FaceId”) + “”);185head.add(rs.getString(“NickName”));186 }187 rs.close();188 ps.close();189 conn.close();190} catch (SQLException e) {191 e.printStackTrace();192 }193return head;194 }* 返回用户信息198 * IdArrayList<String> showUserById(String Id) {203ArrayList<String> users = new ArrayList<String>(); {206String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;207conn = DriverManager.getConnection(url, “sa”, “251860”);208String sql = “select * from Users where Id = ?”;209ps = conn.prepareStatement(sql);210ps.setString(1, Id);211rs = ps.executeQuery();212if (rs.next()) {213users.add(rs.getString(“LoginPwd”));214users.add(rs.getInt(“FriendshipPolicyId”) + “”);215users.add(rs.getString(“NickName”));216users.add(rs.getInt(“FaceId”) + “”);217users.add(rs.getString(“Sex”));218users.add(rs.getInt(“Age”) + “”);219users.add(rs.getString(“Name”));220users.add(rs.getInt(“StarId”) + “”);221users.add(rs.getInt(“BloodTypeId”) + “”);222 }223 rs.close();224 ps.close();225 conn.close();226} catch (SQLException e) {227 e.printStackTrace();228 }229return users;230 }* 更改用户个人资料234 * euif qqId SQLException updateEditUserInfo(EditUserInfoFrame euif, String qqId)240throws SQLException { {243String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;244conn = DriverManager.getConnection(url, “sa”, “251860”);245String sql = “update Users set NickName = ?, Sex = ?, Age = ?, Name = ?, StarId = ?,BloodTypeId = ? where Id =”246+ qqId;247 248ps = conn.prepareStatement(sql);249ps.setString(1, euif.getNickName());250ps.setString(2, euif.getSex());251ps.setInt(3, euif.getAge());252ps.setString(4, euif.getName());253ps.setInt(5, euif.getStarId());254ps.setInt(6, euif.getBloodTypeId());255 256 ps.execute();257} catch (SQLException e) {258 e.printStackTrace();259} finally {260 ps.close();261 conn.close();262 }263 }* 更改用户密码267 * euif qqId SQLException updateEditUserPwd(EditUserInfoFrame euif, String qqId)273throws SQLException { {276String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;277conn = DriverManager.getConnection(url, “sa”, “251860”);278String sql = “update Users set LoginPwd = ? , FriendshipPolicyId = ? where Id = ?”;279ps = conn.prepareStatement(sql);280 281ps.setString(1, euif.getLoginPwd());282ps.setInt(2, euif.getFriendshipPolicyId());283ps.setString(3, qqId);284 ps.execute();285 286} catch (SQLException e) {287 e.printStackTrace();288} finally {289 ps.close();290 conn.close();291 }292 }* 判断是否记住密码 remberId SQLExceptionremberPwd(String remberId) throws SQLException {301boolean statePwd = false;302try {303String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;304conn = DriverManager.getConnection(url, “sa”, “251860”);305String sql = “select RemberPwd from Users where Id= ?”;306ps = conn.prepareStatement(sql);307ps.setString(1, remberId);308rs = ps.executeQuery();309if (rs.next()){310statePwd = rs.getBoolean(“RemberPwd”);311 }312} catch (SQLException e) {313 e.printStackTrace();314}finally315 {316 rs.close();317 ps.close();318 conn.close();319 }320return statePwd;321 }* 记住密码325 * remberId text SQLExceptionupdateStateTo1(String remberId) throws SQLException {331String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;332try {333conn = DriverManager.getConnection(url, “sa”, “251860”);334String sql = “update Users set RemberPwd = 1 where Id = ?”;335ps = conn.prepareStatement(sql);336ps.setString(1, remberId);337 ps.execute();338} catch (SQLException e) {339 e.printStackTrace();340} finally {341 ps.close();342 conn.close();343 }344 }* 取消密码348 * remberId updateStateTo0(String remberId) {352String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;353try {354conn = DriverManager.getConnection(url, “sa”, “251860”);355String sql = “update Users set RemberPwd = 0 where Id = ? “;356ps = conn.prepareStatement(sql);357ps.setString(1, remberId);358 ps.execute();359 360 ps.close();361 conn.close();362} catch (SQLException e) {363 e.printStackTrace();364 }365 }* 插入密保 pwdSet protectInsert(PwdSet pwdSet) {372String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;373try {374conn = DriverManager.getConnection(url, “sa”, “251860”);375String sql = “insert into PwdproSet values (?,?,?,?,?) “;376ps = conn.prepareStatement(sql);377ps.setString(1, pwdSet.getQues());378ps.setString(2, pwdSet.getAnswer());379ps.setString(3, pwdSet.getQues_1());380ps.setString(4, pwdSet.getAnswer_1());381ps.setString(5, pwdSet.getQqId());382 383 ps.execute();384 385 ps.close();386 conn.close();387} catch (SQLException e) {388 e.printStackTrace();389 }390 }* 取得密保 qqIdArrayList<String> protectGet(String qqId) {397ArrayList<String> arrs = new ArrayList<String>();398String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;399try {400conn = DriverManager.getConnection(url, “sa”, “251860”);401String sql = “select ques,answer,ques_1,answer_1 from PwdproSet where qqId = ?”;402ps = conn.prepareStatement(sql);403ps.setString(1, qqId);404rs = ps.executeQuery();405if (rs.next()) {406arrs.add(rs.getString(“ques”));407arrs.add(rs.getString(“answer”));408arrs.add(rs.getString(“ques_1”));409arrs.add(rs.getString(“answer_1”));410} else {411arrs.add(“无密保”);412arrs.add(“无密保”);413arrs.add(“无密保”);414arrs.add(“无密保”);415 }416 rs.close();417 ps.close();418 conn.close();419} catch (SQLException e) {420 e.printStackTrace();421 }422return arrs;423 }* 查找所有好友 Object[][] findAllFriends() {430int i = 0; 431Object[][] ob = new Object[100][4];432String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;433try {434conn = DriverManager.getConnection(url, “sa”, “251860”);435st = conn.createStatement();436rs = st.executeQuery(“select Id,NickName,Age,Sex from Users”);437while (rs.next()){438ob[i][0] = rs.getInt(“Id”)+””;439ob[i][1] = rs.getString(“NickName”);440ob[i][2] = rs.getInt(“Age”)+””;441ob[i][3] = rs.getString(“Sex”);442i++;443 }444DBHelper dbHelper = new DBHelper();445 dbHelper.setN(i);446 rs.close();447 st.close();448 conn.close();449} catch (SQLException e) {450 e.printStackTrace();451 }452return ob;453 }* 精确查找 qqId nickName Object[][] findPres(String qqId, String nickName) {i = 0; 464Object[][] ob = new Object[100][4];465String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;466try {467conn = DriverManager.getConnection(url, “sa”, “251860”);468String sql = “select Id,NickName,Age,Sex from Users where Id = ? or NickName = ?”;469ps = conn.prepareStatement(sql);470ps.setString(1, qqId);471ps.setString(2, nickName);472rs = ps.executeQuery();473while (rs.next()){474ob[i][0] = rs.getInt(“Id”)+””;475ob[i][1] = rs.getString(“NickName”);476ob[i][2] = rs.getInt(“Age”)+””;477ob[i][3] = rs.getString(“Sex”);478i++;479 }480DBHelper dbHelper = new DBHelper();481 dbHelper.setN(i);482 rs.close();483 ps.close();484 conn.close();485} catch (SQLException e) {486 e.printStackTrace();487 }488return ob;489 }* 高级查找 age sex Object[][] findHigh(String age, String sex) {498int i = 0; 499Object[][] ob = new Object[100][4];500String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;501try {502conn = DriverManager.getConnection(url, “sa”, “251860”);503String sql = “select Id,NickName,Age,Sex from Users where Age = ? or Sex = ?”;504ps = conn.prepareStatement(sql);505ps.setString(1, age);506ps.setString(2, sex);507rs = ps.executeQuery(); (rs.next()){510ob[i][0] = rs.getInt(“Id”)+””;511ob[i][1] = rs.getString(“NickName”);512ob[i][2] = rs.getInt(“Age”)+””;513ob[i][3] = rs.getString(“Sex”);514i++;515 }516DBHelper dbHelper = new DBHelper();517 dbHelper.setN(i);518 rs.close();519 ps.close();520 conn.close();521} catch (SQLException e) {522 e.printStackTrace();523 }524return ob;525 }* 查找全部好友529 * ArrayList<String> qqFriends(){533ArrayList<String> qqFris = new ArrayList<String>();534String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”; {537conn = DriverManager.getConnection(url, “sa”, “251860”);538st = conn.createStatement();539rs = st.executeQuery(“select FriendId from Friends”);540while (rs.next()){541qqFris.add(rs.getInt(“FriendId”)+””);542 }543544} catch (SQLException e) {545 e.printStackTrace();546 }547return qqFris;548 }* 插入用户发送的信息 sql1 insertMessages(String sql1) {554String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;555try {556conn = DriverManager.getConnection(url, “sa”, “251860”);557st = conn.createStatement();558 st.executeUpdate(sql1);559560 st.close();561 conn.close();562} catch (SQLException e) {563564 e.printStackTrace();565 }566567 }* 添加好友 hostId friendId addFriends(String hostId,String friendId){574String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;575try {576conn = DriverManager.getConnection(url, “sa”, “251860”);577String sql =”insert into Friends values(?,?)”;578ps = conn.prepareStatement(sql);579ps.setString(1, hostId);580ps.setString(2, friendId);581 ps.execute();582583 ps.close();584 conn.close();585} catch (SQLException e) {586 e.printStackTrace();587 }588589 }* 删除好友 friendId deleteFriends(String friendId) {595String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;596try {597conn = DriverManager.getConnection(url, “sa”, “251860”);598String sql = “delete from Friends where FriendId = ?”;599ps = conn.prepareStatement(sql);600ps.setString(1, friendId);601 ps.execute();602 ps.close();603 conn.close();604} catch (SQLException e) {605 e.printStackTrace();606 }607 }* 接收信息 toFriendArrayList<String> receiveMessages(String toFriend) {615ArrayList<String> arrayList = new ArrayList<String>();616String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;617try {618conn = DriverManager.getConnection(url, “sa”, “251860”);619String sql = “select Message from Messages where ToUserId=? and MessageState = ?”;620ps= conn.prepareStatement(sql);621ps.setString(1, toFriend);622ps.setInt(2, 0);623rs = ps.executeQuery();624while (rs.next()){625arrayList.add(rs.getString(“Message”));626 }627 rs.close();628 ps.close();629 conn.close();e.printStackTrace();632 }633return arrayList;634 }* 更新信息状态 id updateMessage(String id) {640String url = “jdbc:sqlserver://localhost:1433; DatabaseName=MyQQ”;641try {642conn = DriverManager.getConnection(url, “sa”, “251860”);643String sql = “update Messages set MessageState = 1 where ToUserId = ?”;644ps = conn.prepareStatement(sql);645ps.setString(1, id);646 ps.execute();647648 ps.close();649 conn.close();650} catch (SQLException e) {651 e.printStackTrace();652 }653 }654 },挫折其实就是迈向成功所应缴的学费。

MyQQ 项目 (未完…)

相关文章:

你感兴趣的文章:

标签云: