日韩av黄I国产麻豆传媒I国产91av视频在线观看I日韩一区二区三区在线看I美女国产在线I麻豆视频国产在线观看I成人黄色短片

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程语言 > c/c++ >内容正文

c/c++

【C/C++11】天气APP:txt/xml文件处理入库(psurfdata.cpp,_shqx.h),数据结构设计(PowerDesigner)

發布時間:2024/4/24 c/c++ 97 豆豆
生活随笔 收集整理的這篇文章主要介紹了 【C/C++11】天气APP:txt/xml文件处理入库(psurfdata.cpp,_shqx.h),数据结构设计(PowerDesigner) 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

文章目錄

  • 1.txt/xml文件入表/自身調度:結構體內容
  • 2.分區/表空間/網絡/主鍵/錯誤優化:chown -R 用戶
  • 3.歷史文件/表數據清理:生成測試數據后去采集,采集后未刪除文件,因為數據不只一個系統用
  • 4.站點參數建表入表/PowerDesigner/主外鍵:g/./s//./g,多表查詢


1.txt/xml文件入表/自身調度:結構體內容

// makefile #oracle頭文件路徑 ORAINCL = -I$(ORACLE_HOME)/rdbms/public# oracle庫文件路徑 ORALIB = -L$(ORACLE_HOME)/lib -L.# oracle的oci庫 ORALIBS = -lclntshCC=g++ CFLAGS = -g -Wno-write-strings -Wno-unused-variableall:crtsurfdata libftp.a demo18 ftpgetfile psurfdatalibftp.a:ftplib.cgcc -c -o libftp.a ftplib.cdemo18:demo18.cpp _ftp.h _ftp.cpp libftp.ag++ $(CFLAGS) -o demo18 demo18.cpp _public.cpp _ftp.cpp libftp.aftpgetfile:ftpgetfile.cpp _ftp.h _ftp.cpp libftp.a$(CC) $(CFLAGS) -o ftpgetfile ftpgetfile.cpp _public.cpp _ftp.cpp libftp.acp ftpgetfile ../bin/.crtsurfdata:crtsurfdata.cpp _public.h _public.cpp$(CC) $(CFLAGS) -o crtsurfdata crtsurfdata.cpp _public.cppcp crtsurfdata ../bin/.psurfdata:psurfdata.cpp _public.h _public.cppg++ $(CFLAGS) -o psurfdata psurfdata.cpp $(ORAINCL) $(ORALIB) $(ORALIBS) _public.cpp _ooci.cppcp psurfdata ../bin/.clean:rm -rf crtsurfdata demo18 ftpgetfile libftp psurfdata //psurfdata.cpp未封裝成類 //本程序用于處理全國氣象站點觀測的分鐘數據,并保存到數據庫的T_SURFDATA表中。txt文件里面內容以逗號分隔 #include "_public.h" #include "_ooci.h" struct st_surfdata // 全國氣象站點分鐘觀測數據結構 {char obtid[11]; // 站點代碼char ddatetime[21]; // 數據時間:格式yyyy-mm-dd hh:mi:ss。int t; // 氣溫:單位,0.1攝氏度int p; // 氣壓:0.1百帕int u; // 相對濕度,0-100之間的值。int wd; // 風向,0-360之間的值。int wf; // 風速:單位0.1m/sint r; // 降雨量:0.1mmint vis; // 能見度:0.1米 }; CLogFile logfile; CDir Dir; bool _psurfdata(); // 處理數據文件 connection conn; void EXIT(int sig);int main(int argc,char *argv[]) {if (argc!=5){printf("\n本程序用于處理全國氣象站點觀測的分鐘數據,并保存到數據庫的T_SURFDATA表中。\n");printf("/oracle/lian/qxidc/bin/psurfdata 數據文件存放的目錄 日志文件名 數據庫連接參數 程序運行時間間隔\n");printf("例如:/oracle/lian/qxidc/bin/psurfdata /oracle/lian/qxidc/tmp /oracle/lian/qxidc/log/psurfdata.log scott/tiger@snorcl11g_138 10\n");return -1; //失敗跳出main函數,必須在裝有oracle主機中運行,不然_ooci中路徑報錯}CloseIOAndSignal(); // 關閉全部的信號和輸入輸出 signal(SIGINT,EXIT); signal(SIGTERM,EXIT); // 處理程序退出的信號if (logfile.Open(argv[2],"a+")==false){printf("打開日志文件失敗(%s)。\n",argv[2]); return -1;}logfile.Write("程序啟動。\n");while (true){ //1111111111111111111111111111111111111111111111111.掃描數據文件存放的目錄//logfile.Write("開始掃描目錄。\n"); //打開目錄拿到文件名放入string型容器里,需排序的話就把這容器排序(先生成先處理)if (Dir.OpenDir(argv[1],"SURF_ZH_*.txt",1000,true,true)==false) //OpenDir第四個參數是否打開子目錄,第五個參數是否排序{logfile.Write("Dir.OpenDir(%s) failed.\n",argv[1]); sleep(atoi(argv[4])); continue;}//11111111111111111111111111111111111111111111111.逐個處理目錄中的數據文件while (true){if (Dir.ReadDir()==false) break; //false為讀完了 //logfile.Write("%s,%s,%s,%d,%s,%s,%s,%s\n",Dir.m_DirName,Dir.m_FileName,Dir.m_FullFileName,Dir.m_FileSize,Dir.m_ModifyTime,Dir.m_CreateTime,Dir.m_AccessTime);//111111111111111111111111111111111111111111111111.連接數據庫if (conn.m_state==0) //0未連接{if (conn.connecttodb(argv[3],"Simplified Chinese_China.ZHS16GBK")!=0){logfile.Write("connect database(%s) failed.\n%s\n",argv[3],conn.m_cda.message); break;// logfile.Write("連接數據庫成功。\n");}}//1111111111111111111111111111111111111111111111111.處理入庫logfile.Write("開始處理文件%s...",Dir.m_FileName); //開頭有時間if (_psurfdata()==false) {logfile.WriteEx("失敗。\n"); break;} logfile.WriteEx("成功。\n"); //不寫時間,不換行,顯示屏一行放不下} if (conn.m_state==1) conn.disconnect(); //斷開與數據庫的連接sleep(atoi(argv[4]));}return 0; } void EXIT(int sig) {logfile.Write("程序退出,sig=%d\n\n",sig);exit(0); }//1111111111111111111111111111111111111111111111.處理入庫 bool _psurfdata() {CFile File; //打開文件if (File.Open(Dir.m_FullFileName,"r")==false) //Dir的成員變量m_FullFileName也叫屬性{logfile.Write("(File.Open(%s) failed.\n",Dir.m_FullFileName); return false;}char strBuffer[301];CCmdStr CmdStr;struct st_surfdata stsurfdata;//定義stsurfdata結構體變量int iccount=0; //int型初始化sqlstatement stmtsel(&conn);//select * 返回多行多列的結果集,bindin綁定選擇行,bindout綁定選擇列 stmtsel.prepare("select count(*) from T_SURFDATA where obtid=:1 and ddatetime=to_date(:2,'yyyy-mm-dd hh24:mi:ss')");stmtsel.bindin( 1, stsurfdata.obtid,5); // 定義的是字符串不用&stmtsel.bindin( 2, stsurfdata.ddatetime,19);stmtsel.bindout(1,&iccount); //select count(*)返回行數即一個數字賦給iccount這個變量,這個數字也是1列,所以bindout中1對應這列sqlstatement stmtins(&conn);stmtins.prepare("insert into T_SURFDATA(obtid,ddatetime,t,p,u,wd,wf,r,vis) values(:1,to_date(:2,'yyyy-mm-dd hh24:mi:ss'),:3,:4,:5,:6,:7,:8,:9)");stmtins.bindin( 1, stsurfdata.obtid,5); //1對應:1 //,crttime,keyid //values里可加:,sysdate,SEQ_SURFDATA.nextvalstmtins.bindin( 2, stsurfdata.ddatetime,19);stmtins.bindin( 3,&stsurfdata.t);stmtins.bindin( 4,&stsurfdata.p);stmtins.bindin( 5,&stsurfdata.u);stmtins.bindin( 6,&stsurfdata.wd);stmtins.bindin( 7,&stsurfdata.wf);stmtins.bindin( 8,&stsurfdata.r);stmtins.bindin( 9,&stsurfdata.vis);while (true) //讀取文件中的每一行記錄并寫入數據庫的表中{memset(strBuffer,0,sizeof(strBuffer));if (File.Fgets(strBuffer,300,true)==false) break; //Fgets從文件中讀取一行放入strBuffer,第三個參數為是否刪除最后空格// logfile.Write("%s\n",strBuffer); strBuffer內容為58436,2020-02-09 12:11:00,32.4,1006.9,99,249,11.8,0.2,10107.3CmdStr.SplitToCmd(strBuffer,",",true); //以,號拆分成9個片段存入CmdStr中if (CmdStr.CmdCount()!=9){logfile.Write("%s\n",strBuffer); continue;}memset(&stsurfdata,0,sizeof(struct st_surfdata)); //sizeof里一般用結構體類型,傳變量名的話若是指針就不好了CmdStr.GetValue(0,stsurfdata.obtid,5); // 站點代碼 賦值給stsurfdata.obtidCmdStr.GetValue(1,stsurfdata.ddatetime,19); // 數據時間:格式yyyy-mm-dd hh:mi:ss。double dtmp=0;CmdStr.GetValue(2,&dtmp); stsurfdata.t=(int)(dtmp*10); // 氣溫:單位,0.1攝氏度CmdStr.GetValue(3,&dtmp); stsurfdata.p=(int)(dtmp*10); // 氣壓:0.1百帕CmdStr.GetValue(4,&stsurfdata.u); // 相對濕度,0-100之間的值。CmdStr.GetValue(5,&stsurfdata.wd); // 風向,0-360之間的值。CmdStr.GetValue(6,&dtmp); stsurfdata.wf=(int)(dtmp*10); // 風速:單位0.1m/sCmdStr.GetValue(7,&dtmp); stsurfdata.r=(int)(dtmp*10); // 降雨量:0.1mmCmdStr.GetValue(8,&dtmp); stsurfdata.vis=(int)(dtmp*10); // 能見度:0.1米if (stmtsel.execute() != 0){logfile.Write("stmtsel.execute() failed.\n%s\n%s\n",stmtsel.m_sql,stmtsel.m_cda.message); if ( (stmtsel.m_cda.rc>=3113) && (stmtsel.m_cda.rc<=3115) ) return false; //3113-3115是數據庫連接失敗 continue;}iccount=0;stmtsel.next(); //把"select count(*)....."這個sql查詢結果一次一次取結果集賦給綁定輸出的變量即iccount//這里比較特殊剛好一行一列即一個數字if (iccount>0) continue; //有記錄不執行插入if (stmtins.execute() != 0) // 執行SQL語句,一定要判斷返回值,0-成功,其它-失敗{ //往數據庫里插入,如果記錄存在不應該退出,應該跳過已存在的記錄if (stmtins.m_cda.rc!=1) //!=1才是真正的失敗,=1是主鍵沖突,若是主鍵沖突可以跳過不入庫不要返回失敗{logfile.Write("%s\n",strBuffer);logfile.Write("stmtins.execute() failed.\n%s\n%s\n",stmtins.m_sql,stmtins.m_cda.message); if ( (stmtins.m_cda.rc>=3113) && (stmtins.m_cda.rc<=3115) ) return false;}}} //處理生成數據就是先掃描目錄,讀取目錄下文件。讀到文件名后打開一文件,一行一行解析出數據插入數據庫表里,關閉文件,提交事務conn.commit();// 關閉文件指針,并刪除文件,不刪除會重復讀取File.CloseAndRemove(); return true; }



