//#include "widget.h"
|
//#include <QApplication>
|
#include "LDBTool.h"
|
#include <QObject>
|
#include <list>
|
#include <string>
|
#include <iostream>
|
#include <QDebug>
|
#include "myThread.h"
|
#include "dbtest.h"
|
#if 1
|
|
//dev
|
|
|
int main(int argc, char *argv[])
|
{
|
std::cout<<__DATE__<<" "<<__TIME__<<std::endl;
|
{
|
CallBackFunc callf;
|
|
DbTest test_db/*(std::bind(&CallBackFunc::callback_func, &callf, std::placeholders::_1))*/;
|
// DbTest test_db2;
|
|
auto sp_task(std::make_shared<std::string>("haikang:12:34:56:78:90:ab"));
|
auto sp_task2(std::make_shared<std::string>("dahua:12:34:56:78:90:ab"));
|
// test_db.put_task(sp_task);
|
// test_db.put_task(sp_task2);
|
// test_db.put_task(sp_task);
|
// test_db.put_task(sp_task2);
|
// test_db.put_task(sp_task);
|
// test_db.put_task(sp_task2);
|
// test_db.put_task(sp_task);
|
// test_db.put_task(sp_task2);
|
// test_db2.put_task(sp_task);
|
// test_db2.put_task(sp_task2);
|
|
test_db.beginThreads(10);
|
// test_db2.beginThreads(1);
|
|
while(1){
|
test_db.put_task(sp_task);
|
test_db.put_task(sp_task2);
|
}
|
|
}
|
|
|
return 0;
|
}
|
|
|
|
|
|
#else
|
|
//sdkhdl
|
int main(int argc, char *argv[])
|
{
|
// QApplication a(argc, argv);
|
LDBTool test;
|
Record_Chn_Sdk record;
|
|
qDebug() << QDateTime::currentDateTime();
|
|
record.n_id = 0;
|
record.str_storage_dev_id = "str_storage_dev_id1";
|
record.n_chn = 111;
|
record.str_sdks = "1,2,3";
|
record.str_reserved = "str_reserved1";
|
|
test.insertChnSdkTable(record);
|
|
Record_Chn_Sdk record2;
|
record2.n_id = 0;
|
record2.str_storage_dev_id = "str_storage_dev_id2";
|
record2.n_chn = 222;
|
record2.str_sdks = "2,3,4";
|
record2.str_reserved = "str_reserved2";
|
test.insertChnSdkTable(record2);
|
|
std::list<Record_Chn_Sdk> vec;
|
vec = test.searchChnSdkTableAll();
|
// std::cout << vec << std::endl;
|
|
record2.str_sdks = "5,6,7";
|
test.updateChnSdkTable(record2);
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
int chn1 = 111;
|
int chn2 = 222;
|
|
Record_Chn_Sdk rec1 = test.searchChnSdkTableByChannelId(id1, chn1);
|
test.deleteChnSdkTable(id1, chn2);
|
test.deleteChnSdkTable(id2, chn1);
|
test.deleteChnSdkTable(id1, chn1);
|
test.deleteChnSdkTable(id2, chn2);
|
|
return 0;//a.exec();
|
}
|
//sdkhdl
|
int main(int argc, char *argv[])
|
{
|
QApplication a(argc, argv);
|
LDBTool test;
|
Record_Sdk_Hdl_info record;
|
|
qDebug() << QDateTime::currentDateTime();
|
|
record.n_id = 0;
|
record.str_storage_dev_id = "str_storage_dev_id1";
|
record.n_chn = 111;
|
record.str_src_path = "str_src_path1";
|
record.n_total = 11;
|
record.n_pos = 0;
|
record.str_reserved = "str_reserved1";
|
|
test.insertSdkHdlTable(record);
|
|
Record_Sdk_Hdl_info record2;
|
record2.n_id = 0;
|
record2.str_storage_dev_id = "str_storage_dev_id2";
|
record2.n_chn = 222;
|
record2.str_src_path = "str_src_path2";
|
record2.n_total = 22;
|
record2.n_pos = 0;
|
record2.str_reserved = "str_reserved2";
|
test.insertSdkHdlTable(record2);
|
|
|
std::list<Record_Sdk_Hdl_info> vec;
|
vec = test.searchSdkHdlTableAll();
|
// std::cout << vec << std::endl;
|
|
record2.n_pos = 6;
|
test.updateSdkHdlTable(record2);
|
|
test.updateSdkHdlTablePos("str_src_path1", 7);
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
int chn1 = 111;
|
int chn2 = 222;
|
// std::list<Record_Sdk_Hdl_info> vec1 = test.searchChannelTableByChannelId(id1, chn1);
|
// std::list<Record_Sdk_Hdl_info> vec2 = test.searchChannelTableByChannelId(id2, chn2);
|
// std::cout << vec1 << std::endl;
|
// std::cout << vec2 << std::endl;
|
//Record_Sdk_Hdl_info recOldest = test.searchOldestRecordfromSdkHdlTableByUpdateTime();
|
// Record_Sdk_Hdl_info recOldestID = test.searchOldestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
// Record_Sdk_Hdl_info recNewestID = test.searchNewestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
test.insertSdkHdlTableAndDeleteCutVideoTable(record2, id1, chn1, "str_src_path1");
|
test.deleteSdkHdlTable(QString::fromStdString("str_src_path1"));
|
test.deleteSdkHdlTable(QString::fromStdString("str_src_path2"));
|
|
return a.exec();
|
}
|
//cutvideo
|
int main(int argc, char *argv[])
|
{
|
QApplication a(argc, argv);
|
LDBTool test;
|
Record_Cut_Video_info record;
|
|
qDebug() << QDateTime::currentDateTime();
|
|
record.n_id = 0;
|
record.str_storage_dev_id = "str_storage_dev_id1";
|
record.n_chn = 111;
|
record.str_src_path = "str_src_path1";
|
record.str_dst_path = "";
|
record.n_total = 0;
|
record.b_finish_flag = 0;
|
record.tim_update_time = QDateTime::currentDateTime();
|
record.str_reserved = "str_reserved1";
|
|
test.insertCutVideoTable(record);
|
|
Record_Cut_Video_info record2;
|
record2.n_id = 0;
|
record2.str_storage_dev_id = "str_storage_dev_id2";
|
record2.n_chn = 222;
|
record2.str_src_path = "str_src_path2";
|
record2.str_dst_path = "";
|
record2.n_total = 0;
|
record2.b_finish_flag = 0;
|
record2.tim_update_time = QDateTime::currentDateTime();
|
record2.str_reserved = "str_reserved2";
|
test.insertCutVideoTable(record2);
|
|
|
std::list<Record_Cut_Video_info> vec;
|
vec = test.searchCutVideoTableAll();
|
// std::cout << vec << std::endl;
|
|
record2.b_finish_flag = 1;
|
record2.str_dst_path = "str_dst_path222";
|
record2.n_total = 6;
|
record2.tim_update_time = QDateTime::currentDateTime();
|
test.updateCutVideoTable(record2);
|
|
test.updateCutVideoTable("str_src_path1", "str_dst_path111", 7);
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
int chn1 = 111;
|
int chn2 = 222;
|
// std::list<Record_Cut_Video_info> vec1 = test.searchChannelTableByChannelId(id1, chn1);
|
// std::list<Record_Cut_Video_info> vec2 = test.searchChannelTableByChannelId(id2, chn2);
|
// std::cout << vec1 << std::endl;
|
// std::cout << vec2 << std::endl;
|
Record_Cut_Video_info recOldest = test.searchOldestRecordfromCutTableByUpdateTime();
|
// Record_Cut_Video_info recOldestID = test.searchOldestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
// Record_Cut_Video_info recNewestID = test.searchNewestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
test.insertCutVideoTableAndDeleteLoadFileTable(record2, "str_storage_dev_id2",222,\
|
QDateTime::fromString("2018-08-18 16:38:49.819","yyyy-MM-dd hh:mm:ss.zzz"));
|
|
test.deleteCutVideoTable(id1, chn1, QString::fromStdString("str_src_path1"));
|
test.deleteCutVideoTable(id2, chn2, QString::fromStdString("str_src_path2"));
|
|
return a.exec();
|
}
|
//loadfile
|
int main(int argc, char *argv[])
|
{
|
QApplication a(argc, argv);
|
LDBTool test;
|
Record_Load_File_info record;
|
|
qDebug() << QDateTime::currentDateTime();
|
|
record.n_id = 0;
|
record.str_storage_dev_id = "str_storage_dev_id1";
|
record.n_chn = 111;
|
record.tim_do_time = QDateTime::currentDateTime().addDays(-1);
|
record.b_finish_flag = 0;
|
record.str_load_file_path = "";
|
record.tim_update_time = QDateTime::currentDateTime();
|
record.str_reserved = "str_reserved1";
|
|
test.insertLoadFileTable(record);
|
|
Record_Load_File_info record2;
|
record2.n_id = 0;
|
record2.str_storage_dev_id = "str_storage_dev_id2";
|
record2.n_chn = 222;
|
record2.tim_do_time = QDateTime::currentDateTime().addDays(-1);
|
record2.b_finish_flag = 0;
|
record2.str_load_file_path = "";
|
record2.tim_update_time = QDateTime::currentDateTime();
|
record2.str_reserved = "str_reserved2";
|
test.insertLoadFileTable(record2);
|
|
|
std::list<Record_Load_File_info> vec;
|
vec = test.searchLoadFileTableAll();
|
// std::cout << vec << std::endl;
|
|
record2.b_finish_flag = 1;
|
record2.str_load_file_path = "str_load_file_path";
|
record2.tim_update_time = QDateTime::currentDateTime();
|
test.updateLoadFileTable(record2);
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
int chn1 = 111;
|
int chn2 = 222;
|
// std::list<Record_Load_File_info> vec1 = test.searchChannelTableByChannelId(id1, chn1);
|
// std::list<Record_Load_File_info> vec2 = test.searchChannelTableByChannelId(id2, chn2);
|
// std::cout << vec1 << std::endl;
|
// std::cout << vec2 << std::endl;
|
Record_Load_File_info recOldest = test.searchOldestRecordfromLoadTableByUpdateTime();
|
// Record_Load_File_info recOldestID = test.searchOldestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
// Record_Load_File_info recNewestID = test.searchNewestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
|
Record_Cam_Chn chn_record2 = test.searchChannelTableByChannelId("str_storage_dev_id2", 222);
|
chn_record2.tim_do_time = chn_record2.tim_do_time.addSecs(3600);
|
chn_record2.tim_update_time = QDateTime::currentDateTime();
|
test.insertLoadFileTableAndUpdateChannelTable(record2, chn_record2);
|
|
test.deleteLoadFileTable(id1, chn1, record.tim_do_time);
|
test.deleteLoadFileTable(id2, chn2, record2.tim_do_time);
|
|
return a.exec();
|
}
|
//camchn
|
int main(int argc, char *argv[])
|
{
|
QApplication a(argc, argv);
|
LDBTool test;
|
Record_Cam_Chn chn_record;
|
|
// std::cout << QDateTime().toString()<< std::endl;
|
|
chn_record.n_id = 1;
|
chn_record.str_storage_dev_id = "str_storage_dev_id1";
|
chn_record.n_chn = 111;
|
chn_record.str_chn_name = "str_chn_name1";
|
chn_record.str_addr = "str_addr1";
|
chn_record.str_longitude = "str_longitude1";
|
chn_record.str_latitude = "str_latitude1";
|
chn_record.tim_do_time = QDateTime::currentDateTime().addDays(-1);
|
chn_record.tim_update_time = QDateTime::currentDateTime();
|
chn_record.str_reserved = "str_reserved1";
|
|
|
test.insertChannelTable(chn_record);
|
|
Record_Cam_Chn chn_record2;
|
chn_record2.n_id = 2;
|
chn_record2.str_storage_dev_id = "str_storage_dev_id2";
|
chn_record2.n_chn = 222;
|
chn_record2.str_chn_name = "str_chn_name2";
|
chn_record2.str_addr = "str_addr2";
|
chn_record2.str_longitude = "str_longitude2";
|
chn_record2.str_latitude = "str_latitude2";
|
chn_record2.tim_do_time = QDateTime::currentDateTime().addDays(-1);
|
chn_record2.tim_update_time = QDateTime::currentDateTime();
|
chn_record2.str_reserved = "str_reserved2";
|
test.insertChannelTable(chn_record2);
|
|
|
std::list<Record_Cam_Chn> vec;
|
vec = test.searchChannelTableAll();
|
// std::cout << vec << std::endl;
|
|
chn_record2.n_id = 2;
|
chn_record2.str_storage_dev_id = "str_storage_dev_id2";
|
chn_record2.n_chn = 222;
|
chn_record2.str_chn_name = "str_chn_name3";
|
chn_record2.str_addr = "str_addr3";
|
chn_record2.str_longitude = "str_longitude3";
|
chn_record2.str_latitude = "str_latitude3";
|
chn_record2.tim_do_time = QDateTime::currentDateTime().addDays(-1);
|
chn_record2.tim_update_time = QDateTime::currentDateTime();
|
chn_record2.str_reserved = "str_reserved3";
|
test.updateChannelTable(chn_record2);
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
int chn1 = 111;
|
int chn2 = 222;
|
Record_Cam_Chn vec1 = test.searchChannelTableByChannelId(id1, chn1);
|
Record_Cam_Chn vec2 = test.searchChannelTableByChannelId(id2, chn2);
|
// std::cout << vec1 << std::endl;
|
// std::cout << vec2 << std::endl;
|
Record_Cam_Chn recOldest = test.searchOldestRecordfromChnTableByUpdateTime();
|
Record_Cam_Chn recOldestID = test.searchOldestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
Record_Cam_Chn recNewestID = test.searchNewestRecordfromChnTableByChannelId(QString::fromStdString("str_storage_dev_id2"), 222);
|
|
test.deleteChannelTable(id1, chn2);
|
test.deleteChannelTable(id2, chn1);
|
test.deleteChannelTable(id1, chn1);
|
test.deleteChannelTable(id2, chn2);
|
|
return a.exec();
|
}
|
|
//dev
|
int main(int argc, char *argv[])
|
{
|
QApplication a(argc, argv);
|
LDBTool test;
|
Record_Storage_Dev dev_record;
|
|
dev_record.n_id = 0;
|
dev_record.str_storage_dev_id = "str_storage_dev_id1";
|
dev_record.str_dev_name = "str_dev_name1";
|
dev_record.n_total_chn = 32;
|
dev_record.str_all_chn_num = "str_all_chn_num";
|
dev_record.str_addr = "str_addr";
|
dev_record.str_longitude = "str_longitude";
|
dev_record.str_latitude = "str_latitude";
|
dev_record.str_ip = "str_ip";
|
dev_record.n_port = 1;
|
dev_record.str_username = "str_username";
|
dev_record.str_password = "str_password";
|
dev_record.n_duration = 1;
|
dev_record.str_reserved = "str_reserved";
|
|
test.insertLDeviceTable(dev_record);
|
|
Record_Storage_Dev dev_record1;
|
dev_record1.n_id = 2;
|
dev_record1.str_storage_dev_id = "str_storage_dev_id2";
|
dev_record1.str_dev_name = "str_dev_name2";
|
dev_record1.n_total_chn = 16;
|
dev_record1.str_all_chn_num = "str_all_chn_num";
|
dev_record1.str_addr = "str_addr2";
|
dev_record1.str_longitude = "str_longitude2";
|
dev_record1.str_latitude = "str_latitude2";
|
dev_record1.str_ip = "str_ip2";
|
dev_record1.n_port = 222;
|
dev_record1.str_username = "str_username2";
|
dev_record1.str_password = "str_password2";
|
dev_record1.n_duration = 2;
|
dev_record1.str_reserved = "str_reserved2";
|
test.insertLDeviceTable(dev_record1);
|
|
Record_Storage_Dev dev_record2;
|
dev_record2.n_id = 2;
|
dev_record2.str_storage_dev_id = "str_storage_dev_id2";
|
dev_record2.str_dev_name = "str_dev_name3";
|
dev_record2.n_total_chn = 16;
|
dev_record2.str_all_chn_num = "str_all_chn_num3";
|
dev_record2.str_addr = "str_addr3";
|
dev_record2.str_longitude = "str_longitude3";
|
dev_record2.str_latitude = "str_latitude3";
|
dev_record2.str_ip = "str_ip3";
|
dev_record2.n_port = 333;
|
dev_record2.str_username = "str_username3";
|
dev_record2.str_password = "str_password3";
|
dev_record2.n_duration = 3;
|
dev_record2.str_reserved = "str_reserved3";
|
test.updateLDeviceTable(dev_record2);
|
|
|
std::list<Record_Storage_Dev> vec;
|
vec = test.searchDeviceTableAll();
|
|
QString id1("str_storage_dev_id1");
|
QString id2("str_storage_dev_id2");
|
Record_Storage_Dev s1 = test.searchDeviceTableByDeviceId(id1);
|
Record_Storage_Dev s2 = test.searchDeviceTableByDeviceId(id2);
|
|
int n = test.searchDeviceNumber();
|
|
int d = test.searchDurationByDeviceId(id1);
|
|
test.deleteLDeviceTable(id1);
|
test.deleteLDeviceTable(id2);
|
|
return a.exec();
|
}
|
#endif
|
