开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > ICQ/即时通讯 > 查看源码
severdata.cs
资源名称：类似QQ聊天程序.rar　[点击查看]
上传用户：yan_wy
上传日期：2007-06-09
资源大小：112k
文件大小：13k
源码类别：

ICQ/即时通讯

开发平台：

C#

severdata.cs：源码内容
  1. using System;
  2. using System.Data;
  3. using System.Drawing;
  4. using System.Collections;
  5. using System.ComponentModel;
  6. using System.Windows.Forms;
  7. using System.Net;
  9. namespace qq
  10. {
  11. /// <summary>
  12. /// severdata 的摘要说明。
  13. /// </summary>
  14. public class severdata : System.Windows.Forms.Form
  15. {
  16. public DataSet dataset;
  17. Form1 form;
  18. private System.Data.SqlClient.SqlCommand sqlSelectCommand1;
  19. private System.Data.SqlClient.SqlCommand sqlInsertCommand1;
  20. public System.Data.SqlClient.SqlConnection sqlConnection1;
  21. public System.Data.SqlClient.SqlDataAdapter sqlDataAdapter1;
  22. private System.Data.SqlClient.SqlCommand sqlSelectCommand2;
  23. private System.Data.SqlClient.SqlCommand sqlInsertCommand2;
  24. private System.Data.SqlClient.SqlDataAdapter sqlDataAdapter2;
  25. /// <summary>
  26. /// 必需的设计器变量。
  27. /// </summary>
  28. private System.ComponentModel.Container components = null;
  30. public severdata(Form1 sform)
  31. {
  32. //
  33. // Windows 窗体设计器支持所必需的
  34. //
  35. form=sform;
  36. dataset=new DataSet();
  37. dataset.Tables.Add("user");
  38. dataset.Tables.Add("me");
  39. dataset.Tables.Add("you");
  40. InitializeComponent();
  42. //
  43. // TODO: 在 InitializeComponent 调用后添加任何构造函数代码
  44. //
  45. }
  47. /// <summary>
  48. /// 清理所有正在使用的资源。
  49. /// </summary>
  50. protected override void Dispose( bool disposing )
  51. {
  52. if( disposing )
  53. {
  54. if(components != null)
  55. {
  56. components.Dispose();
  57. }
  58. }
  59. base.Dispose( disposing );
  60. }
  62. #region Windows 窗体设计器生成的代码
  63. /// <summary>
  64. /// 设计器支持所需的方法 - 不要使用代码编辑器修改
  65. /// 此方法的内容。
  66. /// </summary>
  67. private void InitializeComponent()
  68. {
  69. this.sqlSelectCommand1 = new System.Data.SqlClient.SqlCommand();
  70. this.sqlConnection1 = new System.Data.SqlClient.SqlConnection();
  71. this.sqlInsertCommand1 = new System.Data.SqlClient.SqlCommand();
  72. this.sqlDataAdapter1 = new System.Data.SqlClient.SqlDataAdapter();
  73. this.sqlSelectCommand2 = new System.Data.SqlClient.SqlCommand();
  74. this.sqlInsertCommand2 = new System.Data.SqlClient.SqlCommand();
  75. this.sqlDataAdapter2 = new System.Data.SqlClient.SqlDataAdapter();
  76. // 
  77. // sqlSelectCommand1
  78. // 
  79. this.sqlSelectCommand1.CommandText = "SELECT id, mima, name, sex, picture, age, jianjie, state, ip FROM [user]";
  80. this.sqlSelectCommand1.Connection = this.sqlConnection1;
  81. // 
  82. // sqlInsertCommand1
  83. // 
  84. this.sqlInsertCommand1.CommandText = "INSERT INTO [user] (id, mima, name, sex, picture, age, jianjie, state, ip) VALUES" +
  85. " (@id, @mima, @name, @sex, @picture, @age, @jianjie, @state, @ip); SELECT id, mi" +
  86. "ma, name, sex, picture, age, jianjie, state, ip FROM [user]";
  87. this.sqlInsertCommand1.Connection = this.sqlConnection1;
  88. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@id", System.Data.SqlDbType.Int, 4, "id"));
  89. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@mima", System.Data.SqlDbType.NVarChar, 10, "mima"));
  90. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@name", System.Data.SqlDbType.VarChar, 10, "name"));
  91. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@sex", System.Data.SqlDbType.VarChar, 10, "sex"));
  92. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@picture", System.Data.SqlDbType.VarChar, 10, "picture"));
  93. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@age", System.Data.SqlDbType.Int, 4, "age"));
  94. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@jianjie", System.Data.SqlDbType.VarChar, 2147483647, "jianjie"));
  95. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@state", System.Data.SqlDbType.Int, 4, "state"));
  96. this.sqlInsertCommand1.Parameters.Add(new System.Data.SqlClient.SqlParameter("@ip", System.Data.SqlDbType.VarChar, 10, "ip"));
  97. // 
  98. // sqlDataAdapter1
  99. // 
  100. this.sqlDataAdapter1.InsertCommand = this.sqlInsertCommand1;
  101. this.sqlDataAdapter1.SelectCommand = this.sqlSelectCommand1;
  102. this.sqlDataAdapter1.TableMappings.AddRange(new System.Data.Common.DataTableMapping[] {
  103.   new System.Data.Common.DataTableMapping("Table", "user", new System.Data.Common.DataColumnMapping[] {
  104.   new System.Data.Common.DataColumnMapping("id", "id"),
  105.   new System.Data.Common.DataColumnMapping("mima", "mima"),
  106.   new System.Data.Common.DataColumnMapping("name", "name"),
  107.   new System.Data.Common.DataColumnMapping("sex", "sex"),
  108.   new System.Data.Common.DataColumnMapping("picture", "picture"),
  109.   new System.Data.Common.DataColumnMapping("age", "age"),
  110.   new System.Data.Common.DataColumnMapping("jianjie", "jianjie"),
  111.   new System.Data.Common.DataColumnMapping("state", "state"),
  112.   new System.Data.Common.DataColumnMapping("ip", "ip")})});
  113. // 
  114. // sqlSelectCommand2
  115. // 
  116. this.sqlSelectCommand2.CommandText = "SELECT uid, friendid FROM friends";
  117. this.sqlSelectCommand2.Connection = this.sqlConnection1;
  118. // 
  119. // sqlInsertCommand2
  120. // 
  121. this.sqlInsertCommand2.CommandText = "INSERT INTO friends(uid, friendid) VALUES (@uid, @friendid); SELECT uid, friendid" +
  122. " FROM friends";
  123. this.sqlInsertCommand2.Connection = this.sqlConnection1;
  124. this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@uid", System.Data.SqlDbType.Int, 4, "uid"));
  125. this.sqlInsertCommand2.Parameters.Add(new System.Data.SqlClient.SqlParameter("@friendid", System.Data.SqlDbType.Int, 4, "friendid"));
  126. // 
  127. // sqlDataAdapter2
  128. // 
  129. this.sqlDataAdapter2.InsertCommand = this.sqlInsertCommand2;
  130. this.sqlDataAdapter2.SelectCommand = this.sqlSelectCommand2;
  131. this.sqlDataAdapter2.TableMappings.AddRange(new System.Data.Common.DataTableMapping[] {
  132.   new System.Data.Common.DataTableMapping("Table", "friends", new System.Data.Common.DataColumnMapping[] {
  133.  new System.Data.Common.DataColumnMapping("uid", "uid"),
  134.  new System.Data.Common.DataColumnMapping("friendid", "friendid")})});
  135. // 
  136. // severdata
  137. // 
  138. this.AutoScaleBaseSize = new System.Drawing.Size(6, 14);
  139. this.ClientSize = new System.Drawing.Size(292, 273);
  140. this.Name = "severdata";
  141. this.Text = "severdata";
  142. this.Closing += new System.ComponentModel.CancelEventHandler(this.severdata_Closing);
  143. this.Closed += new System.EventHandler(this.severdata_Closed);
  144. this.Paint += new System.Windows.Forms.PaintEventHandler(this.severdata_Paint);
  146. }
  147. #endregion
  149. public int yanzhen()
  150. {
  151. try
  152. {
  153. //下面是用户登陆时，验证密码是否错误，如果错误，则抛出错误，同时返回错误信息
  154. System.Data.SqlClient.SqlCommand sss=new System.Data.SqlClient.SqlCommand();
  155. sss.CommandText="SELECT name,mima,sex,picture,age,jianjie from [user] where id="+form.userid;
  156. sss.Connection=this.sqlConnection1;
  157. this.sqlDataAdapter1.SelectCommand=sss;
  158. this.sqlDataAdapter1.Fill(dataset,"me");
  159. if(this.dataset.Tables["me"].Rows.Count==0)
  160. return 0;//没有此用户
  161. foreach(DataRow dt in this.dataset.Tables["me"].Rows)
  162. {
  164. if(form.mima!=(dt[1].ToString()).Trim())
  165. return 0;//用户密码错误
  166. form.name=dt[0].ToString();
  167. }
  168. return 1;//密码正缺
  169. }
  170. catch(Exception ee)
  171. {
  172. return 2;//异常处理
  173. }
  175. }
  176. public void close()
  177. {
  178. //下面是当用户下线时，更新数据库，把它的state变为0，同时发送下线通知消息，以便它的好友用户处理
  179. System.Data.SqlClient.SqlCommand updata=new System.Data.SqlClient.SqlCommand();
  180. updata.CommandText= "UPDATE [user] SET state=0 WHERE id="+form.userid; 
  181. updata.Connection=this.sqlConnection1;
  182. this.sqlConnection1.Open();
  183. updata.ExecuteNonQuery();//执行语句
  184. this.sqlConnection1.Close();
  185. foreach(UserControl1 dt in form.userlist)
  186. {
  187. if(dt.state=="1")
  188. {
  190. form.use.sendmessage(form.userid);
  191. form.use.sendmessage(dt.uid);
  192. form.use.sendmessage("下线通知");//下线通知
  194. }
  195. }
  197. }
  198. public void addfriends()
  199. {
  201. }
  202. public void adduse(string name,string mima,string jianjie,string picture)
  203. {
  204. System.Data.SqlClient.SqlCommand select=new System.Data.SqlClient.SqlCommand();
  205. select.CommandText="SELECT top 1 id from [user] order by id desc";
  206. select.Connection=this.sqlConnection1;
  207. //这里是添加好友，上面先找到QQ号码最大的一个，这样在注册号码时，就自动分配给它的QQ号是当前的最大号加1
  209. try
  210. {
  211. this.sqlConnection1.Open();
  212. string a= (select.ExecuteScalar()).ToString();
  213. int b=int.Parse(a);//字符转换为数据
  214. b=b+1;//号码加1
  215. a=b.ToString();
  216. this.form.userid=a;
  218. string hostname=Dns.GetHostName();
  219. IPAddress ipAddress = Dns.GetHostByName(hostname).AddressList[0];
  220. //得到主机ip
  221. //下面是把用户加到数据库，insert语句的格式是insert into （×× ）value（对应的数据）；
  222. System.Data.SqlClient.SqlCommand insert=new System.Data.SqlClient.SqlCommand();
  223. insert.CommandText="INSERT INTO [user] (id, mima, name, sex, picture, age, jianjie, state, ip)  VALUES ("+//+b+","+form.mima+","+name+",男,1,20,"+jianjie+",0,0)";
  224. a+",'"+mima+"','"+name+"','男','"+picture+"',20,'"+jianjie+"',0,'"+ipAddress.ToString()+"')";
  225. MessageBox.Show("你的QQ号："+b);//向用户说明你的QQ号
  226. insert.Connection=this.sqlConnection1;
  227. insert.ExecuteNonQuery();//执行查询
  228. insert.Connection=this.sqlConnection1;
  231. this.sqlConnection1.Close();
  232. }
  233. catch(Exception ee)
  234. {
  235. MessageBox.Show(ee.ToString());//   出错处理
  236. }
  238. }
  239. public void shanxian()
  240. {
  241. foreach(UserControl1 dt in form.userlist)
  242. {
  243. if(dt.state=="1")
  244. {
  246. form.use.sendmessage(form.userid);
  247. form.use.sendmessage(dt.uid);
  248. form.use.sendmessage("上线通知");
  250. }
  251. }
  252. }
  253. public void  Startset()
  254. {
  256. try
  257. {
  259. string hostname=Dns.GetHostName();
  260. IPAddress ipAddress = Dns.GetHostByName(hostname).AddressList[0];
  262. //获得主机ip，用DNS查询
  263. System.Data.SqlClient.SqlCommand updata=new System.Data.SqlClient.SqlCommand();
  264. updata.CommandText= "UPDATE [user] SET state=1 ,ip='"+ipAddress.ToString()+"' WHERE id="+form.userid; 
  265. /*
  266.   这句话是把数据库中的state由0变为1，同时储存它的ip，意思是用户上线了。这里的查询的号码为form。userid的用户
  267.   这里我要提醒一条的是，在写数据库语句时，如果是字符串，要加单引号，如果是数字，就不用了
  268.  */
  269. updata.Connection=this.sqlConnection1;
  270. this.sqlConnection1.Open();//打开连接
  271. updata.ExecuteNonQuery();//执行上面的语句，这里一定要打开数据连接
  272. this.sqlConnection1.Close();//关闭连接
  274. System.Data.SqlClient.SqlCommand select=new System.Data.SqlClient.SqlCommand();
  275. select.CommandText= "SELECT [user].id,[user].name,[user].sex,[user].picture,[user].age,[user].jianjie,[user].state,[user].ip FROM [user] , [friends]  where [friends].uid="+form.userid+" and [user].id =[friends].friendid";
  276. select.Connection=this.sqlConnection1;
  277. this.sqlDataAdapter1.SelectCommand=select;
  278. this.sqlDataAdapter1.Fill(dataset,"user");
  279. //上面是选择语句，选择本用户的好友信息，然后保存在dataset里的user表里
  280.                   //这里的sqlDataAdapter执行时不用写sqlconnect。open因为它集成了打开操作。
  281. //另外在数据库的语句中，凡是数据库的表都要加『』符合。
  282. }
  283. catch(Exception ee)
  284. {
  286. this.form.isinline=0;//出错处理。表示连接不到数据库
  288. }
  289. //下面是在用户界面上显示好友，数据来自dataset的user
  291. foreach(DataRow dt in this.dataset.Tables["user"].Rows)
  292. {
  293. UserControl1 userControl13=new UserControl1(form);
  294. userControl13.Dock=DockStyle.Top;
  295. userControl13.uid=dt[0].ToString();
  296. userControl13.name=dt[1].ToString();
  297. userControl13.sex=dt[2].ToString();
  298. userControl13.picture=dt[3].ToString();
  299. userControl13.age=dt[4].ToString();
  300. userControl13.jianjie=dt[5].ToString();
  301. userControl13.state=dt[6].ToString();
  302. userControl13.ip=dt[7].ToString().Trim();
  303. userControl13.setname(dt[1].ToString());
  304. userControl13.setimage((dt[3].ToString()).Trim());
  305. form.userlist.Add(userControl13);
  306. }
  307. foreach(UserControl1 dt in form.userlist)
  308. {
  309. if(dt.state=="0")
  310. form.panel4.Controls.Add(dt);
  311. }
  312. foreach(UserControl1 dt in form.userlist)
  313. {
  314. if(dt.state=="1")
  315. {
  316. form.panel4.Controls.Add(dt);
  319. }
  320. }
  322. }
  324. private void severdata_Closed(object sender, System.EventArgs e)
  325. {
  327. }
  329. private void severdata_Closing(object sender, System.ComponentModel.CancelEventArgs e)
  330. {
  332. }
  334. private void severdata_Paint(object sender, System.Windows.Forms.PaintEventArgs e)
  335. {
  337. }
  339. }
  340. }