vi psurfdata.log,如下子目錄下的文件也讀取到了。

如下在_psurfdata()里思路是讀一行,按,號拆分,將每個內容讀出來再*10放入數據庫。


vi /htidc/shqx/ini/stcode1.ini 。

在_shqx.cpp中有InsertTable()成員函數,有select,insert,update及各個的execute()。如下如果記錄在表里已存在就執行stmtupt.execute(),不存在就執行stmtins.execute(),不管是這兩個執行,只要出錯,無效的記錄數invalidcount就+1,成功的話updatacount和insertcount都+1。


如下時間和文件名一樣,但站點不一樣 ,59287這個站點是存在的即外鍵存在。

以下是自身的調度:1.以下將psurfdata.cpp改為程序自身調度,不用crontab調度。每10秒鐘掃描一次目錄,有文件的話就連接數據庫。

如下為什么不在while(true)掃描目錄前連上數據庫?假設數據一分鐘生成一個文件,處理一個文件入庫一秒不到,所以一直連著數據庫浪費資源,掃描到有文件處理就連數據庫。

如下數據庫沒連上也不用return -1,只要psurfdata.cpp啟動后就一直運行,遇到錯誤也不能退出,所以改為break只跳出這個小循環,繼續往下面執行,日志還是會寫“connect database…failed”。

2.以下crtsurfdata中自身調度。

結構體可存不同數據類型,需解析xml,將值放入結構體再訪問。start.sh里面放crt.,ftp.,p…三個啟動腳本并最后加&符。

