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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Telnet服务器 > 查看源码
InsertDB.cpp
资源名称：telnet-2.1b2-source.rar　[点击查看]
上传用户：haiweijt
上传日期：2018-02-23
资源大小：8195k
文件大小：9k
源码类别：

Telnet服务器

开发平台：

Visual C++

InsertDB.cpp：源码内容
  1. // TMyBuffer.cpp: implementation of the TMyBuffer class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  4. #include "InsertDB.h"
  5. #include <stdio.h>
  6. #include <string.h>
  9. //////////////////////////////////////////////////////////////////////
  10. // Construction/Destruction
  11. //////////////////////////////////////////////////////////////////////
  13. InsertDB::InsertDB()
  14. {
  15. m_Offset = 0;//行中的字符索引
  16. m_flag=10;  //标记命令索引
  17. m_zhizhen=0; //标记是否读取字段名行并与配置命令所在的字段名行相符情况下的条件
  18. m_zhi=0; // 标记正在读取字段名行
  19. tco.Open();
  20. char ip[50];
  21. tco.ReadSystemString("IP", ip,32);
  22. char User[50];
  23. tco.ReadSystemString("User",User,sizeof(User));
  24. char PWD[50];
  25. tco.ReadSystemString("PWD",PWD,sizeof(PWD));
  26. char DB[50];
  27. tco.ReadSystemString("DB",DB,sizeof(DB));
  28. tn.Open(ip,User,PWD,DB);
  29. tn.Connect();
  33. char value[3];
  34. int count;
  35. int tt;
  36. char field[10][512];
  37. char v_field[6][50];
  38. char v_str[300];
  39. tco.ReadCount(value,sizeof(value));
  40. count=value[0]-48;//命令条数
  41. for(int t=0;t<count;t++)//将配置文件所有参数赋给文件变量
  42. {
  43. tco.ReadCmd(t,m_cmd[t],sizeof(m_cmd[t]));
  44. tco.ReadField(t,field[t],sizeof(field[t]));
  45. int m=0;
  46. tt=0;
  47. while(field[t][tt]!=' '&&(field[t][tt]!='')&&(field[t][tt]>0))
  48. {
  49. while(field[t][tt]==' ')
  50. {
  51. tt++;
  52. }
  53. int r=0;
  54. while((field[t][tt]!='^')&&(field[t][tt]!=''))
  55. {
  56. if(field[t][tt]=='-')
  57. {
  58. m_field[t][m][r++]='_'; //建表时字段不允许“-”符号
  59. field[t][tt]=='_';
  60. tt++;
  61. }
  62. m_field[t][m][r++]=field[t][tt++];
  64. }
  65. m_field[t][m][r]='';
  66. m++;
  67. m_fies[t]=m+48;
  68. if(field[t][tt]!='')
  69. tt++;
  70. }
  71. }
  72. for(int n=0;n<count;n++)//建表
  73. { int i=0;
  74. int j=0;
  75. while(m_cmd[n][i]!='')
  76. {
  77. if(m_cmd[n][i]==' ')
  78. { i++;
  79. v_cmd[n][j++]='_';
  80. }else{
  81. v_cmd[n][j++]=m_cmd[n][i++];
  82. }
  83. }
  84. v_cmd[n][j]='';
  85. strcpy(v_str,"CREATE TABLE ");
  86. strcat(v_str,v_cmd[n]);
  87. strcat(v_str,"( ");
  88. int k;
  89. for(k=0;k<m_fies[n]-49;k++)
  90. {
  91. strcat(v_str,m_field[n][k]);
  92. strcat(v_str," [nvarchar](300) ,");
  93. }
  94. strcat(v_str,m_field[n][k]);
  95. strcat(v_str," [nvarchar](300) )");
  96. tn.Execute(v_str);
  97. strcpy(v_str,"");
  99. }
  102. }
  104. InsertDB::~InsertDB()
  105. {
  107. }
  109. void InsertDB::InsertInto(char *str)
  110. {
  112. char Fie[6][200]={{""}};
  113. char Do[50]; //一个字段还有多个分离的字符串
  114. char str1[500]="";
  115.     char path[256];
  116. char cmd[100];
  117. int zd; //标记字段起始点
  118. int m_duozd=0; //标记遇到上条记录余下的记录
  120.    // TNewADO* tn=new TNewADO;
  121. // char* s=tco->GetConfigFileName(path,256);
  125.     int i=0;
  126.     int j=0;
  127. while((str[i]!=' ')&&(str[i]!='>'))
  128. {
  129. cmd[j++]=str[i++];
  130. }
  131. cmd[j]='';
  132. if(strcmp(cmd,"TCS_Switch")==0)
  133. {
  134. strcpy(cmd,"");
  135. i++;
  136. j=0;
  137. while(str[i]!='x0d')
  138. {
  139. cmd[j++]=str[i++];
  140. }
  141. cmd[j]='';
  142. for(int t=0;t<10;t++)
  143. {
  144. if(strcmp(cmd,m_cmd[t])==0)
  145. { //判断命令属于配置文件中的第几条，并用m_flag标注
  146. m_flag=t;
  147. for(int fo=0;fo<6;fo++)
  148. {
  149. ziduan[fo]=0;
  150. }
  151. return;
  152. }
  153. if(t==9) return;
  154. }
  156. //printf("---%sn",cmd);
  157. }
  158. i=0;j=0;
  159. while((i<strlen(str))&&m_flag!=10)//这里默认设置最多配置10条命令
  160. {
  161.   if((str[i]!=''))//(str[i]!=' ')&&
  162. {   
  163. while((str[i]=='-')&&(str[i+1]=='-'))
  164. return;
  165. zd=i;
  166. char zid[20]="";
  167. if(ziduan[0]==0){
  168. while(str[i]!=' ')
  169. {
  170. Fie[0][j++]=str[i++];
  171. }
  172. }else{
  173. while((i-zd)<ziduan[0]-1)
  174. {
  175. Fie[0][j++]=str[i++];
  177. int r;
  178. for( r=0;r<ziduan[0]-1;r++)
  179. {
  180. zid[r]=' ';
  181. }
  182. zid[r+1]='';
  183. }
  184. }
  185. Fie[0][j]='';//intferace
  187. //strcpy(v_duozd[0],Fie[0]);
  188.    if(strcmp(Fie[0],m_field[m_flag][0])==0)
  189. { //判断命令后，在找出信息列表中的表头首字段，如果是就继续读取
  190. m_zhizhen=1;
  191. m_zhi=1;
  192. } 
  193. if((strcmp(Fie[0],zid)==0))
  194.    {
  195.  m_duozd=1;
  196.    }
  197. if(m_zhizhen==1)
  198. {
  199. j=0;
  200. if(m_zhi==1)
  201. {
  202. while(str[i]==' ')
  203. {
  204.    i++;
  205. }
  206. if(m_zhi==1)
  207. ziduan[0]=i-zd;
  208. zd=i;
  209. while(str[i]!=' ')
  210. {
  211. if(str[i]=='-')
  212. {
  213. Fie[1][j++]='_';
  214. i++;
  215. }
  216.    Fie[1][j++]=str[i++];
  217. }
  219. }else{
  220. zd=i;
  221. while((i-zd)<ziduan[1]-1){
  222.  Fie[1][j++]=str[i++];
  223. }
  224. }
  225. Fie[1][j]=''; 
  227.  //ip
  228. //strcpy(v_duozd[1],Fie[1]);
  229. j=0;
  230. if(m_zhi==1)
  231. {
  232. while(str[i]==' ')
  233. {
  234.    i++;
  235. }
  236. if(m_zhi==1)
  237. ziduan[1]=i-zd;
  238. zd=i;
  239. while(str[i]!=' ')
  240. {
  241. if(str[i]=='-')
  242. {
  243. Fie[1][j++]='_';
  244. i++;
  245. }
  246.    Fie[2][j++]=str[i++];
  247. }
  249. }else{
  250. zd=i;
  251. while((i-zd)<ziduan[2]+1){
  252.  Fie[2][j++]=str[i++];
  253. }
  254. }
  256. Fie[2][j]='';       //ok
  257. //strcpy(v_duozd[2],Fie[2]);
  258. j=0;
  259. while((str[i]==' ')&&(str[i]!=''))
  260. {
  261.    i++;
  262. }
  263. if(m_zhi==1)
  264. ziduan[2]=i-zd;
  265. zd=i;
  266. if((m_zhi!=1)&&(ziduan[4]==2))
  267. {   int f=i;
  268. while(str[f]!='n')
  269. {
  270. f++;
  271. }
  272. ziduan[3]=f-i;
  273. }
  274. while((str[i]!=' ')&&(str[i]!=13))
  275. {
  276.    Fie[3][j++]=str[i];
  277.    
  278. i++;
  279. }
  280. Fie[3][j]='';    //method
  281.   //strcpy(v_duozd[3],Fie[3]);
  283. j=0;
  284. while((i-zd)<ziduan[3]-1)
  285. {
  286.    Do[j++]=str[i++];
  287. }
  288. Do[j]='';
  289. strcat(Fie[3],Do);
  290. strcpy(Do,"");
  294. j=0;
  295. while((str[i]==' ')&&(str[i]!=''))
  296. {
  297.    i++;
  298. }
  299. if(m_zhi==1)
  300. ziduan[3]=i-zd;
  301. zd=i;
  302. while(str[i]!=' '&&(str[i]!=''))
  303. { 
  304.    Fie[4][j++]=str[i++];
  305. }
  306. Fie[4][j]=' ';
  307. Fie[4][j+1]='';//status
  308. while((i-zd)<(ziduan[4]-2)){
  309. i++;
  310. j=0;
  311. while(i<(ziduan[4]+zd-1))
  312. {
  313.    Do[j++]=str[i++];
  314. }
  315. Do[j]='';
  316. strcat(Fie[4],Do);
  317. strcpy(Do,"");
  318. }
  319. //strcpy(v_duozd[4],Fie[4]);
  320. j=0;
  321. while(str[i]==' '&&(str[i]!=''))
  322. {
  323.    i++;
  324. }
  325. if(m_zhi==1)
  326. ziduan[4]=i-zd;
  327. zd=i;
  328. while((str[i]!=' ')&&(str[i]!=''))
  329. {
  330.    Fie[5][j++]=str[i++];
  331. }
  332. Fie[5][j]=''; //prot
  333. // strcpy(v_duozd[5],Fie[5]);
  334. if(m_zhi==1)
  335. {
  336. if(strcmp(Fie[1],m_field[m_flag][1])==0)
  337. {   
  338. m_zhi=0;
  339. return;
  340. }else{
  341. m_zhi=0;
  342. m_flag=10;
  343. return;
  344. }
  345. }
  346. while(i<strlen(str))
  347. {
  348.    i++;
  349. }
  350. if(m_zhi==1)
  351. ziduan[4]=i-zd;
  353. }
  354. }
  355. i++;
  356. }
  357. if(m_duozd==1){  //遇到一条记录占多行的情况 通过删除和插入累加到数据库中
  358. strcat(v_duozd[3],Fie[3]);
  359. char str2[200]="";
  360. strcpy(str2,"DELETE FROM ");
  361. strcat(str2,v_cmd[m_flag]);
  362. strcat(str2," WHERE ");
  363. strcat(str2,m_field[m_flag][0]);
  364. strcat(str2,"='");
  365. strcat(str2,v_duozd[0]);
  366. strcat(str2,"'");
  367. tn.Execute(str2);
  368. //m_duozd=0;
  371. char str3[200]="";
  372. strcpy(str3,"INSERT INTO ");
  373. strcat(str3,v_cmd[m_flag]);
  374. strcat(str3," (");
  375. int k;
  376. for(k=0;k<m_fies[m_flag]-49;k++)
  377. {
  378. strcat(str3,m_field[m_flag][k]);
  379. strcat(str3,"  ,");
  380. }
  381. strcat(str3,m_field[m_flag][k]);
  382. strcat(str3,") VALUES('");
  383. int n;
  384. for(n=0;n<m_fies[m_flag]-49;n++)
  385. {
  386. strcat(str3,v_duozd[n]);
  387. strcat(str3,"','");
  388. }
  389. strcat(str3,v_duozd[n]);
  390. strcat(str3,"')");
  391. tn.Execute(str3);
  392. }
  393. if((m_flag!=10)&&(m_duozd==0))
  394. {
  395. strcpy(str1,"INSERT INTO ");
  396. strcat(str1,v_cmd[m_flag]);
  397. strcat(str1," (");
  398. int k;
  399. for(k=0;k<m_fies[m_flag]-49;k++)
  400. {
  401. strcat(str1,m_field[m_flag][k]);
  402. strcat(str1,"  ,");
  403. }
  404. strcat(str1,m_field[m_flag][k]);
  405. strcat(str1,") VALUES('");
  406. int n;
  407. for(n=0;n<m_fies[m_flag]-49;n++)
  408. {
  409. strcat(str1,Fie[n]);
  410. strcat(str1,"','");
  411. }
  412. strcat(str1,Fie[n]);
  413. strcat(str1,"')");
  414. tn.Execute(str1);
  416. }
  417. if(m_duozd==0)
  418. {
  419. for(int k=0;k<6;k++){
  420. strcpy(v_duozd[k],Fie[k]);
  421. }
  422. }
  423. //一行一行的写入硬盘文件中
  424. FILE* fp = fopen("c:\Telnet.txt","at");
  425. fprintf(fp, "%s",str);
  426. fclose(fp);
  429. }
  431. void InsertDB::Insert(char *buf, int size)
  432. {
  433. if (size == 0)
  434. return;
  435. unsigned char tmpc = *(unsigned char *)buf;
  436. switch(tmpc)
  437. {
  438. case 8:
  439. if (m_Offset > 0)
  440. m_Offset --;
  441. break;
  442. case 13:
  443. m_Buffer[m_Offset++] = 'x0d';
  444. break;
  445. case 10:
  446. m_Buffer[m_Offset++] = 'x0a';
  447. m_Buffer[m_Offset] = '';
  448. InsertInto(m_Buffer);
  449. strcpy(m_Buffer,"");
  450. m_Offset = 0;
  451. break;
  452. default:
  453. m_Buffer[m_Offset++] = buf[0];
  454. break;
  455. }
  456. Insert(buf+1, size-1);
  457. }