3. pat info. save to MySQL with cpp connector

http://chipmaker.tistory.com/entry/mysql-cpp-connector-study

에서 cpp connector wrapper 클래스를 만들고 이 클래스를 기반 클래스로 정의하였다.

여기서는 이 기반 클래스를 구체화하는 예제로 PAT 정보를 MySQL에 써 보도록 하자.

1. 소스 트리

.

├── CMakeLists.txt

├── mysqlAdaptor.cpp

├── mysqlAdaptor.h

├── mysqlAdaptorForPAT.cpp

├── mysqlAdaptorForPAT.h

├── pat.cpp

├── pat.h

├── psi_glob.h

├── remove.sh

├── section.cpp

├── section.h

├── test.cpp

└── types.h

2. 헤더 파일

#ifndef __MYSQL_ADAPTOR_PAT_H__ #define __MYSQL_ADAPTOR_PAT_H__ #include <iostream> #include <string> #include <sstream> #include <iomanip> #include <pat.h> #include "mysql_connection.h" #include <cppconn/driver.h> #include <cppconn/exception.h> #include <cppconn/resultset.h> #include <cppconn/statement.h> #include "mysqlAdaptor.h" /* ------------------------------------------------------------------------------------------------------------------- declare define ------------------------------------------------------------------------------------------------------------------- */ /* ------------------------------------------------------------------------------------------------------------------- declare class data ------------------------------------------------------------------------------------------------------------------- */ class MySQLAdaptorForPAT : public BaseMySQLAdaptor { public : MySQLAdaptorForPAT(); virtual ~MySQLAdaptorForPAT(); void createTable(const std::string databaseName, const std::string tableName); void insertTable(const std::string tableName, void *object); void select(const std::string tableName); }; #endif

PAT 정보를 MySQL에 쓰는 파일만 보고 전체 파일을 github link을 참조.

3. 클래스 본체

/** This is free and unencumbered software released into the public domain. Anyone is free to copy, modify, publish, use, compile, sell, or distribute this software, either in source code form or as a compiled binary, for any purpose, commercial or non-commercial, and by any means. In jurisdictions that recognize copyright laws, the author or authors of this software dedicate any and all copyright interest in the software to the public domain. We make this dedication for the benefit of the public at large and to the detriment of our heirs and successors. We intend this dedication to be an overt act of relinquishment in perpetuity of all present and future rights to this software under copyright law. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. For more information, please refer to <http://unlicense.org> */ /** -------------------------------------------------------------------- file : mysqlAdaptorForPAT.cpp mysql c++ connector wrapper class version : 1.0 data : 2016.06.01 author : HeeSoon Kim(chipmaker0304@gmail.com) -----------------------------------------------------------------------*/ #include "mysqlAdaptorForPAT.h" #include "pat.h" std::string PatTableString[] = { "version INT,", "section_number INT,", "program_number INT,", "pmtPid INT" }; MySQLAdaptorForPAT::MySQLAdaptorForPAT() { driver = get_driver_instance(); std::cout << __FUNCTION__ << std::endl; } MySQLAdaptorForPAT::~MySQLAdaptorForPAT() { std::cout << __FUNCTION__ << "," << __LINE__ << std::endl; } void MySQLAdaptorForPAT::createTable(const std::string databaseName, const std::string tableName) { useDB(databaseName); std::string columQuery; for(auto str : PatTableString) { columQuery += str; } std::string databaseQuery = "CREATE TABLE "; databaseQuery += tableName; databaseQuery += "("; databaseQuery += columQuery; databaseQuery += ")"; deleteTabe(tableName); stmt->execute(databaseQuery.c_str()); } void MySQLAdaptorForPAT::insertTable(const std::string tableName, void *object) { PAT *pat; std::string databaseQuery; pat = static_cast<PAT*> (object); for(auto list : pat->getPatList()) { char buffer[256] = {0, }; std::sprintf(buffer, "(%d, %d, %d, %d)", list.version, list.section_number, list.program_number,\ list.pmtPid); databaseQuery = "INSERT INTO "; databaseQuery += tableName; databaseQuery += " VALUES"; databaseQuery += buffer; stmt->execute(databaseQuery.c_str()); } } void MySQLAdaptorForPAT::select(const std::string tableName) { std::string databaseQuery; int i = 1; databaseQuery += "SELECT * from "; databaseQuery += tableName; res = stmt->executeQuery(databaseQuery); while (res->next()) { std::cout << std::dec << i << "] " << "PAT "; std::cout << "version : " << res->getString(1) << ", "; std::cout << "section_number : " << res->getString(2) << ", "; std::cout << "program_number : " << res->getString(3) << ", "; std::cout << "PID : " << res->getString(4) << " "; std::cout << "[ " << std::hex << std::showbase << res->getInt(4) << " ]" << std::endl; i++; } }

기반 클래스에서 순수 가상함수를 사용하였으나, 구지 순수 가상함수를 만들지 않고

가상함수로 만들고 함수 오버라이딩 기법을 사용해도 되지만 두서 없이 c++ 공부하다 보니 그 떄 생각나고

짜보고 싶은 것을 위주로 생각해서 진행해서 어떤 설계를 기반으로 하지 않은점은 고력해야 한다.

4. 테스트 예제

#include <thread> #include <chrono> #include <mutex> #include "section.h" #include "pat.h" #include "mysqlAdaptorForPAT.h" int main(int argc, char* argv[]) { std::string address = "tcp://127.0.0.1:3306"; std::string user = "root"; std::string password = ""; std::string dbName = "test"; std::string tableName = "pat"; SECTION_INFO_T sec; CSection* section = new CSection(); PAT* pat = new PAT(); MySQLAdaptorForPAT *pMySqlPAT = new MySQLAdaptorForPAT(); // open media test, media is file section->openMedia("file://SGP.ts"); // create task to read continously std::thread tr = std::thread([&]() { while(1) { if(section->readMedia(&sec) == RESULT_NOTOK) break; // PAT parsing PAT PID is zero if(sec.pid == 0) { pat->parsingPATSection((UINT8*)sec.section); } } }); tr.join(); // print PAT info pat->printPATList(); pMySqlPAT->connect(address, user, password); pMySqlPAT->deleteDB(dbName); pMySqlPAT->createDB(dbName); pMySqlPAT->createTable(dbName, tableName); pMySqlPAT->insertTable(tableName, (void*)pat); pMySqlPAT->select(tableName); //std::this_thread::sleep_for(std::chrono::milliseconds(1000)); delete section; delete pat; delete pMySqlPAT; return 0; }

5. 실행 결과

6. github link (전체 소스) 

https://github.com/heesoon/mpeg/tree/master/test/patSaveToMySQLDB