//將psurfdata.cpp,txt文件入庫封成類 #include "_public.h" #include "_ooci.h" #include "_shqx.h" CLogFile logfile; CDir Dir; bool _psurfdata(); connection conn; //實例化對象,con也叫變量(稱呼) void EXIT(int sig);int main(int argc,char *argv[]) {if (argc!=5){printf("\n本程序用于處理全國氣象站點觀測的分鐘數據,并保存到數據庫的T_SURFDATA表中。\n");printf("這是完善后的程序,未完善的程序在psurfdata_old.cpp中。\n");printf("/htidc/shqx/bin/psurfdata 數據文件存放的目錄 日志文件名 數據庫連接參數 程序運行時間間隔\n");printf("例如:/htidc/shqx/bin/psurfdata /data/shqx/sdata/surfdata /log/shqx/psurfdata.log shqx/pwdidc@snorcl11g_198 10\n");return -1;}CloseIOAndSignal();signal(SIGINT,EXIT); signal(SIGTERM,EXIT);if (logfile.Open(argv[2],"a+")==false){printf("打開日志文件失敗(%s)。\n",argv[2]); return -1;}logfile.Write("程序啟動。\n");while (true){ //111111111111111111111111111111111111111111111.掃描數據文件存放的目錄,只匹配"SURF_ZH_*.txt"// logfile.Write("開始掃描目錄。\n");if (Dir.OpenDir(argv[1],"SURF_ZH_*.txt",1000,true,true)==false){logfile.Write("Dir.OpenDir(%s) failed.\n",argv[1]); sleep(atoi(argv[4])); continue;}//11111111111111111111111111111111111111111111111.連接數據庫while (true){if (Dir.ReadDir()==false) break; if (conn.m_state==0){if (conn.connecttodb(argv[3],"Simplified Chinese_China.ZHS16GBK")!=0){logfile.Write("connect database(%s) failed.\n%s\n",argv[3],conn.m_cda.message); break;}// logfile.Write("連接數據庫成功。\n");} logfile.Write("開始處理文件%s...",Dir.m_FileName);//111111111111111111111111111111111111111111111111.處理入庫if (_psurfdata()==false) {logfile.WriteEx("失敗。\n"); break;}}if (conn.m_state==1) conn.disconnect(); // 斷開與數據庫的連接sleep(atoi(argv[4]));}return 0; } void EXIT(int sig) {logfile.Write("程序退出,sig=%d\n\n",sig);exit(0); }//111111111111111111111111111111111111111111111111.處理入庫 bool _psurfdata() {CFile File;if (File.Open(Dir.m_FullFileName,"r")==false){logfile.Write("(File.Open(%s) failed.\n",Dir.m_FullFileName); return false;}//1111111111111111111111111111讀取文件中的每一行記錄,寫入數據庫的表中CSURFDATA SURFDATA(&conn,&logfile); //上行給m_conn和m_logfile兩個指針成員變量賦值初始化也可寫成如下兩行://SURFDATA.m_conn=&conn; //con是對象也是變量//SURFDATA.m_logfile=&logfile;char strBuffer[301]; while (true){memset(strBuffer,0,sizeof(strBuffer));if (File.Fgets(strBuffer,300,true)==false) break; //從文件中獲取一行記錄 if (SURFDATA.SplitBuffer(strBuffer)==false) { logfile.Write("%s\n",strBuffer); continue; }// 把用逗號分隔的記錄拆分到結構體中long rc=SURFDATA.InsertTable(); //把結構體中的數據更新到T_SURFDATA表中,因為不知道返回哪個sql,所以用long rc =if ( (rc>=3113) && (rc<=3115) ) return false; //只要不是數據庫session的錯誤,程序就繼續。if (rc != 0) { logfile.Write("%s\n",strBuffer); continue; }}conn.commit(); //提交事務File.CloseAndRemove(); //關閉文件指針,并刪除文件logfile.WriteEx("成功(total=%d,insert=%d,update=%d,invalid=%d)。\n",SURFDATA.totalcount,SURFDATA.insertcount,SURFDATA.updatecount,SURFDATA.invalidcount);return true; } //psurfdata1.cpp本程序只支持xml文件入庫已封裝成類,有keyid等字段。 //表加字段,結構體不用,在sqlplus中輸入一行創建序列命令,stcode.ini不要最后留空行 #include "_public.h" #include "_ooci.h" #include "_shqx.h" CLogFile logfile; CDir Dir; bool _psurfdata(); connection conn; void EXIT(int sig);int main(int argc,char *argv[]) {if (argc!=5){printf("\n本程序用于處理全國氣象站點觀測的分鐘數據,并保存到數據庫的T_SURFDATA表中。\n");printf("與psurfdata.cpp不同,本程序只支持xml格式。\n");printf("/htidc/shqx/bin/psurfdata1 數據文件存放的目錄 日志文件名 數據庫連接參數 程序運行時間間隔\n");printf("例如:/htidc/shqx/bin/psurfdata1 /data/shqx/sdata/surfdata /log/shqx/psurfdata1.log shqx/pwdidc@snorcl11g_198 10\n");return -1;}CloseIOAndSignal();signal(SIGINT,EXIT); signal(SIGTERM,EXIT);if (logfile.Open(argv[2],"a+")==false){printf("打開日志文件失敗(%s)。\n",argv[2]); return -1;}logfile.Write("程序啟動。\n");while (true){ //1111111111111111111111111111111111111111111.掃描數據文件存放的目錄,匹配"SURF_ZH_*.xml"// logfile.Write("開始掃描目錄。\n");if (Dir.OpenDir(argv[1],"SURF_ZH_*.xml",1000,true,true)==false){logfile.Write("Dir.OpenDir(%s) failed.\n",argv[1]); sleep(atoi(argv[4])); continue;}//111111111111111111111111111111111111111111111.逐個處理目錄中的數據文件while (true){if (Dir.ReadDir()==false) break;//111111111111111111111111111111111111111111111.連接數據庫if (conn.m_state==0){if (conn.connecttodb(argv[3],"Simplified Chinese_China.ZHS16GBK")!=0){logfile.Write("connect database(%s) failed.\n%s\n",argv[3],conn.m_cda.message); break;}// logfile.Write("連接數據庫成功。\n");} logfile.Write("開始處理文件%s...",Dir.m_FileName);//111111111111111111111111111111111111111111111.處理入庫if (_psurfdata()==false) {logfile.WriteEx("失敗。\n"); break;}}if (conn.m_state==1) conn.disconnect(); sleep(atoi(argv[4]));}return 0; } void EXIT(int sig) {logfile.Write("程序退出,sig=%d\n\n",sig);exit(0); }//111111111111111111111111111111111111111111111.處理入庫 bool _psurfdata() {CFile File;if (File.Open(Dir.m_FullFileName,"r")==false){logfile.Write("(File.Open(%s) failed.\n",Dir.m_FullFileName); return false;}CSURFDATA SURFDATA(&conn,&logfile);char strBuffer[301];while (true){memset(strBuffer,0,sizeof(strBuffer));if (File.FFGETS(strBuffer,300,"<endl/>")==false) break;// logfile.Write("str=%s=\n",strBuffer);// logfile.Write("%s\n",strBuffer); if (SURFDATA.SplitBuffer1(strBuffer)==false) { logfile.Write("%s\n",strBuffer); continue; }long rc=SURFDATA.InsertTable(); if ( (rc>=3113) && (rc<=3115) ) return false; // 只要不是數據庫session的錯誤,程序就繼續。if (rc != 0) { logfile.Write("%s\n",strBuffer); continue; }}conn.commit(); File.CloseAndRemove(); //關閉文件指針,并刪除文件logfile.WriteEx("成功(total=%d,insert=%d,update=%d,invalid=%d)。\n",SURFDATA.totalcount,SURFDATA.insertcount,SURFDATA.updatecount,SURFDATA.invalidcount);return true; } //_shqx.h #ifndef _SHQX_H #define _SHQX_H #include "_public.h" #include "_ooci.h" struct st_stcode //全國氣象站點參數數據結構 {char provname[31]; // 省名稱char obtid[11]; // 站點代碼char cityname[31]; // 城市名double lat; // 緯度double lon; // 經度double height; // 海拔高度 }; struct st_surfdata //全國氣象站點分鐘觀測數據結構 {char obtid[11]; // 站點代碼char ddatetime[21]; // 數據時間:格式yyyy-mm-dd hh:mi:ss。int t; // 氣溫:單位,0.1攝氏度int p; // 氣壓:0.1百帕int u; // 相對濕度,0-100之間的值。int wd; // 風向,0-360之間的值。int wf; // 風速:單位0.1m/sint r; // 降雨量:0.1mmint vis; // 能見度:0.1米 }; struct st_signallog //分區信號數據結構 {char obtid[11];char ddatetime[20];char signalname[2];char signalcolor[2]; };//111111111111111111111111111111111111111111111111.CSURFDATA類 class CSURFDATA { public:int totalcount,insertcount,updatecount,invalidcount; // 記錄總數據、插入數、更新數、無效記錄數。struct st_surfdata m_stsurfdata;CSURFDATA(connection *conn,CLogFile *logfile); //在構造函數里傳進參數~CSURFDATA();void initdata(); // 數據初始化connection *m_conn; //在類里操作數據庫需要一個指針,m_conn,m_logfile這兩個成員需要給它們賦值CLogFile *m_logfile; //在類里寫日志,m_logfile->,類里不能再類實例化,所以定義為指針int iccount; //不能定義到成員函數里值會變sqlstatement stmtsel,stmtins,stmtupt;// 把用逗號分隔的記錄拆分到m_stsurfdata結構中。bool SplitBuffer(const char *strBuffer); // 把xml格式的記錄拆分到m_stsurfdata結構中。bool SplitBuffer1(const char *strBuffer);// 把m_stsurfdata結構中的值更新到T_SURFDATA表中。long InsertTable(); };//11111111111111111111111111111111111111111111112.CSIGNALLOG類 class CSIGNALLOG { public:int totalcount,insertcount,updatecount,invalidcount; // 記錄總數據、插入數、更新數、無效記錄數。struct st_signallog m_stsignallog;vector<struct st_signallog> vsignallog; // 容器存放一個文件的全部記錄CSIGNALLOG(connection *conn,CLogFile *logfile);~CSIGNALLOG();void initdata(); // 數據初始化connection *m_conn;CLogFile *m_logfile;int iccount;sqlstatement stmtsel,stmtins,stmtupt; bool SplitBuffer(const char *strBuffer); // 把記錄拆分到vsignallog容器中。 long InsertTable(); // 把vsignallog容器中的值更新到T_SIGNALDATA表中。 };//111111111111111111111111111111111111111113.把非結構化數據文件寫入oracle數據庫的表中 int FileToTable(connection *in_conn,CLogFile *in_logfile,char *in_tname,char *in_filename,char *in_ddatetime); #endif //_shqx.cpp #include "_shqx.h" //111111111111111111111111111111111111111111111111111111.CSURFDATA類 CSURFDATA::CSURFDATA(connection *conn,CLogFile *logfile) {initdata(); // 構造函數里傳入兩個指針變量并賦初值m_conn=conn; m_logfile=logfile; // 所以調用CSURFDATA(&conn,&logfile);就能完成初始化 } void CSURFDATA::initdata() {totalcount=insertcount=updatecount=invalidcount=0;m_conn=0; m_logfile=0;memset(&m_stsurfdata,0,sizeof(struct st_surfdata)); } CSURFDATA::~CSURFDATA() { }bool CSURFDATA::SplitBuffer(const char *strBuffer) //把用逗號分隔的記錄拆分到m_stsurfdata結構中 { totalcount++;memset(&m_stsurfdata,0,sizeof(struct st_surfdata));CCmdStr CmdStr;CmdStr.SplitToCmd(strBuffer,",",true);if (CmdStr.CmdCount()!=9) { invalidcount++; return false; }CmdStr.GetValue(0,m_stsurfdata.obtid,5); // 站點代碼CmdStr.GetValue(1,m_stsurfdata.ddatetime,19); // 數據時間:格式yyyy-mm-dd hh:mi:ss。double dtmp=0;CmdStr.GetValue(2,&dtmp); m_stsurfdata.t=(int)(dtmp*10); // 氣溫:單位,0.1攝氏度CmdStr.GetValue(3,&dtmp); m_stsurfdata.p=(int)(dtmp*10); // 氣壓:0.1百帕CmdStr.GetValue(4,&m_stsurfdata.u); // 相對濕度,0-100之間的值。CmdStr.GetValue(5,&m_stsurfdata.wd); // 風向,0-360之間的值。CmdStr.GetValue(6,&dtmp); m_stsurfdata.wf=(int)(dtmp*10); // 風速:單位0.1m/sCmdStr.GetValue(7,&dtmp); m_stsurfdata.r=(int)(dtmp*10); // 降雨量:0.1mmCmdStr.GetValue(8,&dtmp); m_stsurfdata.vis=(int)(dtmp*10); // 能見度:0.1米return true; }bool CSURFDATA::SplitBuffer1(const char *strBuffer) //把xml格式的記錄拆分到m_stsurfdata結構中 {totalcount++;memset(&m_stsurfdata,0,sizeof(struct st_surfdata));GetXMLBuffer(strBuffer,"obtid",m_stsurfdata.obtid,5); // 站點代碼GetXMLBuffer(strBuffer,"ddatetime",m_stsurfdata.ddatetime,19); // 數據時間:格式yyyy-mm-dd hh:mi:ss。double dtmp=0;GetXMLBuffer(strBuffer,"t",&dtmp); m_stsurfdata.t=(int)(dtmp*10); // 氣溫:單位,0.1攝氏度GetXMLBuffer(strBuffer,"p",&dtmp); m_stsurfdata.p=(int)(dtmp*10); // 氣壓:0.1百帕GetXMLBuffer(strBuffer,"u",&m_stsurfdata.u); // 相對濕度,0-100之間的值。GetXMLBuffer(strBuffer,"wd",&m_stsurfdata.wd); // 風向,0-360之間的值。GetXMLBuffer(strBuffer,"wf",&dtmp); m_stsurfdata.wf=(int)(dtmp*10); // 風速:單位0.1m/sGetXMLBuffer(strBuffer,"r",&dtmp); m_stsurfdata.r=(int)(dtmp*10); // 降雨量:0.1mmGetXMLBuffer(strBuffer,"vis",&dtmp); m_stsurfdata.vis=(int)(dtmp*10); // 能見度:0.1米return true; }long CSURFDATA::InsertTable() //把m_stsurfdata結構中的值更新到T_SURFDATA表中 {if (stmtsel.m_state==0){stmtsel.connect(m_conn);stmtsel.prepare("select count(*) from T_SURFDATA where obtid=:1 and ddatetime=to_date(:2,'yyyy-mm-dd hh24:mi:ss')");stmtsel.bindin( 1, m_stsurfdata.obtid,5);stmtsel.bindin( 2, m_stsurfdata.ddatetime,19);stmtsel.bindout(1,&iccount);}if (stmtins.m_state==0){stmtins.connect(m_conn);stmtins.prepare("insert into T_SURFDATA(obtid,ddatetime,t,p,u,wd,wf,r,vis,crttime,keyid) values(:1,to_date(:2,'yyyy-mm-dd hh24:mi:ss'),:3,:4,:5,:6,:7,:8,:9,sysdate,SEQ_SURFDATA.nextval)");stmtins.bindin( 1, m_stsurfdata.obtid,5);stmtins.bindin( 2, m_stsurfdata.ddatetime,19);stmtins.bindin( 3,&m_stsurfdata.t);stmtins.bindin( 4,&m_stsurfdata.p);stmtins.bindin( 5,&m_stsurfdata.u);stmtins.bindin( 6,&m_stsurfdata.wd);stmtins.bindin( 7,&m_stsurfdata.wf);stmtins.bindin( 8,&m_stsurfdata.r);stmtins.bindin( 9,&m_stsurfdata.vis);}if (stmtupt.m_state==0){stmtupt.connect(m_conn);stmtupt.prepare("update T_SURFDATA set t=:1,p=:2,u=:3,wd=:4,wf=:5,r=:6,vis=:7 where obtid=:8 and ddatetime=to_date(:2,'yyyy-mm-dd hh24:mi:ss')");stmtupt.bindin( 1,&m_stsurfdata.t);stmtupt.bindin( 2,&m_stsurfdata.p);stmtupt.bindin( 3,&m_stsurfdata.u);stmtupt.bindin( 4,&m_stsurfdata.wd);stmtupt.bindin( 5,&m_stsurfdata.wf);stmtupt.bindin( 6,&m_stsurfdata.r);stmtupt.bindin( 7,&m_stsurfdata.vis);stmtupt.bindin( 8, m_stsurfdata.obtid,5);stmtupt.bindin( 9, m_stsurfdata.ddatetime,19);}if (stmtsel.execute() != 0){invalidcount++; m_logfile->Write("stmtsel.execute() failed.\n%s\n%s\n",stmtsel.m_sql,stmtsel.m_cda.message); return stmtsel.m_cda.rc;} iccount=0;stmtsel.next();if (iccount>0) {if (stmtupt.execute() != 0) //執行更新的SQL語句,一定要判斷返回值,0-成功,其它-失敗。{invalidcount++; m_logfile->Write("stmtupt.execute() failed.\n%s\n%s\n",stmtupt.m_sql,stmtupt.m_cda.message);return stmtupt.m_cda.rc;}updatecount++;}else{ if (stmtins.execute() != 0) // 執行插入的SQL語句,一定要判斷返回值,0-成功,其它-失敗。{invalidcount++; m_logfile->Write("stmtins.execute() failed.\n%s\n%s\n",stmtins.m_sql,stmtins.m_cda.message);return stmtins.m_cda.rc;}insertcount++;}return 0; }//11111111111111111111111111111111111111111111111111111111111112.CSIGNALLOG類 CSIGNALLOG::CSIGNALLOG(connection *conn,CLogFile *logfile) {initdata();m_conn=conn; m_logfile=logfile; } void CSIGNALLOG::initdata() {totalcount=insertcount=updatecount=invalidcount=0;m_conn=0; m_logfile=0;memset(&m_stsignallog,0,sizeof(struct st_signallog));vsignallog.clear(); } CSIGNALLOG::~CSIGNALLOG() { }bool CSIGNALLOG::SplitBuffer(const char *strBuffer) //把記錄拆分到vsignallog容器中 {vsignallog.clear();memset(&m_stsignallog,0,sizeof(struct st_signallog));CCmdStr CmdStr; CmdStr.SplitToCmd(strBuffer," ",true);if (CmdStr.CmdCount()<3) { invalidcount++; return false; }CmdStr.GetValue(0,m_stsignallog.ddatetime,12); //數據時間:格式yyyymmddhh24mistrcat(m_stsignallog.ddatetime,"00");AddTime(m_stsignallog.ddatetime,m_stsignallog.ddatetime,8*60*60,"yyyy-mm-dd hh24:mi:ss");CmdStr.GetValue(1,m_stsignallog.obtid,4); //站點代碼char strtemp[11];for (int ii=3;ii<=CmdStr.CmdCount();ii++){ // 201809142353 GWTE A3000 ....= memset(strtemp,0,sizeof(strtemp));CmdStr.GetValue(ii-1,strtemp,5); // m_stsignallog.signalname[0]表示字符串中第一個字符m_stsignallog.signalname[0]=strtemp[0]; //strtemp[0]就是Am_stsignallog.signalcolor[0]=strtemp[1]; //strtemp[1]就是3vsignallog.push_back(m_stsignallog);totalcount++;}return true; }long CSIGNALLOG::InsertTable() //把vsignallog容器中的值更新到T_SIGNALDATA表中 { //可能會返回stmtupt.m_cda.rc,所以用longif (stmtsel.m_state==0){stmtsel.connect(m_conn);// 如下這個表的主鍵有三個字段stmtsel.prepare("select count(*) from T_SIGNALLOG where obtid=:1 and ddatetime=to_date(:2,'yyyy-mm-dd hh24:mi:ss') and signalname=:3");stmtsel.bindin( 1, m_stsignallog.obtid,4);stmtsel.bindin( 2, m_stsignallog.ddatetime,19);stmtsel.bindin( 3, m_stsignallog.signalname,1);stmtsel.bindout(1,&iccount);}if (stmtins.m_state==0){stmtins.connect(m_conn);stmtins.prepare("insert into T_SIGNALLOG(obtid,ddatetime,signalname,signalcolor,crttime,keyid) values(:1,to_date(:2,'yyyy-mm-dd hh24:mi:ss'),:3,:4,sysdate,SEQ_SIGNALLOG.nextval)");stmtins.bindin( 1, m_stsignallog.obtid,4);stmtins.bindin( 2, m_stsignallog.ddatetime,19);stmtins.bindin( 3, m_stsignallog.signalname,1);stmtins.bindin( 4, m_stsignallog.signalcolor,1);}if (stmtupt.m_state==0){stmtupt.connect(m_conn);stmtupt.prepare("update T_SIGNALLOG set signalcolor=:1 where obtid=:2 and ddatetime=to_date(:3,'yyyy-mm-dd hh24:mi:ss') and signalname=:4");stmtupt.bindin( 1, m_stsignallog.signalcolor,1);stmtupt.bindin( 2, m_stsignallog.obtid,4);stmtupt.bindin( 3, m_stsignallog.ddatetime,19);stmtupt.bindin( 4, m_stsignallog.signalname,1);}for (int ii=0;ii<vsignallog.size();ii++){ //把容器里的值拷出來memcpy(&m_stsignallog,&vsignallog[ii],sizeof(struct st_signallog));m_logfile->Write("%s,%s,%s,%s\n",m_stsignallog.obtid,m_stsignallog.ddatetime,m_stsignallog.signalname,m_stsignallog.signalcolor);if (stmtsel.execute() != 0){invalidcount++; m_logfile->Write("stmtsel.execute() failed.\n%s\n%s\n",stmtsel.m_sql,stmtsel.m_cda.message); return stmtsel.m_cda.rc;} iccount=0;stmtsel.next(); if (iccount>0) { if (stmtupt.execute() != 0) //執行更新的SQL語句,一定要判斷返回值,0-成功,其它-失敗。{invalidcount++; m_logfile->Write("stmtupt.execute() failed.\n%s\n%s\n",stmtupt.m_sql,stmtupt.m_cda.message);return stmtupt.m_cda.rc;}updatecount++;}else{ if (stmtins.execute() != 0) //執行插入的SQL語句,一定要判斷返回值,0-成功,其它-失敗。{invalidcount++; m_logfile->Write("stmtins.execute() failed.\n%s\n%s\n",stmtins.m_sql,stmtins.m_cda.message);return stmtins.m_cda.rc;}insertcount++;}}return 0; }//1111111111111111111111111111111111111111111111113.把非結構化數據文件寫入oracle數據庫的表中 int FileToTable(connection *in_conn,CLogFile *in_logfile,char *in_tname,char *in_filename,char *in_ddatetime) {sqlstatement stmt(in_conn); int icount=0; //判斷文件記錄在表中是否已存在stmt.prepare("select count(*) from %s where filename=:1",in_tname);stmt.bindin(1,in_filename,300);stmt.bindout(1,&icount);if (stmt.execute() != 0){in_logfile->Write("FileToTable() failed.%s\n%s\n",stmt.m_sql,stmt.m_cda.message); return stmt.m_cda.rc;}stmt.next(); if (icount>0) return 0; //如果記錄已存在,直接返回0-成功。 //11111111111111111111111111111111111111111111111111111111111111111int ifilesize=FileSize(in_filename); //把文件信息插入表中。stmt.prepare("\insert into %s(filename,ddatetime,filesize,filecontent,crttime,keyid)\values(:1,to_date(:2,'yyyymmddhh24miss'),:3,empty_blob(),sysdate,SEQ_%s.nextval)",\in_tname,in_tname+2); stmt.bindin(1,in_filename,300); //empty_blob()可以換成null試試,文件內容可以不弄到blob字段stmt.bindin(2,in_ddatetime,14);stmt.bindin(3,&ifilesize); if (stmt.execute() != 0){in_logfile->Write("FileToTable() failed.%s\n%s\n",stmt.m_sql,stmt.m_cda.message); return stmt.m_cda.rc;} //111111111111111111111111111111111111111111111111111111111111111stmt.prepare("select filecontent from %s where filename=:1 for update",in_tname);stmt.bindin(1,in_filename,300); //把文件內容更新到BLOB字段中。stmt.bindblob();if (stmt.execute() != 0){in_logfile->Write("FileToTable() failed.%s\n%s\n",stmt.m_sql,stmt.m_cda.message); return stmt.m_cda.rc;} if (stmt.next() != 0) return -1; //獲取一條記錄,一定要判斷返回值,0-成功,1403-無記錄,其它-失敗 if (stmt.filetolob((char *)in_filename) != 0) { //把磁盤文件pic_in.jpg的內容寫入BLOB字段,一定要判斷返回值,0-成功,其它-失敗。in_logfile->Write("FileToTable() stmt.filetolob() failed.\n%s\n",stmt.m_cda.message); return -1;} in_conn->commit(); //圖片數據大,一個文件提交一次return 0; }

2.分區/表空間/網絡/主鍵/錯誤優化:chown -R 用戶

用文件夾代替實際分區。root用戶mkdir htidc log data,htidc分public和shqx兩個文件夾。如下授權給Oracle用戶。

下面為改進makefile,PUBINCL中-I指定頭文件_public.h,_ftp.h等等搜索目錄,自己去找頭文件。冒號前后整個一行等于下行編譯命令。冒號后面文件有更新(必須要有一個同名cpp文件),則重新編譯(只是有這個重編譯功能),一般后面不放_ooci…因為穩定不需要改動。

# oracle頭文件路徑 ORAINCL = -I$(ORACLE_HOME)/rdbms/public # oracle庫文件路徑 ORALIB = -L$(ORACLE_HOME)/lib -L. # oracle的oci庫 ORALIBS = -lclntsh# 通用框架頭文件路徑 PUBINCL = -I/htidc/public/c # 通用框架庫文件路徑 PUBCPP = /htidc/public/c/_public.cpp FTPCPP = /htidc/public/c/_ftp.cpp OCICPP = /htidc/public/c/_ooci.cppCC=g++ # CFLAGS = -O2 # CFLAGS = -O2 -Wall CFLAGS = -g -Wno-write-strings -Wno-unused-variableall: crtsurfdata psurfdata psignallog wgetrain24\wgettemp24 pzhrain24filecrtsurfdata:crtsurfdata.cpp _shqx.h _shqx.cpp$(CC) $(CFLAGS) -o crtsurfdata crtsurfdata.cpp $(ORAINCL) $(ORALIB) $(ORALIBS) $(PUBINCL) $(PUBCPP) $(OCICPP) _shqx.cpp -lm -lccp -f crtsurfdata ../bin/.psurfdata: psurfdata.cpp _shqx.h _shqx.cpp$(CC) $(CFLAGS) -o psurfdata psurfdata.cpp $(ORAINCL) $(ORALIB) $(ORALIBS) $(PUBINCL) $(PUBCPP) $(OCICPP) _shqx.cpp -lm -lccp -f psurfdata ../bin/.pzhrain24file: pzhrain24file.cpp _shqx.h _shqx.cpp$(CC) $(CFLAGS) -o pzhrain24file pzhrain24file.cpp $(ORAINCL) $(ORALIB) $(ORALIBS) $(PUBINCL) $(PUBCPP) $(OCICPP) _shqx.cpp -lm -lccp -f pzhrain24file ../bin/.psignallog: psignallog.cpp _shqx.h _shqx.cpp$(CC) $(CFLAGS) -o psignallog psignallog.cpp $(ORAINCL) $(ORALIB) $(ORALIBS) $(PUBINCL) $(PUBCPP) $(OCICPP) _shqx.cpp -lm -lccp -f psignallog ../bin/.wgetrain24: wgetrain24.cpp $(CC) $(CFLAGS) -o wgetrain24 wgetrain24.cpp $(PUBINCL) $(PUBCPP) -lm -lccp -f wgetrain24 ../bin/.wgettemp24: wgetrain24.cpp $(CC) $(CFLAGS) -o wgettemp24 wgettemp24.cpp $(PUBINCL) $(PUBCPP) -lm -lccp -f wgettemp24 ../bin/.clean:rm -rf crtsurfdata psurfdata psignallog wgetrain24rm -rf wgettemp24 pzhrain24file

切換用戶如下目錄里的*.sh都會執行,和oracle名字無關。如上makefile中不需要數據庫就不要包含路徑。


如下crttable.sql里最后不寫exit;的話下行登錄sqlplus不退出,每行sql語句需要分號結尾。如下.sql文件里一般放一些系統初始化sql語句如建表,839行insert站點參數。snorcl11g_198是連遠程該服務名指定的數據庫,不加就連本地數據庫。

oracle安裝好后會自動創建幾個表空間,表空間是用來存放數據庫對象的一個空間,類似分區,如下是查看oracle表空間大小的sql(登錄再執行)。

SELECT a.tablespace_name, --表空間名 total, --表空間大小 free, --表空間剩余大小 (total-free), --表空間使用大小 Round((total-free)/total,4)*100 --使用率 FROM (SELECT tablespace_name,Sum(bytes) free FROM DBA_FREE_SPACE GROUP BY tablespace_name) a, (SELECT tablespace_name,Sum(bytes) total FROM DBA_DATA_FILES GROUP BY tablespace_name)b WHERE a.tablespace_name=b.tablespace_name;

SYSTEM表空間(創建數據庫時創建的)相當于win系統C盤,USERS表空間相當于D盤放數據,UNDOTBS1表空間相當于事務緩沖區,SYSAUX相當于SYSTEM表空間輔助分區。

創建新用戶并指定該用戶缺省表空間為users,vi creuser.sql。

--把數據庫用戶允許錯誤重試的次數改為不限制 alter profile DEFAULT limit FAILED_LOGIN_ATTEMPTS UNLIMITED; alter profile DEFAULT limit PASSWORD_LIFE_TIME UNLIMITED;-- 上海氣象數據中心的主用戶,shqx為用戶名,pwdidc為密碼,default tablespace users默認user表空間 -- drop user shqx cascade; create user shqx profile default identified by pwdidc default tablespace users account unlock; grant connect to shqx; grant dba to shqx;exit;

下面是以超級用戶登錄,/ 指不用任何密碼,不能遠程登錄只能登錄本機且裝有數據庫。

如下是網絡/主鍵/錯誤優化 :入庫時查看日志,時間太長,truncate刪除表記錄繼續入庫時間測試。

如上連本機數據庫1秒之內處理完,下面方式和不帶服務名一樣也不通過網絡設備,日志都為1秒左右。

以上說明第一點:網絡對性能影響大,下面是第二點:主鍵沖突(數據庫已存在主鍵即有記錄了,沒有truncate)。


下面為改善:先去表中查下有沒有這條記錄存在,有的話就不插入insert入庫,m_cda.rc報個錯,這樣能提高速度解決主鍵沖突。以下在psurfdata.cpp中,2個主鍵查詢。bindin行,bindout列。

如下出現rc=1重復記錄即主鍵沖突就不管,不等于1日志寫錯誤信息并直接return false。

如上行出現問題logfile.write("stmtins.execute() fail…最后直接return false(-1)退出整個大循環,如下所示。

所以將return false改為continue(這個小循環下面不執行,重新從這個小循環開頭執行),break(跳出小循環往后執行,不重小循環開頭開始)。





如下oracle類似的錯誤代碼是連在一起的,以下兩個錯必須退出(return false),其他的錯沒必要退出。

3.歷史文件/表數據清理:生成測試數據后去采集,采集后未刪除文件,因為數據不只一個系統用

一般兩個需求:1.刪除哪個時間點前文件(常用),2.只保留多少個文件(一般刪除數據庫歸檔日志)。
1.以下是刪除多長時間之前文件(生成或采集的.txt數據文件)。

//這個程序不寫日志,deletefiles.cpp #include "_public.h" void EXIT(int sig); void _help(char *argv[]); //顯示程序的幫助,argv[]未指定字符串長度int main(int argc,char *argv[]) { //最后一個參數可有可無,如下argv是變量相當于&argv或&argv[0]if ( (argc != 3) && (argc != 4) ) { _help(argv); return -1; } //CloseIOAndSignal(); // 關閉全部的信號和輸入輸出,可以先//了,因為調試時要輸出信息// 處理程序退出的信號設置信號,在shell狀態下可用 "kill + 進程號" 正常終止些進程,但請不要用 "kill -9 +進程號" 強行終止signal(SIGINT,EXIT); signal(SIGTERM,EXIT); char strPathName[201]; //strPathName:/data/shqx/ftp/surfdata,dDayOut,strTimeOutdouble dDayOut=0;memset(strPathName,0,sizeof(strPathName));strcpy(strPathName,argv[1]); dDayOut=atof(argv[2]); char strTimeOut[21];LocalTime(strTimeOut,"yyyy-mm-dd hh24:mi:ss",0-(int)(dDayOut*24*60*60)); //獲取需要刪的時間點存入strTimeOut中CDir Dir; //strMatch:\"*.TXT,*.CSV\"char strMatch[50]; memset(strMatch,0,sizeof(strMatch));if (argc==3) strcpy(strMatch,"*"); //如果只有3個參數,全刪else strcpy(strMatch,argv[3]); //11111111111111111111111111111111111111111111111打開目錄,讀取文件,包括它的子目錄if (Dir.OpenDir(strPathName,strMatch,10000,true,false) == false){printf("Dir.OpenDir(%s) failed.\n",strPathName); return -1;}char strLocalTime[21];while (Dir.ReadDir() == true){if (strcmp(Dir.m_ModifyTime,strTimeOut) > 0) continue; //m_ModifyTime大于strTimeOut的話就不用刪除printf("delete %s ok.\n",Dir.m_FullFileName);REMOVE(Dir.m_FullFileName); //C語言提供了remove函數,在_public.cpp中重寫了REMOVE,刪不了多試幾次}return 0; } void EXIT(int sig) {printf("程序退出,sig=%d\n\n",sig);exit(0); }//111111111111111111111111111111111111111111111顯示程序的幫助 void _help(char *argv[]) {printf("\n");printf("Using:/htidc/public/bin/deletefiles pathname dayout [matchstr]\n");printf("Sample:/htidc/public/bin/deletefiles /data/shqx/ftp/surfdata 0.1 \"*.TXT,*.CSV\"\n\n");// dayout單位是天,如果要清除30分鐘前數據,則dayout填30/(24*60),如上0.1*24*60=144分鐘,就是當前時間往前推144分鐘printf("本程序是數據中心的公共功能模塊,用于刪除指定目錄下的歷史文件。\n");printf("pathname 待清理的目錄名,包括這個目錄下的各級子目錄。\n");printf("dayout 文件保留天數,單位是天,可以用小數。\n");printf("matchstr 待清理文件名的匹配規則,這是一個可選參數,可以匹配多種類型的文件,中間用逗號分隔,最好用雙引號包含起來。\n\n"); }

deletefiles.cpp不用自身調度用crontab -e,最后一個參數可不寫,寫了必須加雙引號。


下面改進,寫日志后清空兩個容器,在crtsurfdata.cpp中。


2.下面是第二個需求,保留多少文件。

//刪除數據庫的歸檔日志,deletearchive.cpp #include "_public.h" int main(int argc,char *argv[]) {char strPathName[201];int uSaveCount=0;if (argc != 3){printf("\n");printf("Using:/htidc/htidc/bin/deletearchive pathname savecount\n\n");printf("Example:/htidc/htidc/bin/procctl 300 /htidc/htidc/bin/deletearchive /oracle/archive 20\n\n");printf("本程序讀取目定pathname錄下的文件信息,并按時間降序,只保留最近savecount個文件,其它的都刪除掉。\n");printf("本程序主要用于刪除oracle數據庫的歸檔日志文件。\n");printf("本程序不寫日志文件,也不會在屏幕上輸出任何信息。\n");printf("本程序調用/bin/ls -lt pathname獲取歸檔日志文件信息。\n");printf("本程序可以手工運行,也可以由procctl調度。\n\n\n");printf("啟用oracle歸檔日志的相關命令如下:\n");printf("sqlplus /nolog\n");printf("connect / as sysdba;\n");printf("alter system set log_archive_dest_1='location=/home/oracle/oradata/EJETDB/archive';\n");printf("shutdown immediate;\n");printf("startup mount;\n");printf("alter database archivelog;\n");printf("alter database open;\n");printf("alter system switch logfile;\n\n\n");return -1;}memset(strPathName,0,sizeof(strPathName));strcpy(strPathName,argv[1]);uSaveCount=atoi(argv[2]);// 關閉全部的信號和輸入輸出// 設置信號,在shell狀態下可用 "kill + 進程號" 正常終止些進程// 但請不要用 "kill -9 +進程號" 強行終止CloseIOAndSignal(); FILE *fp=NULL; //fp指向ls -l的輸出的內容char strCmd[301]; //strPathName:/oracle/archivememset(strCmd,0,sizeof(strCmd)); sprintf(strCmd,"/bin/ls -lt %s",strPathName); if ( (fp=popen(strCmd,"r")) == NULL ){printf("popen %s failed.\n",strCmd); return -1;}CCmdStr CmdStr;int uFetchedCount=0;char strBuffer[1024],strFullFileName[201];while (TRUE){memset(strBuffer,0,sizeof(strBuffer));if (FGETS(strBuffer,2000,fp) == FALSE) break; uFetchedCount++;if (uFetchedCount <= uSaveCount + 1 ) continue;UpdateStr(strBuffer," "," "); // Trim(strBuffer);CmdStr.SplitToCmd(strBuffer," ");memset(strBuffer,0,sizeof(strBuffer));CmdStr.GetValue(CmdStr.CmdCount()-1,strBuffer,200);memset(strFullFileName,0,sizeof(strFullFileName));snprintf(strFullFileName,200,"%s/%s",strPathName,strBuffer);REMOVE(strFullFileName);}pclose(fp);return 0; }

3.下面為工具程序用于清理表中數據。

//deletetables.cpp #include "_public.h" #include "_ooci.h" char logfilename[301]; char connstr[101]; char tname[51]; char where[1024]; char hourstr[101]; char localhour[21]; connection conn; CLogFile logfile; void EXIT(int sig); void _help(char *argv[]); // 顯示程序的幫助 int maxcounts=500; // 每批刪除的記錄數 bool _deletetables(); int main(int argc,char *argv[]) {if (argc != 2) { _help(argv); return -1; }memset(logfilename,0,sizeof(logfilename));memset(connstr,0,sizeof(connstr));memset(tname,0,sizeof(tname));memset(where,0,sizeof(where));memset(hourstr,0,sizeof(hourstr));GetXMLBuffer(argv[1],"logfilename",logfilename,300);GetXMLBuffer(argv[1],"connstr",connstr,100);GetXMLBuffer(argv[1],"tname",tname,50);GetXMLBuffer(argv[1],"where",where,1000);GetXMLBuffer(argv[1],"hourstr",hourstr,2000);//上面為獲取參數放入一開始定義的幾個char字符串中,下面是判斷參數的合法性if (strlen(logfilename) == 0) { printf("logfilename is null.\n"); return -1; }if (strlen(connstr) == 0) { printf("connstr is null.\n"); return -1; }if (strlen(tname) == 0) { printf("tname is null.\n"); return -1; }if (strlen(where) == 1) { printf("where is null.\n"); return -1; }if (strlen(hourstr) == 0) { printf("hourstr is null.\n"); return -1; }CloseIOAndSignal();//關閉全部的信號和輸入輸出signal(SIGINT,EXIT); signal(SIGTERM,EXIT);//處理程序退出的信號if (logfile.Open(logfilename,"a+") == FALSE){printf("logfile.Open(%s) failed.\n",logfilename); return -1;}while (true) //自身調度,不用crontab{ memset(localhour,0,sizeof(localhour)); //判斷當前時間是否在啟動時間之內LocalTime(localhour,"hh24");if (strstr(hourstr,localhour)==0) { sleep(60); continue; }if (conn.connecttodb(connstr,"Simplified Chinese_China.ZHS16GBK") != 0){logfile.Write("connect database %s failed.\n",connstr); sleep(60); continue; }logfile.Write("delete table %s.\n",tname);if (_deletetables() == false) logfile.Write("deletetables failed.\n"); conn.disconnect();sleep(60); }return 0; } void EXIT(int sig) {printf("程序退出,sig=%d\n\n",sig);exit(0); }//11111111111111111111111111111111111111111顯示程序的幫助 void _help(char *argv[]) {printf("\nUsing:/oracle/htidc/shqx/bin/deletetables \"<logfilename>/oracle/log/shqx/deletetables_SURFDATA.log</logfilename><connstr>shqx/pwdidc@snorcl11g_188</connstr><tname>T_SURFDATA</tname><where>where ddatetime<sysdate</where><hourstr>14,15,16</hourstr>\"\n\n");printf("這是一個工具程序,用于清理表中的數據。\n");printf("<logfilename>/log/shqx/deletetables_ALLAWSDATA.log</logfilename> 本程序運行日志文件名。\n");printf("<connstr>szidc/pwdidc@SZQX_10.153.97.251</connstr> 目的數據庫的連接參數。\n");printf("<tname>T_ALLAWSDATA</tname> 待清理的表名。\n");printf("<where>where ddatetime<sysdate-5</where> 待清理數據的條件。\n");printf("<hourstr>01,02,03</hourstr> 本程序啟動的時次,小時,時次之間用半角的逗號分隔開。\n\n");return; }bool _deletetables() {int ccount=0;char strrowid[51],strrowidn[maxcounts][51];//sqlstatement stmt;//stmt.prepare("delete from %s %s",tname,where);//stmt.execute();//conn.commit();//如上這么寫不行,如果表要刪除的數據很多,delete from....這語句跑不動,不能讓Oracle產生大事務//stmt.prepare("delete from %s %s" and rownum<10000",tname,where);//如上一次刪除10000條,這種方法效率不高,假設where這個條件帶的參數查這個數據時,假設這字段沒有索引,那這sql執行時間相當長//111111111111111111111111111111111111111111111111獲取符合條件的記錄的rowidsqlstatement selstmt(&conn);selstmt.prepare("select rowid from %s %s",tname,where);selstmt.bindout(1, strrowid,50);if (selstmt.execute() != 0){logfile.Write("%s failed.\n%s\n",selstmt.m_sql,selstmt.m_cda.message); return false;}//1111111111111111111111111111111111111111生成刪除數據的SQL語句,一次刪除maxcounts條記錄int ii=0;char strDeleteSQL[10241];memset(strDeleteSQL,0,sizeof(strDeleteSQL));sprintf(strDeleteSQL,"delete from %s where rowid in (",tname);char strtemp[11];for (ii=0; ii<maxcounts; ii++){memset(strtemp,0,sizeof(strtemp));if (ii==0) sprintf(strtemp,":%d",ii+1); //:號是sql綁定變量if (ii >0) sprintf(strtemp,",:%d",ii+1);strcat(strDeleteSQL,strtemp);}strcat(strDeleteSQL,")");sqlstatement delstmt(&conn);delstmt.prepare(strDeleteSQL);for (ii=0; ii<maxcounts; ii++){delstmt.bindin(ii+1,strrowidn[ii],50);}while (true){memset(strrowid,0,sizeof(strrowid));if (selstmt.next() != 0) break;strcpy(strrowidn[ccount],strrowid);ccount++; //logfile.Write("%s\n",delstmt.m_sql);if (ccount == maxcounts){if (delstmt.execute() != 0){logfile.Write("delete %s failed.\n%s\n",tname,delstmt.m_cda.message); return false;}conn.commit();memset(strrowidn,0,sizeof(strrowidn));ccount=0;}//1111111111111111111111111111111111111刪除的記錄數到10000時提交一次事務,不讓數據庫產生大事務if (fmod(selstmt.m_cda.rpc,10000) < 1){logfile.Write("rows %d deleted.\n",selstmt.m_cda.rpc);//表里數據可能會非常多,幾個小時都刪不完,只要不在啟動時間內就不干了,明天再說//干完活了,刪除完記錄了再判斷當前時間是否在啟動時間之內 memset(localhour,0,sizeof(localhour));LocalTime(localhour,"hh24");if (strstr(hourstr,localhour)==0) return true;}}//11111111111111111111111111111111111在以上循環處理的時候,如果不足maxcounts,就在這里處理for (ii=0; ii<ccount; ii++){delstmt.prepare("delete from %s where rowid=:1",tname);//剩下的一次刪一條delstmt.bindin(1,strrowidn[ii],50); //logfile.Write("%s\n",delstmt.m_sql);if (delstmt.execute() != 0){if (delstmt.m_cda.rc != 1){logfile.Write("delete %s failed.\n%s\n",tname,delstmt.m_cda.message); return false;}}}logfile.Write("rows %d deleted.completed.\n",selstmt.m_cda.rpc);conn.commit();return true; }

如下0.7天前就是0.7*24=16.8,即16.8個小時前(1小時前大約0.04天前)。

vi /log/shqx/deletetables_…log(如上文件名)如下。

執行一條sql語句就會刪除500條,最后不到500,一條一條刪日志如下。


4.站點參數建表入表/PowerDesigner/主外鍵:g/./s//./g,多表查詢

vi crttable.sql,T_OBTCODE這個表沒必要創建索引,因為數據量很少。

drop table T_OBTCODE; create table T_OBTCODE (obtid char(5),cityname varchar2(30),provname varchar2(30),lat number(5,2),lon number(5,2),height number(8,2),rsts number(1), --狀態:1-啟用,2-禁用,3-故障primary key(obtid) );




如下圖整列(列操作)插入'和,1);,技巧:alt+shift+鼠標拖動右邊滾條到最低+鼠標點擊最低。如下取消勾選全詞匹配。


vi T_OBTCODE.sql將上面列操作實現的sql全部復制進去。




vi T_OBTCODE.sql,改完后。

PowerDesigner安裝鏈接:https://pan.baidu.com/s/1TR5tT6qh7G4CVPDFxZ7_wg 提取碼:vx9m 。

將上面漢化…文件夾里文件全復制替換到下面安裝目錄中(可改變安裝目錄)。

上海氣象.pdm文件:鏈接:https://pan.baidu.com/s/1zkzGDQuggwZhd1oNobeVqQ 提取碼:0ad6 。

P:主鍵,F:外鍵,M:勾上不允許為空。

下面為保存并生成.sql文件。

如下還要將雙引號替換為空,不同數據庫生成不同sql語句,如下修改設置就不生成雙引號了。

1.下面為主鍵命名,主鍵在Columns里p字段已指定。

如下是主鍵的另一種寫法。

2.下面為創建索引。


3.下面為創建表空間,如下將表存入名為USERS的表空間。

如下將索引存入名為INDEXS表空間。

如下主鍵就是索引也有這些參數也扔入INDEXS表空間。

4.字段值附上約束條件,如果復制其他表記得刪除字段值約束條件。

5.如下U是unique index,記錄序號即keyid是唯一約束,第三行是數據時間。

下面是創建序列。

ctrl+G生成.sql文件,注意主鍵名不要重復,雙引號替換為空。復制剛生成的.sql文件內容到crttable.sql中,執行如下命令必須其他窗口SQL>exit

1.創建主外鍵約束,站點代碼在如下左表里是主鍵,在右表是外鍵,命名為:FK_子表_父表。在SURFDATA(右)表上建立了外鍵約束,如下圖標是創建主外鍵連接線。如下<pk,fk>,pk主鍵勾上p字段,fk外鍵勾上f字段。

如下 多從外 引出。


2.下面演示出錯情況,建立這種約束后有什么效果,雙擊主外鍵約束線。ctrl+G生成crebas.sql文件,復制到crttable.sql。

:g/"/s// /g

3.如果表被鎖住(未提交)資源忙超時,dbshut關數據庫再開。左邊updata只有none和restrict兩個選項。如下兩個都為restrict為父表刪不了子表已經在用的記錄。


將上面復制修改到下面crttable.sql中,之前有生成腳本寫入過,這里只要修改下最后就行。

如下刪除59493等等其他的可以刪除,但59287不行,因為已經在查詢中用了,所以如下為上面兩個Restrict效果。

4.父表刪一條記錄,子表和它相關的記錄就被刪。

preview將引號換為空格,復制粘貼到SQL>(先登錄SQL),不用重新建表。

如下是多表查詢,想用一個sql語句查出數據同時也將站點名稱obtname也查出來。

總結

以上是生活随笔為你收集整理的【C/C++11】天气APP:txt/xml文件处理入库(psurfdata.cpp,_shqx.h),数据结构设计(PowerDesigner)的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。

人人澡人人舔 | av丝袜美腿 | 亚一亚二国产专区 | 日韩av成人在线 | 亚洲国产影院av久久久久 | 国产午夜一区二区 | 亚洲精品一区二区三区新线路 | 成年人在线免费视频观看 | 丁香六月欧美 | 在线午夜av | 999久久久免费视频 午夜国产在线观看 | 日日草天天草 | 国产精品国产自产拍高清av | 97人人模人人爽人人少妇 | 丁香六月婷婷综合 | 日韩理论 | 久久视频二区 | 香蕉久久久久久久 | 久久久精品国产一区二区 | 日韩系列在线 | 国外成人在线视频网站 | 亚洲日本三级 | 五月婷婷六月丁香 | 午夜久久久久久久久久久 | 久久久久久国产精品久久 | 久久99热精品这里久久精品 | av免费看av | 一区二区高清在线 | 91麻豆精品国产午夜天堂 | 精品久久一区二区三区 | 免费高清在线观看电视网站 | 久久视频 | 91亚洲精品久久久中文字幕 | av在线免费播放 | 五月婷婷,六月丁香 | 九九热在线播放 | 久久精品国产精品 | aaa日本高清在线播放免费观看 | 91久久影院| 麻豆91精品91久久久 | 91黄在线看| 国产福利网站 | 亚洲国产中文字幕在线观看 | 免费久久99精品国产婷婷六月 | 99久热在线精品视频成人一区 | 人人插人人澡 | 国产精品久久久久永久免费观看 | 黄色成人91| 午夜精品福利一区二区三区蜜桃 | 国产精品高潮在线观看 | 国产理论免费 | 成人中文字幕在线 | 视频成人永久免费视频 | 日韩免费播放 | 国产剧情在线一区 | 96精品在线| 亚洲伦理中文字幕 | 久99久在线 | 国产精品第7页 | 久久免费一级片 | 国产日产精品一区二区三区四区的观看方式 | 中文字幕在线乱 | 激情视频国产 | 探花视频在线观看 | 一区二区三区精品久久久 | 精品国产伦一区二区三区观看体验 | 超碰日韩 | 偷拍精偷拍精品欧洲亚洲网站 | 色网站黄 | 国产精品片 | 操操操日日日干干干 | 天天色天 | 免费高清在线观看电视网站 | 国产精品福利一区 | 又污又黄的网站 | av一级免费 | 韩日在线一区 | 成人午夜网址 | 夜夜躁狠狠躁 | av黄色大片| 国内久久久久 | 午夜视频福利 | 日韩精品一区二区三区丰满 | 五月婷婷狠狠 | 久久精品免费电影 | 日韩欧美高清在线 | 免费网站黄色 | 麻豆91精品91久久久 | 久久在线免费观看 | 免费观看一级成人毛片 | 日韩综合视频在线观看 | 国产一区二区播放 | av永久网址 | 国内精品美女在线观看 | 精品一区二三区 | av福利在线播放 | 亚洲人精品午夜 | 国产69精品久久久久99尤 | 成人av在线网| 91精品国产福利在线观看 | 偷拍久久久 | 精品在线观看一区二区三区 | 久久久久久久久爱 | 狠狠干狠狠色 | 一区二区三区免费播放 | 99久久精品免费看 | 精品久久久久久久久亚洲 | www夜夜操com | 成片免费观看视频 | 欧美在线一级片 | 开心激情久久 | 成人a毛片 | 色偷偷人人澡久久超碰69 | 亚洲日韩中文字幕在线播放 | 欧美性网站 | 在线激情影院一区 | 一区二区 不卡 | 国产精品第72页 | 蜜臀aⅴ精品一区二区三区 久久视屏网 | 国产一区高清在线 | 色a在线观看 | 国产精品入口麻豆 | 婷婷爱五月天 | 成人毛片网 | 久久99久久99久久 | 黄色小说网站在线 | 国内少妇自拍视频一区 | 亚洲一二三区精品 | 黄色一级在线视频 | 色999五月色| 黄色大片视频网站 | 日韩网页 | 日韩精品中文字幕在线 | 久久综合久久88 | 亚洲成av人片在线观看无 | 黄色大片免费播放 | 欧美一级爽 | 国产精品理论视频 | 中文字幕韩在线第一页 | 免费视频一区二区 | 又黄又爽又刺激的视频 | 天天做天天爱天天综合网 | 日韩在线国产精品 | 亚洲精品乱码久久久久久久久久 | 在线直播av| 国产黄色片免费观看 | 91在线精品观看 | 国产一级不卡视频 | 国产福利精品视频 | 久久久久久99精品 | 在线观看免费高清视频大全追剧 | 伊人婷婷激情 | www.国产高清 | 免费在线观看一区二区三区 | 黄色av电影在线 | 区一区二区三在线观看 | 综合网av| 精品毛片久久久久久 | 在线免费亚洲 | 日本久久中文字幕 | 久久免费视频8 | 国产免费av一区二区三区 | 一区二区三区在线视频观看58 | 欧美久久久久久久久久 | 国产专区精品视频 | 国产原厂视频在线观看 | 精品黄色在线观看 | 在线观看av不卡 | 91精品国产九九九久久久亚洲 | 国产精品女教师 | 久久中文字幕在线视频 | 最新免费av在线 | www.com在线观看 | 久久黄色网 | 国产专区精品视频 | 啪啪av在线 | 午夜精品福利一区二区三区蜜桃 | 亚洲视频一 | 久久精品伊人 | 久久一久久| 国产在线观看二区 | 天天干天天干天天 | 成人动漫一区二区 | 日韩免费视频一区二区 | 日韩成人黄色 | 欧美精品日韩 | 一本一本久久a久久精品综合妖精 | 欧美激情精品 | www色片 | 久久久久久久久久毛片 | 自拍超碰在线 | 色婷婷av国产精品 | 欧美日本高清视频 | 国产精华国产精品 | 99国产一区| 久久亚洲私人国产精品va | 国产91成人在在线播放 | 五月婷在线播放 | 国产亚洲人成网站在线观看 | 久久久久久久久久伊人 | 波多野结衣在线播放一区 | 日韩色在线观看 | 久久天天躁夜夜躁狠狠躁2022 | 国产在线美女 | www.99av| 国产在线色 | 丁香婷婷综合网 | av大全免费在线观看 | 久久99精品国产一区二区三区 | 操一草| 亚洲清纯国产 | 五月天婷婷在线观看视频 | 婷婷色中文网 | 黄网站app在线观看免费视频 | 亚洲精品久久久久www | 中文字幕av在线不卡 | 久草电影在线 | 日日夜夜亚洲 | 国产亚洲成人网 | 日本最新高清不卡中文字幕 | 一级欧美一级日韩 | 国产成人一区二区三区在线观看 | 国产中的精品av小宝探花 | 99精品视频免费看 | 午夜精品婷婷 | 国产精品一区二区av麻豆 | 久草在线最新视频 | 国产精品wwwwww | 色片网站在线观看 | 久久视频在线观看 | 黄色大全免费网站 | 天天操夜| 日韩久久精品一区二区 | 亚洲 欧美 精品 | 视频福利在线观看 | 日韩二区三区在线观看 | 亚洲极色| 视频一区久久 | 久视频在线播放 | 国产91精品一区二区绿帽 | 草樱av| 日韩在线色视频 | 日韩av午夜| 91精品久久久久久 | 婷婷香蕉 | 激情婷婷久久 | 久久99精品久久久久蜜臀 | 国产视频欧美视频 | 成年人免费看片网站 | 久久精品欧美一区二区三区麻豆 | 500部大龄熟乱视频使用方法 | 成人a免费视频 | av网站播放| 久久精品国产免费观看 | 天天干天天操天天干 | 麻豆视频国产在线观看 | 日本久久视频 | 亚洲精品视频久久 | 99视屏| 一级片黄色片网站 | 欧美激情综合五月色丁香小说 | 在线观看视频黄色 | 丁香激情婷婷 | 99产精品成人啪免费网站 | 国产精品免费在线播放 | 成人免费xxx在线观看 | 亚洲精品中文在线资源 | 精品国产一区二区三区男人吃奶 | 99精品热视频 | 国产麻豆视频在线观看 | 亚州国产精品久久久 | 久久久国产精品一区二区三区 | 国产免费午夜 | 五月婷婷一区二区三区 | 日本中文在线观看 | 久久久99国产精品免费 | 色婷婷在线播放 | 欧美一级片免费播放 | 九九影视理伦片 | 99热播精品 | 人人澡人人爽欧一区 | 欧美无极色| 97福利| 亚洲久久视频 | 国产一区二区精品久久 | 精品亚洲va在线va天堂资源站 | 久久一区国产 | 免费91麻豆精品国产自产在线观看 | 国产真实精品久久二三区 | 午夜国产一区二区 | 97超在线视频 | 久久99精品久久久久久三级 | 成人毛片久久 | 日韩久久一区 | 色婷婷电影 | 国产在线中文 | 99久久精品国产观看 | 人人看黄色 | 91看片黄色| 成人精品国产 | 婷婷天天色 | 91精品久久久久久 | 午夜黄网 | 91网址在线 | 免费在线一区二区 | 五月开心激情 | 天天伊人狠狠 | 九九久久久久久久久激情 | 五月婷婷中文字幕 | 狠狠狠色丁香婷婷综合久久五月 | 国产一区二区三区免费视频 | 91麻豆精品国产自产 | 黄污视频网站 | 色com网| 亚洲乱码在线 | 国产视频精品在线 | 国产精品区在线观看 | 麻豆一二 | 亚洲一区 av| 久久99国产综合精品 | 2023亚洲精品国偷拍自产在线 | 91在线永久 | 久久久久免费观看 | av中文国产 | 探花视频在线观看免费版 | 国产精品第一视频 | 精品在线一区二区三区 | 国产精品视频在线观看 | 亚洲天堂精品视频 | 人人爽人人搞 | 中文字幕在线观看视频网站 | 99热在线这里只有精品 | 日韩在线视频网 | av不卡中文字幕 | 国产精品入口麻豆 | 亚洲v精品 | 最近免费中文字幕大全高清10 | 日韩欧美精品在线 | 久久成人午夜 | 亚洲视频专区在线 | 国产在线国偷精品产拍 | 欧美日韩在线播放 | 在线视频a | 在线亚州| 色视频在线观看免费 | 日日夜夜艹| 亚洲一二视频 | 在线国产精品一区 | 在线观看国产亚洲 | 中文在线字幕免费观看 | 西西444www大胆高清视频 | 中文字字幕在线 | 成人三级视频 | 激情网站网址 | 国产九色91| 亚洲国产免费看 | 69国产盗摄一区二区三区五区 | 黄网站免费大全入口 | 亚洲精品在线国产 | 免费特级黄毛片 | 午夜 久久 tv | a级片久久久 | 免费欧美精品 | 黄色软件在线观看 | 免费在线观看av的网站 | 精品国产电影一区 | 婷婷色在线播放 | 91视频免费看网站 | 在线观看亚洲视频 | 一区二区三区在线免费观看 | 超碰资源在线 | 久久99国产精品久久99 | 欧美韩国日本在线观看 | 久久久久久免费视频 | 精品字幕 | 亚洲色综合 | 看片网站黄 | 免费看一及片 | 黄色影院在线观看 | 亚洲 欧美 精品 | 激情视频综合网 | 干天天 | 中文字幕有码在线播放 | 99精品在线直播 | 伊人久久电影网 | 手机在线黄色网址 | www.成人久久 | 日韩一区二区免费在线观看 | 国产福利av在线 | 激情偷乱人伦小说视频在线观看 | 亚洲精品国偷自产在线91正片 | 亚洲精品视频在线观看网站 | 国产精品一区欧美 | 国产美女免费观看 | 天天射日 | 国产欧美精品一区二区三区 | 天天干天天操人体 | 久久精品一区二区 | 国产高清中文字幕 | 伊人五月天 | 天天超碰 | 精品黄色视 | 久久久久久电影 | 在线视频黄 | av最新资源 | 国产69精品久久久久9999apgf | 色综合久久久久 | 国产高清在线免费 | 久久黄色a级片 | 午夜在线免费观看视频 | 最新动作电影 | 久草在线免费看视频 | 欧美 亚洲 另类 激情 另类 | 国产亚洲精品久久久久秋 | 亚洲综合在线发布 | 91中文在线视频 | 日韩久久久 | 日韩美在线观看 | 亚洲最大av| 婷婷成人亚洲综合国产xv88 | 亚洲成aⅴ人在线观看 | 国产精品久久久久久久久久 | 国产精品久久久久久欧美 | 久久免费的精品国产v∧ | 成片免费观看视频 | 日韩专区中文字幕 | 日韩黄色在线观看 | 欧美日韩在线视频一区二区 | 久久精视频 | 国产精品成人一区二区三区 | 国产vs久久| 最新av中文字幕 | 久久精品理论 | 日韩在线观看电影 | 国产精品乱码高清在线看 | 嫩嫩影院理论片 | 热re99久久精品国产66热 | 一本一道久久a久久精品 | 免费看十八岁美女 | 亚洲天堂毛片 | 欧美电影黄色 | 国产久草在线观看 | 亚洲另类视频 | 亚洲欧洲国产精品 | 丁香五婷 | 国产成人久久 | 国产精品免费视频一区二区 | 久久久久在线观看 | 国产成人精品av在线 | 国产精品video爽爽爽爽 | 人人藻人人澡人人爽 | 国产精品午夜8888 | 91在线小视频| 日韩三级一区 | 波多野结衣在线播放一区 | 人人澡视频 | 丁香六月婷 | 97超碰国产精品 | 国产一区二区三区高清播放 | 黄色三级免费网址 | 色网站免费在线看 | 日韩黄色在线 | 欧美一级视频免费看 | 国产精品久久久一区二区三区网站 | 99视频精品全部免费 在线 | 成人一级黄色片 | 亚洲精品国偷拍自产在线观看 | 免费视频xnxx com| 成人免费一级片 | 日韩网站一区二区 | 亚州国产精品 | 91精彩视频 | 亚洲国产精品成人综合 | 99久久精品国产系列 | 日韩欧美视频一区二区 | 日韩成人精品一区二区三区 | 中文字幕大全 | 91精品国产电影 | 操操操影院| 伊人国产在线播放 | 天天干天天操天天 | 最近高清中文在线字幕在线观看 | 久久免费视频网站 | 91精品国产九九九久久久亚洲 | 一级黄色在线免费观看 | 超碰成人网 | a√天堂资源 | 激情xxxx| 婷婷色中文字幕 | 国产啊v在线 | 天天做日日做天天爽视频免费 | 国产精品久久久久久一区二区三区 | 精品国产乱码久久久久久三级人 | 色五月激情五月 | 麻豆视频大全 | 伊人开心激情 | 久久久99久久 | 91视频在线自拍 | 亚洲综合一区二区精品导航 | 久久免费在线观看 | a级国产乱理伦片在线播放 久久久久国产精品一区 | 欧美肥妇free| 亚洲人成精品久久久久 | 日本黄色免费观看 | 91.精品高清在线观看 | 2024av| 日韩免费高清在线观看 | 国产成人av电影在线 | 亚洲性少妇性猛交wwww乱大交 | 亚洲深爱激情 | 深夜免费福利 | 亚洲天天摸日日摸天天欢 | 99麻豆视频 | 91日韩国产| 亚洲国产精品视频 | 欧美日韩有码 | 97久久精品午夜一区二区 | 精品国产乱码久久久久久1区二区 | 久久超级碰视频 | 国产精品中文久久久久久久 | 在线免费日韩 | 国产高清精品在线观看 | 天天综合婷婷 | 这里只有精品视频在线 | 在线观看91精品国产网站 | 国产精品成人一区二区 | 91桃色免费视频 | 亚洲欧美激情精品一区二区 | 久久午夜鲁丝片 | 亚洲永久精品在线观看 | 国产在线精品国自产拍影院 | 欧美激情另类 | 00av视频 | 成年人免费电影 | 热久久免费国产视频 | 日韩视频一 | 色精品视频 | 日韩欧美在线观看一区二区 | 三级在线视频播放 | 狠狠狠狠狠狠狠 | 久久看视频 | 一级片视频在线 | 日本韩国精品一区二区在线观看 | 亚洲专区免费观看 | 色网站黄 | 久久久国产精品一区二区三区 | 国产福利一区二区三区视频 | 91影视成人 | 国产亚洲精品女人久久久久久 | 91福利免费 | 精品久久久一区二区 | 精品国产一区二区三区久久久久久 | 亚洲成aⅴ人片久久青草影院 | 免费精品视频在线 | 久久精品伊人 | 日日婷婷夜日日天干 | 午夜丰满寂寞少妇精品 | 婷婷5月激情5月 | 四虎永久网站 | 成人av电影在线 | 久久精品美女视频 | 99视频在线精品免费观看2 | 日韩在线观看视频中文字幕 | 日韩中文字幕91 | 久久综合给合久久狠狠色 | 天天摸天天操天天舔 | 在线观看一二三区 | 91国内产香蕉 | 久久久久久久久久久久久久电影 | 国产精品久久一区二区三区不卡 | 69av视频在线 | 精品产品国产在线不卡 | 免费看片黄色 | 亚洲精品xx | 九九久久视频 | 中文字幕在线观看第三页 | www.夜夜干.com| 国语精品视频 | 99久久精品国产一区二区成人 | 色激情五月| 午夜av在线 | 午夜成人免费电影 | 亚洲乱码一区 | 久99久在线| 欧美亚洲成人免费 | 久久精品日本啪啪涩涩 | 日韩精品不卡在线观看 | 九九日九九操 | 国产日韩欧美在线 | 超碰97国产在线 | 久久精品看 | 五月婷婷香蕉 | 婷婷色网站 | 成人污视频在线观看 | 久久精品视频日本 | 天天爱天天色 | 国产成人一区二区三区久久精品 | 97在线视频免费播放 | 欧美日韩国产一区二区三区 | 91精品国产网站 | 久久亚洲二区 | 中文字幕中文字幕中文字幕 | av高清在线 | 国产一级一级国产 | 九九国产精品视频 | 瑞典xxxx性hd极品 | 超碰在线人人爱 | 麻豆国产精品永久免费视频 | av综合网址 | 国产一区二区免费在线观看 | 欧美激情精品久久久久久变态 | 国产视频一级 | 国产中文字幕在线免费观看 | 欧美精品久久久久性色 | 久久久久久久久久久久99 | 欧美激情视频一区二区三区免费 | www.天天射| 久久久人人人 | 成人av片免费观看app下载 | 在线免费观看成人 | 亚洲 在线 | 亚洲va男人天堂 | a级国产乱理论片在线观看 伊人宗合网 | 国产福利在线免费 | 天天综合精品 | 能在线看的av | 日韩在线三区 | 免费看色的网站 | 99操视频 | 亚洲爽爽网 | 国产精品欧美激情在线观看 | 免费国产亚洲视频 | 超碰在线观看97 | 欧美性生活一级片 | 99国内精品久久久久久久 | 在线日韩一区 | 美女福利视频在线 | 久久久久www| 欧美地下肉体性派对 | 久久成人精品电影 | 国产成人免费观看久久久 | 911香蕉 | 亚洲毛片在线观看. | 国产黑丝一区二区三区 | 最近中文字幕免费观看 | 91在线精品观看 | 免费在线视频一区二区 | 成人福利在线播放 | 永久免费的啪啪网站免费观看浪潮 | 亚洲精品理论 | 九色91在线视频 | 亚洲国产欧美一区二区三区丁香婷 | 在线精品在线 | 黄色一级片视频 | 欧美日韩精品在线播放 | 黄色综合 | 国产精品久久久久久五月尺 | 亚洲手机天堂 | 久久人91精品久久久久久不卡 | av直接看 | 午夜在线资源 | 日本黄色免费电影网站 | 国产无遮挡又黄又爽馒头漫画 | 国产精品久久免费看 | 人人澡视频 | 伊人黄| 国产一级精品在线观看 | 久久夜色精品国产欧美乱 | 国产午夜亚洲精品 | 91在线亚洲| 欧美精品久久人人躁人人爽 | 日韩在线电影观看 | 日韩免费看的电影 | 超碰在线人人97 | 久久精品中文字幕免费mv | 啪嗒啪嗒免费观看完整版 | 丁香六月婷婷 | 亚洲在线免费视频 | 精品一区二区在线观看 | 欧美aⅴ在线观看 | 天天插视频 | 在线观看aa | 精品国产精品久久一区免费式 | 成人一级免费电影 | 日韩av免费在线看 | 操操操操网 | 亚洲国产精品va在线 | 欧美婷婷综合 | 五月婷婷六月丁香 | 国产精品久久久久久久久费观看 | 精品电影一区 | 免费高清看电视网站 | 亚洲精品在线免费 | 国产黄| 青春草免费在线视频 | 91成人黄色| 超碰97在线资源 | a电影在线观看 | 一区二区三区免费播放 | 国产99在线免费 | 久久免费影院 | 91精品在线看 | 国产香蕉97碰碰久久人人 | 久射网| 人人舔人人爱 | 波多野结衣在线视频免费观看 | 色综合天天干 | 国模吧一区| 中文字幕免费高清在线 | 伊人天天操 | 久久综合九色欧美综合狠狠 | 午夜免费福利视频 | 精品一区二区在线播放 | 久久午夜精品视频 | 夜夜躁日日躁狠狠久久av | 亚洲视频免费在线观看 | 久久久久久国产精品美女 | 久久综合九色综合97婷婷女人 | 美女久久久久久久久久久 | 免费看的黄色 | 久久 国产一区 | 欧美另类v | 91精品在线麻豆 | 最新高清无码专区 | 日韩精品视频第一页 | 手机av在线免费观看 | 中文字幕色在线视频 | av黄色在线 | 91丨九色丨蝌蚪丰满 | 久久一区二区三区国产精品 | 久久成熟 | 国产亚洲精品女人久久久久久 | 婷婷丁香花五月天 | 亚洲午夜精品一区二区三区电影院 | 精品亚洲一区二区 | 成人av资源站 | 99久久99久久精品国产片果冰 | 香蕉97视频观看在线观看 | 青青河边草免费观看 | 在线观看岛国av | 亚洲精品乱码久久久久久9色 | 日韩电影在线观看一区 | 精品99久久久久久 | 亚洲人人精品 | 日韩在线观看av | 精品久久网 | www日韩视频 | 日韩和的一区二在线 | 国产久草在线观看 | 日韩高清一区二区 | 国产精品久久久久久久久大全 | 欧美久久综合 | 天天射天天 | 免费福利视频网站 | 77国产精品 | 婷婷色综合 | 麻豆视频国产在线观看 | 99久久夜色精品国产亚洲96 | 精品国产一区二区久久 | 色婷婷丁香 | 99热精品在线 | 亚洲精品在线免费看 | 久久99精品久久久久蜜臀 | 久久人人看| 在线色吧| 在线а√天堂中文官网 | 在线精品一区二区 | 欧美在线视频a | 黄色av免费电影 | 精品视频国产一区 | 久久久免费看视频 | 成人免费电影 | 欧美日韩精品在线观看 | 欧洲一区二区在线观看 | 国产精品成人免费 | 日韩久久久 | 91.dizhi永久地址最新 | 成人资源在线 | 免费观看mv大片高清 | 青青河边草观看完整版高清 | www.com久久久 | 国产手机av在线 | 日日草视频 | 99色免费| 最新av在线网站 | 波多野结衣视频一区二区 | 最近中文字幕大全 | 日韩理论片在线 | 日韩精品免费在线观看视频 | 亚洲精品黄网站 | 黄色毛片在线看 | 日韩精品一卡 | 精品一区二区三区在线播放 | 伊人激情综合 | 色综合久久综合中文综合网 | 精品视频免费在线 | 日韩精品大片 | 国产视频日韩 | 日韩在线第一区 | 久久蜜臀av| 国产福利a | 狠狠88综合久久久久综合网 | 毛片的网址 | 国产精品白虎 | 不卡av免费在线观看 | 五月综合色| 久久久久久国产精品美女 | 九九综合在线 | 三级免费黄| 久久久久久久久网站 | 国产麻豆视频 | 精品字幕 | 亚洲jizzjizz日本少妇 | 日韩免费观看一区二区 | 亚洲一区二区天堂 | 五月天激情婷婷 | 九九视频这里只有精品 | 国产中文字幕大全 | 中文字幕免费久久 | 国语对白少妇爽91 | 色九九视频 | 一级一片免费视频 | www.国产高清| 黄毛片在线观看 | 免费黄色网址网站 | 看片网站黄色 | 97色国产| bbbbb女女女女女bbbbb国产 | 久久精国产 | 久久精品国产一区二区三区 | 欧美日韩中文字幕视频 | 精品久久一 | 亚洲精品99久久久久久 | 国产成人高清av | 人人爽人人干 | 日韩一区在线播放 | 久久成人午夜视频 | www亚洲精品 | 久久在线观看视频 | 99国产视频在线 | 3d黄动漫免费看 | www.国产在线视频 | 久久久综合色 | 午夜18视频在线观看 | 国产黄a三级三级 | 98久久| 99综合视频 | 1024手机看片国产 | 91亚洲精品国产 | 久久99精品国产麻豆婷婷 | 日本中文字幕电影在线免费观看 | 欧美在线观看视频 | 91精品91| 激情喷水 | 91成人精品在线 | 久久精品这里热有精品 | 欧美精品在线免费 | 日韩精品亚洲专区在线观看 | 深爱五月激情网 | 99国产精品一区二区 | 色99视频| 久久久久久片 | 5月丁香婷婷综合 | 高清免费av在线 | 亚洲成人免费在线观看 | 99热精品在线观看 | 国产亚洲综合精品 | 九九国产精品视频 | 久久五月婷婷丁香社区 | 久久精品女人毛片国产 | 91亚洲狠狠婷婷综合久久久 | 91av精品| 日韩av成人免费看 | 天天爽夜夜操 | 超碰999 | 国产99久久久久久免费看 | 99精品视频99 | 国内精品在线观看视频 | av在线永久免费观看 | 成人a免费视频 | 日韩欧美视频 | 三级黄色免费片 | 四虎成人网 | 超级碰碰碰免费视频 | 又紧又大又爽精品一区二区 | 久久国产一区二区三区 | 在线观看黄色小视频 | 日韩中文字幕a | a精品视频| 精久久久久 | 深夜免费福利视频 | av成人在线观看 | 国内久久久 | 色香com.| 日韩av片免费在线观看 | 婷婷在线网| 麻豆传媒视频观看 | av在线免费网 | 国产人成一区二区三区影院 | 国产一区网址 | 久久久久国产精品午夜一区 | 在线观看视频国产一区 | 中文字幕日韩在线播放 | 亚洲精品久久久久中文字幕二区 | 成人精品在线 | 亚洲国产精品推荐 | 精品国产电影一区 | 97在线观看免费高清 | 99国产精品一区 | 久久久久亚洲精品中文字幕 | 黄色国产在线观看 | 99久e精品热线免费 99国产精品久久久久久久久久 | 一区在线观看 | 国产精品美女久久久久久久网站 | 久久久久国产精品www | 超碰人人干人人 | 在线观看视频免费播放 | 999久久久国产精品 高清av免费观看 | 天天操天天操天天操天天操天天操 | 99久久99久久精品国产片 | 国产精品日韩久久久久 | 国产成人久 | 日韩理论片 | 日韩高清免费无专码区 | 欧美专区国产专区 | 在线看片中文字幕 | 91视频 - 114av| 亚洲粉嫩av | 婷婷在线网 | 欧美-第1页-屁屁影院 | 久久99久久久久久 | 五月天激情视频在线观看 | 国产精品久久久久久吹潮天美传媒 | 国产美女精品在线 | 在线视频亚洲 | 99精品国产99久久久久久福利 | 99在线精品视频 | 麻豆av一区二区三区在线观看 | 久久不卡免费视频 | 91在线麻豆 | 成年人在线免费看 | 国产精品久久久一区二区三区网站 | 黄色毛片一级 | 性色va| 国产精品大片在线观看 | 久久久精品成人 | av福利在线免费观看 | 午夜视频免费 | 亚洲国产999| 国产精品久久久久三级 | 久久精品视频在线观看免费 | 亚洲香蕉在线观看 | 亚洲女人av | 西西www4444大胆视频 | 2021国产在线视频 | 久久久婷| 久久99国产精品 | 91精品在线免费观看 | 欧美a性 | 欧美日韩国产在线观看 | 日本中文不卡 | 国产美女网站视频 | 国产高清永久免费 | 成人羞羞视频在线观看免费 | 日韩三区在线观看 | 午夜精品久久久久久久爽 | 亚洲成av人片| 色欧美成人精品a∨在线观看 | 欧美日韩视频免费看 | 久99久在线视频 | 亚洲欧美日韩不卡 | 手机成人免费视频 | 久久久国产精品麻豆 | 日韩av看片| 一区二区视频在线播放 | 国产精品一区二区在线观看 | 国产精品资源在线观看 | 天天视频色版 | 欧美另类xxxxx | 九九久久精品 | av黄色在线播放 | 久久久国产精品亚洲一区 | 九九九九九精品 | 国产免费大片 | 亚洲成aⅴ人在线观看 | 最新三级在线 | 国产精品久久久久久久久久新婚 | 丁香久久激情 | 999男人的天堂 | 久99久在线视频 | 99re中文字幕 | 欧美福利网站 | 欧美日韩aaaa| 国产特级毛片aaaaaa毛片 | 黄色视屏av | 亚洲精品字幕在线观看 | 在线观看av麻豆 | 日韩小视频 |