pvbrowser 서버 백그라운드 실행

pvbrowser 서버를 백그라운드에서 실행하고 싶다.

무엇을 잘못 해서 인지는 몰라도 백그라운드 실행이 아음대로 되지않는다.
pvbrowser에서 공식적으로 제시하는 방법은

•  pvservice
•  pcontrol

여기다 start_pvapp 을 이용하여 할 수 있을 것 같은데

 우선 pvservice 사용법을 잘 모르겠다. 윈도우에서 공식적으로 지원해 주는 프로그램을 이용해서 하는 것 같은데 머리 용량이 딸려서 몇번 시도하다 포기.
pcontrol 도 시도하다 포기.
.
.
.OTL
.
.
start_pvapp을 이용하여 서버를 돌리고 pvbrowser에서 작동하는 것 까지는 확인했는 데, 이상하게 재접속하면 되지 않는다.

그래서 윈도우 OS 에서 서비스 등록하는 방법을 검색하다, 발견한 것이

NSSM - the Non-sucking Service Manager

이 프로그램을 이용하여 윈도우 서비스를 등록하니 잘 된다. modbusdaemon도 서비스 등록이 된다. 더 좋은 것은 부팅 단계부터자동실행하게 할 수 있다.

바로 내가 찾던 프로그램....그럼 한번 사용해 보자


NSSM 홈페이지에서 압축파일 다운로드 한 후, 압축을 풀면 소스, 32비트, 64비트 폴더가 생성된다. 자신의 OS에 따라 실행하면 된다.설치도 필요 없다.

단 조심하자.
event log message를 nssm 프로그램이 사용하기 때문에 다른 위치에서 실행하던가. 버전이 다른 것을 사용하면 충돌이 발생할 수 있다고... 설명되어 있다.
동일 폴더에서 nssm을 실행시키면 문제가 없는 것 같다.

기본적으로 도스 모드에서 동작하는 프로그램으로 홈페이지에서 설명한 방법으로 서비스 등록하면 NSSM 설정창이 나타나는 데, 설정창에서 필요한 설정을 하면 서비스 등록이 된다.
서비스 등록, 시작, 정지, 제거와 같은 것들은 CMD 창에서(관리자 권한으로) 수행하여야 한다.

1.서비스 등록 (install)

nssm install <servicename>

서비스이름을 pvs로 지정하고 실행해 보았다.

그림 1. NSSM

그림2. NSSM install 실행화면

다음과 같은 Tab으로 구성되어 있다.

• Application
• Details
• Log on
• Dependencies
• Process
• Shutdown
• Exit actions
• I/O
• File rotation
• Environment

Application Tab에서 프로그램을 등록하면 된다.

그림 3.application 설정

• Path
  실행파일의 전체 경로를 적어준다.
  본인의 경우 프로젝트/release 폴더에 생성된 실행파일을 지정해준다.
• Startup directory
  실행파일이 실행될 디렉토리를 적어준다
  본인의 경우 프로젝트 폴더를 지정해준다. 서버 프로그램 개발시 사용하는 파일들이 프로젝트 폴더에 있기 때문. 예)SVG,....
• Arguments
  서버 실행시 필요한 인자들을 적어준다.
  예) -port=5050

Detail 탭에서는 서비스 창에 나타날 정보들을 입력한다.
이 탭에서 중요한 것은 startup_type이다. 컴퓨터 부팅 단계부터 실행하고 싶으면 Automatic을 설정하면 된다. 본인의 경우 manual을 선호한다.

그림 4.Detail 탭

• Display name
  서비스에 나타나는 이름을 적어 준다
• Description
  서비스에 나타나는 설명을 적어준다.
• Startup_type
   Automatic
   Automatic ( Delayed Start)
   Manual
   Disabled

Dependences 탭은 이 서비스를 실행하기 위해 함께 실행하여야 되는 서비스를 넣어준다.
함께 실행하고자하는 서비스 역시 서비스로 등록되어 있어야 한다.
본인의 경우 modbusdaemon도 함께 실행하고 싶기 때문에 pvsModbus라는 서비스를 등록한후 dependences 탭에 넣어 주었다.

그림 5. Dependences 탭

이 정도만 설정하고 Install Service 버튼을 누르면 서비스에 등록된다.
등록된 서비스는  윈도우 서비스 매니저에서 확인하면 된다. 수동으로 서비스를 등록한 경우 서비스 매니저에서 시작 혹은 정지할 수 있다.

그림 6. 윈도우 서비스 매니저

 서비스 매니저 이름 항목에 나타나는 것이 Displayname, 설명 항목에 나타나는 것이 Description 항목이다. 본인이 보기 쉬운 것(확인하기 쉬운 것)으로 써주면 된다.

너무 간단하게 설명해서 죄송.
NSSM 홈페이지 메뉴얼에 너무 자세하게 설명되어 있어 통과합니다.

저는 배치파일로 만들어사용합니다.


echo off echo Batch Process for Server START/STOP for Arduino echo. if "%1" == "-install" goto INSTALL if "%1" == "-status" goto STATUS if "%1" == "-start" goto START if "%1" == "-stop" goto STOP if "%1" == "-remove" goto STOP echo. echo USAGE : start-dd install echo Service Install : start-dd -install echo Service Status : start-dd -status echo Service Start : start-dd -start echo Service Stop : start-dd -stop echo Service Remove : start-dd -remove goto QUIT :INSTALL echo. echo Install modbusdaemon for Arduino G:\nssm\nssm.exe install ArduinoModbusD G:\exercise\pvbrowser\test100-Arduino\modbusdaemon.exe G:\nssm\nssm.exe set ArduinoModbusD AppDirectory G:\exercise\pvbrowser\test100-Arduino G:\nssm\nssm.exe set ArduinoModbusD DisplayName pvbrowser Modbusdaemon for Arduino G:\nssm\nssm.exe set ArduinoModbusD Description Modbus daemon for Arduino Communication G:\nssm\nssm.exe set ArduinoModbusD Start SERVICE_DEMAND_START echo. echo Install pvserver for Arduino G:\nssm\nssm.exe install Arduino G:\exercise\pvbrowser\test100-Arduino\release\pvs.exe G:\nssm\nssm.exe set Arduino AppDirectory G:\exercise\pvbrowser\test100-Arduino G:\nssm\nssm.exe set Arduino AppParameters -port=5050 G:\nssm\nssm.exe set Arduino DisplayName pvbrowser Server for Arduino G:\nssm\nssm.exe set Arduino Description pvbrowser Server Service for Arduino G:\nssm\nssm.exe set Arduino Start SERVICE_DEMAND_START G:\nssm\nssm.exe set Arduino DependOnService ArduinoModbusD :START echo. echo. echo Start Service for Arduino G:\nssm\nssm.exe start Arduino goto QUIT :STATUS echo. echo Arduino pvServer G:\nssm\nssm status Arduino echo Arduino Modbus Daemon G:\nssm\nssm.exe status ArduinoModbusD :STOP echo. echo Stop Service echo Stop Service for Arduino G:\nssm\nssm.exe stop Arduino G:\nssm\nssm.exe stop ArduinoModbusD if "%1" == "stop" goto QUIT echo. echo Remov Service G:\nssm\nssm.exe remove Arduino confirm G:\nssm\nssm.exe remove ArduinoModbusD confirm goto QUIT :QUIT echo. echo.................... pause

참조만 하시기 바랍니다.
batch쪽은 거의 사용하지 못합니다.

여하튼 가장 많이 쓴 명령어를 한번살펴보죠.

• nssm install <servicename>
  서비스 등록
• nssm start <servicename>
  등록된 서비스 시작
• nssm stop <servicename>
  등록된 서비스 정지
• nssm remove <servicename>
  등록된 서비스 제거
• nssm set <servicename> <parameter> <subparameter>
  서비스 항목 편집
  사용 예)
  nssm set pvs AppDirectory c:\...\...
  서비스로 사용하고 싶은 프로그램의 디폴트 디렉토리
  .<parameter>에 대한 자세한 내용은 nssm 홈페이지 메뉴얼 참조
• nssm edit <servicename>
  서비스 항목은 이 명령을 이용하면 보다 쉽게 할 수 있습니다.
  GUI 창이 나타나니까.

여하튼 배치로 만들어 사용하니 매우 편리합니다.

pvbrowser MySQL 사용하기 - Modbus 통신 데이터 Database 에 저장하기

자, Database에 연결하였고, DB에 데이터도 넣어보았습니다.

데이터를 자동으로 입력해 보죠.
제가 사용하는 방법이 틀릴수도 있습니다. 작동이 되지않는다 그런 문제가 아니라 시스템에 부하가 많이 가해질수도 있고, 에러가 발생한 우려도 있다는 겁니다. 그러니 이 사람은 이런 식으로 사용하는구나... 라고 생각하시기 바랍니다.

SCADA, HMI, 기타... 등등, 대부분의 데이터 수집 장치는 백그라운드에서 일정 주기 간격으로 데이터를 수집합니다. 사용자가 수집된 데이터를 버튼을 이용해 저장하는 것은 극히 드물죠

가장 중요한 개념은 백그라운드에서 일정주기 간격으로 저장한다.

pv서버 프로그램에서 백그라운드는 무엇일까요, 뭐, 서버프로그램 자체가 백그라운드라고 말한다면, 할 말없고, 여하튼 main, mask,... 제가 볼때 main이 백그라운드 입니다. mask 프로그램은 호출받을때만 실행되므로, mask에 주기적으로 데이터를 저장하는 코드를 집어넣어도 제대로 작동하지 않습니다. 만약 mask가 한개만 있다면 가능하죠. 그러나 여러 mask를 사용하는 경우는 제대로 작동하지 않습니다.

일정주기 간격으로 저장할려면 어떻게 해야 할까요? 이건 이벤트 혹은 인터럽트 개념인데...

여하튼 골치 아픈 문제 입니다.
QTimer와 signal Slot을 이용하여 해결해 보려고 했는데 yahoo Group 에 있는 pvbrowser 항목을 살펴보니 이건...OTL... pvbrowser는 Qt를 이용해 개발했지만 다른 쪽은 아니라는 식으로 설명되어 있네요.

그냥 스레드를 하나 만들어 처리하는 식으로 방향을 잡고 진행해 보도록 하겠습니다.

스레드 만들기

그럼 스레드 만드는 법을 살펴보죠.
스레드를 만들기 위해서 사용하는 라이브러리가 "rlthread.h"입니다. 헤더 파일에 정의해 놓고 넘어가죠.

메인 함수에 다음과 같은 코드를 집어 넣었습니다.

rlThread timerBase; static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; return arg; }

pvInit(ac,av,&p); /* here you may interpret ac,av and set p->user to your data */ //Thread timerBase.create(timerBaseThread, NULL);

간단히 말하면 timerBase라는 rlThread 객체를 만들었습니다. 그리고 객체(timerBase)가 사용할 함수(timerBaseThread())를 하나 만든 후 rlthread에서 지원하는 create()함수를 이용하여 스레드를 만들었습니다.
간단하죠, 우선은 인자로 NULL을 넘겨 주었습니다.

timerBaseThread() 함수를 수정하여 5초마다 '>>I'm alive." 문장을 출력하도록 해보죠.
만들어진 Thread가 주기적으로 작동하는지 확인하기 위해서...

static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; time_t delayTime = time(0) + 5; int counter = 1; while(1) { if(time(0) > delayTime) { printf(">>I'm alive! Counter =%d\n", counter++); delayTime = time(0) + 5; } } return arg; }

timer를 사용하기 위해 C 표준함수인 <ctime.h>을 사용하였습니다. 헤더파일 수정해 주시기 바랍니다.

서버를 시작한 후 확인해 보았습니다.

그림 1. 서버 실행화면

5초마다 자기가 살아있다는 메시지를 출력하는 군요. 시간은 정확한 5초가 아니고 5초 이상에서 한번씩 나타납니다...(이것은 본인 실력이 이것 밖에 되지 않으니 이해해 주시기를...)

Modbus 입력 데이터 Database에 저장하기

그럼 timeBaseThread() 함수에서 지난번에 만든 Arduino Modbus에서 수집한 데이터를 읽어 들여오도록 코드를 수정해보죠. 5초 이상의 간격으로 데이터를 수집하는 구문입니다. 


static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; unsigned short sqlData[29; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; int counter = 1; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2, 0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); } } return arg; }

modbus에서 넘어오는 dataInterval 변수로 지정한 주기로 저장하기 위해 unsigned short 형식의 sqlData 배열을 정의하였습니다. 살펴보시면 특이 사항이 없기 때문에 실행해보죠.

그림 2. 서버실행화면-Modbus Data

Arduino에서 난수 형태의 데이터가 넘어오는 것을 확인할 수 있습니다. 잘 동작하네요.

지금까지의 내용이 "백그라운드에서 일정주기 간격으로 저장한다." 라는 개념을 반영한 것입니다.



자, 그럼 최종적으로 이 데이터를 Database에 저장해보죠.

지금부터의 내용은 본인이 제대로 이해하지 못하면서, 작동하게만 만들어 놓은 코드입니다.
즉, 정확한 내용(혹은 방법)이 아닐 수 있습니다. 하지만 동작하는데 이상은 없었습니다. 마음에 드는 코드는 아니지만...

우선 DataType을 하나 정의 했습니다.

typedef struct { PARAM *p; } myThreadData;

특이한 것 없습니다. 나중을 위해.... 특이한 것은 PARAM *p 를 이용했다는 것.


static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; myThreadData *d = (myThreadData *)p->user; char queryBuffer[2048]; string sqlQueryBuffer; unsigned short sqlData[29; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); p->thread->lock(); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2, 0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); p->thread->unlock(); p->thread->lock(); int ret = db.query(d->p, "INSERT INTO Arduino (data00, data01, data02) VALUES(10, 20, 30)"); printf("db.query = 'insert *' re=%d\n", ret); p->thread->unlock(); } } return arg; }

Header 함수에 string 함수를 사용하기 위해 다음과 같이 하여 주시기 바랍니다.

#include <string> using namespace std;

여기서 이해 되지 않는 부분이

myThreadData *d = (myThreadData *) p->user;

db.query(d->p, "INSERT INTO Arduino .....");

myThreadData 로 d 를 정의하여야 query에서 인식을 하는데 왜 그런지다시 한번 확인해 보자...여하튼 지금은 그냥 넘어가자.

컴파일 후

그림 3 pvbrowser 실행화면

그림3과 같이 데이터가 주기적으로 계속 저장되고 있습니다.
비록 Arduino에서 넘어온 데이터는 아니지만....

자 Arduino에서 넘어온 데이터를 Database에 넣어 보죠.

설명하기 귀찮아서아래와 같은 코드를 작성하였습니다.

// // Thread for timerBase // static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; myThreadData *d = (myThreadData *)p->user; char queryBuffer[2048]; string sqlQueryBuffer; string stringTemp; int sqlData[29]; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); p->thread->lock(); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2,0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); p->thread->unlock(); sqlQueryBuffer = "INSERT INTO Arduino ("; sqlQueryBuffer += "data00, data01, data02, data03, data04, data05, data06, "; sqlQueryBuffer += "data07, data08, data09, data10, data11, data12, data13, "; sqlQueryBuffer += "data14, data15, data16, data17, data18, data19, data20, "; sqlQueryBuffer += "data21, data22, data23, data24, data25, data26, data27, "; sqlQueryBuffer += "data28) VALUES ("; stringTemp = ""; sprintf(queryBuffer, " %d", sqlData[0]); stringTemp += queryBuffer; for (int i = 1; i < 29; i++) { sprintf(queryBuffer, ", %d", sqlData[i]); stringTemp += queryBuffer; } stringTemp += ");"; sqlQueryBuffer += stringTemp; strcpy(queryBuffer, sqlQueryBuffer.c_str()); // string to char* conversion printf(">>Query : %s\n", queryBuffer); p->thread->lock(); int ret = db.query(d->p, queryBuffer); printf("db.query = 'insert *' re=%d\n", ret); p->thread->unlock(); delayTime = time(0) + dataInterval; } } return arg; }


코드 최적화를 해야하는데 실력이 되지 않네요. 여하튼 실행시키면 그림 4와 같은 화면이 나타납니다.

그림 4. 서버 실행화면

그림 5. pvbrowser 실행화면

pvbrowser 화면에서 확인해 보았습니다. 잘 되는 군요.

뒤로 갈수록 설명이 영 엉망이네요. thread관련 부분은 다시 한번 검토해 보아야 할 것 같습니다.

pvbrowser MySQL 사용하기 - Database(MariaDB) 연결

DATABASE에 연결 방법 정리

하도 오래 간만에 하려고 하니, 했던 방법을 다 잊어버려 개고생...하다. 나중에 같은 일이 발생할까봐 정리하게 되었습니다.

잠깐, 삼천포로 빠지겠습니다.
 pvbrowser는 Qt를 이용하여 만들어진 프로그램입니다. 즉, Qt에 있는 모듈을 모두 사용할 수 있습니다. Qt에서 기본적으로 지원하는 QtSql 모듈은 플랫폼(OS), DATABASE의 종류에 무관하게 사용할 수 있을 뿐 아니라. Qt의 모델/뷰(Model/View) 구조를 지원합니다.
아직 저도 Model/View 개념은 혼동이 있는 상태지만, 익숙해지면 쉬워지겠죠.

Qt에서 Database와 관련된 모듈들을 한번 살펴보면

• QSqlDatabase
• QSqlQuery
• QSqlTableModel
• QSqlRelationalTableModel
• ...

여하튼 많이 있습니다. 이번에는 데이터베이스를 연결하고, 테스트하는 것이 목적이므로 QSqlDatabase, QSqlQuery가 주 관심사이며, pvbrowser에서 어떻게 코딩하여야 하는지 알아보죠.

오늘 하는 내용은 "pvaddon\templates\qtDatabase" 에 있는 내용을 쉽게 풀어 쓴 것이라고 생각해 주시기 바랍니다. pvaddon 패키지는 pvbrwoser 홈페이지에서 다운로드 받으시기 바랍니다. 아니면 GitHub에서 검색하셔도 됩니다. 여하튼, 이 패키지에 있는 qtdatabase.h, qtdatabase.cpp 파일이 필요합니다.


먼저 Qt의 SQL을 모듈을 사용할 수 있게 project 파일을 수정하여야 합니다.

새로 만든 프로젝트 파일의 기본 내용입니다.
TEMPLATE = app CONFIG += warn_on release console CONFIG -= qt

아래와 같이 수정해 주시기 바랍니다.
TEMPLATE = app CONFIG += warn_on release console CONFIG += qt QT += sql

pvbrowser 프로젝트를 생성하면 기본적으로 Qt 관련 내용을 사용하지 않는 것으로 설정되어 있습니다. 하지만 Qt에서 지원하는 SQL 관련 모듈을 사용하기 위해서는 위와 같이 수정해 주셔야 합니다.


두번째로 pvaddon 에 있는 qtdatabase 코드를 사용하도록 설정하겠습니다.
사용하기 전에 한번 qtdatabase 헤더파일을 살펴보죠.

/*************************************************************************** qtdatabase.h - description ------------------- begin : Fri May 28 2010 http://pvbrowser.org TODO: customize / extend this class for your own purposes ***************************************************************************/ #include <stdio.h> #include <stdlib.h> #include <qsqldatabase> #include <qsqlrecord> #include <qsqlfield> #include <qsqlquery> #include <qsqlerror> #include <qvariant> #include <qstring.h> #include "processviewserver.h" /** The currently available driver types are: dbtype := Description "QDB2" IBM DB2, v7.1 and higher "QIBASE" Borland InterBase Driver "QMYSQL" MySQL Driver "QOCI" Oracle Call Interface Driver "QODBC" ODBC Driver (includes Microsoft SQL Server) "QPSQL" PostgreSQL v6.x and v7.x Driver "QSQLITE" SQLite version 3 or above "QSQLITE2" SQLite version 2 "QTDS" Sybase Adaptive Server */ class qtDatabase { public: qtDatabase(); ~qtDatabase(); int open(const char *dbtype, const char *hostname, const char *dbname, const char *user, const char *pass); int close(); int query(PARAM *p, const char *sqlcommand); int populateTable(PARAM *p, int id); const char *recordFieldValue(PARAM *p, int x); int nextRecord(); QSqlDatabase *db; QSqlQuery *result; QSqlError *error; };

qsqldatabase, qsqlrecord,qsqlfield, qsqlquery, qsqlerror 를 이용하여 qtDatabase 객체를 만들었고, 다음과 같은 함수들을 지원해주는 군요.

• open()
• close()
• query()
• populateTable()
• recordFieldValue()
• nextRecord()

 오늘은 qtDatabase 객체에서 지원하는 이 함수들을 이용하여 MariaDB에 접속하고자 합니다


만들어준 pvbrowser 프로젝트 폴더에, 이 함수들을 이용할 수 있게 설정한 후, 사용하고자하는 mask에서 extern 명령을 이용하면 됩니다.(글이 많이 꼬여 있네요...) 여하튼 다음과 같은 코드를 프로젝트 파일에 넣어 주시기 바랍니다.

#DATABASE code HEADERS += qtdatabase.h SOURCES += qtdatabase.cpp

수정된 프로젝트 코드입니다.
TEMPLATE = app CONFIG += warn_on release console CONFIG += qt QT += sql # Input #HEADERS += rldefine.h HEADERS += pvapp.h \ mask1_slots.h SOURCES += main.cpp \ mask1.cpp #DATABASE code HEADERS += qtdatabase.h SOURCES += qtdatabase.cpp

코드를 수정하신 후 다운받은 qtdatabase.h, qtdatabase.cpp를 프로젝트 폴더에 복사하여 주십시오. 만약 위치가 틀릴 경우 HEADERS, SOURCES 에 경로를 함께 적어 주셔야 합니다.
저는 그냥 복사하여 사용하였습니다.

이 단계까지 수정한 후 컴파일 해 보았습니다.

그림 1. 컴파일 화면

별로 특이한 것이 없는 것 같은데... 여하튼 넘어가죠.


프로젝트 파일에 필요한 수정은 다 끝난 상태입니다. 두가지만 기억하죠.
qtsql 모듈을 사용하도록 설정해야한다는 것과 외부 파일(qtdatabase Header & Source)의 경로를 설정한다는 것.
Mask에 database관련 코드를 직접 코딩할 경우 외부파일이 필요 없습니다. 하지만 그러지 않아도 복잡한 Mask 파일에 부하를 감소시키는 방법이 있으면 활용하는 것이 좋겠죠.

다음은 Main() 함수에서 DATABASE와 연결해 보겠습니다.
Main() 함수에서 qtDatabase 객체를 사용하기 위해 다음과 같이 정의해 주십시오.

qtDatabase db;

Main()함수에 qtDatabase 클래스를 사용하려면 pvapp.h에 다음과 같이 입력해 주셔야 합니다.
#include "qtdatabase.h"

컴파일해볼까요.

그림 2. 컴파일 화면

아직까지는 에러가 발생하지 않고 있네요. 만약 "qtDatabase does not name a type"  에러가 발생하면 pvapp.h 파일에서 qtdatabase.h 파일을 include 하지 않아서 입니다. 주의하시기 바랍니다.


자, SQL 관련 기본 준비는 끝난 것 같군요. 데이터베이스에 접속해 보겠습니다.
데이터베이스 접속코드는 일반적으로 Main() 함수에 넣어줍니다. 그래야 다른 mask에서도 사용할 수 있으니까.

만약, INETD를 사용하는 경우(LINUX,.. 계열)에는 #ifdef USE_INETD 밑에 있는 main()함수에, 윈도우 계열에서는 #else 밑에 있는 main()함수에 다음과 같은 코드를 넣어 주십시오.

int ret = db.open("QMYSQL", "192.168.0.***", "pvbrowser", "root", "********"); printf("db.open ret=%d\n", ret);

qtDatabase class 정의된 open() 함수를 이용하여 "192.168.0.***"에 설치된MariaDB에 MySQL 커넥터를 이용하여 접속하고 있습니다.
open() 함수의 인자는 다음과 같습니다.

• DBType
  QMYSQL, QOCI, QODBC, QSQLITE,...
• Hostname
  SQL server
• User
• Pass

db.open()이 정상적으로 수행되는 경우ret = 0, 에러가 발생하면 -1 값을 반환합니다. 물론 정상적으로 수행되어야 db 객체가 생성됩니다.

컴파일 해보죠

그림3. 컴파일 화면

Make를 이용하여 컴파일 한 결과 입니다. 정상적으로 되고 있습니다.

그럼 pvbrowser에서 테스트하기 위해 서버를 시작해 볼까요. Action->Start Server를 눌러 주십시오.

그림 4. 서버 실행 화면

화면 하단부에 보면 다음과 같은 문구가 나타나내요.

QSqlDatabase: QMYSQL driver not loaded QSqlDatabase: available drivers:QSQLITE QMYSQL QMYSQL3 QODBC QODBC3 QPSQL QPSQL7 QSqlDatabase: an instance of QCoreApplication is required for loading driver plugins db.open ret = -1

우선 "db.open ret = -1 " DATABASE 를 열지(연결)하지 못했다는 메시지가 나오네요.
이것은 위에 있는 메시지를 보면 해결방법이 나옵니다.
"QMYSQL driver not load" 즉, 드라이버가 설치되어 있지 않기 때문입니다. 이 문제는
Database Connector를 설치하면 해결됩니다.
각 DB마다 필요한 connector를 설치해야합니다. 저의 경우 mysql connector for C/C++을 설치하여야 이 문제가 해결되죠.
그럼 connector는 어떻게 설치하죠. 두가지 방법이 있습니다.

• DB 서버 구축
  
  

  

  그림 5.MariaDB lib폴더

  
  MariaDB가 설치된 위치에 있는 lib 폴더에 보면 libmysql.dll이 설치되어 있습니다.
• DB connector 단독 설치
  홈페이지에서 connector 설치프로그램 다운로드 및 설치

MySQL Database도 동일하다고 생각하시면 됩니다.

여하튼 libmysql.dll 라이브러리가 필요합니다. 이 파일을 현재 프로젝트 폴더에 넣어주시거나, pvb가 설치된 디렉토리 하위에 있는 다음의 디렉토리에 복사해 넣어주십시오.

pvb\win-mingw\bin

Action->start server를 눌러 서버를 실행해 보죠

그림 6. 서버 실행 화면

"QMYSQL driver not load" 메시지가 사라지고 "db.open ret=0" 이라는 메시지가 출력되었네요.
서버에 정상 접속되었습니다.
만약 이 단계에서도 ret=-1이 나타나면 db 서버 상태, 사용자/PASSWORD, DB Connector 지원 방식을 다시 확인해 보시기 바랍니다.

기본적으로 qt를 사용한다면(CONFIG += qt) qt 관련 이벤트를 처리하기 위한 모듈을 로딩하는 것이 필요합니다. "QSqlDatabase: an instance of QCoreApplication is required for loading driver plugins" 이 메시지와 연관이 있는 것 같습니다. 무시해도 사용은 되지만, 잘 모릅니다. 찜찜하죠. 그래서 다음과 같은 것을 넣어 주죠.

#include <QCoreApplication>
QtGUI 를 사용하지 않는 프로그램에서 Qt 이벤트 처리를 지원해주는 것입니다. 위치는 main.cpp에 넣어주시기 바랍니다.

#include "pvapp.h" #include <qcoreapplication> // todo: comment me out. you can insert these objects as extern in your masks.

여기까지 하면 qtDatabase 객체인 db가 생성된 것입니다. 이제 이 객체를 이용하면 되죠.


qtdatabase.h 에 정의 되어 있는 query()와 populateTable()를 사용해 보겠습니다.

테스트용으로 아래와 같은 GUI를 하나 만들었습니다.

그림 7. 기본 GUI 화면

사용하는 mask에 다음의 내용을 입력해 주십시오.

extern qtDatabase db; extern rlMutex dbmutex;

설명을 하지 않았는데, db접속시 multi thread 개념을 사용하여야 합니다. DATABASE는 혼자가 아닌 여러 프로그램들이 사용하므로...
여하튼 rlMutex를 이용해야 하므로 이 객체가 정의되어 있는 rlthread.h를 사용할 수 있게 하여야 합니다. 헤더와 메인 프로그램에 다음과 같이 넣어 주십시오.

>> 헤더 프로그램
//#include "ppidaemon.h" // this is generated #include "rlthread.h" // Thread #include "qtdatabase.h" // DATABASE Class int show_mask2(PARAM *p);


>>Main 프로그램
//rlPPIClient ppi(ppidaemon_MAILBOX,ppidaemon_SHARED_MEMORY,ppidaemon_SHARED_MEMORY_SIZE); qtDatabase db; rlMutex dbmutex; int pvMain(PARAM *p)


테이블 위젯에 DB 에서 읽어들인 데이터를 표시하기 위해 다음과 같은 코드를 사용하였습니다. pvaddon에 있는 예제를 인용했습니다.

static int slotDatabaseTablePopulate(PARAM *p, DATA *d) { dbmutex.lock(); int ret = db.query(p, "select * from arduino"); printf("db.query='select * from tables' ret=%d\n", ret); db.populateTable(p,table_01); dbmutex.unlock(); return 0; }

Database 쿼리 관련 작업은 간단할 수도 있지마, 많은 데이터를 처리하는 경우 시간이 소요되는 작업이기 때문에 mutex 방식으로 데이터를 보호하고 있습니다.

sql 명령어 쿼리는 db.query() 함수를 이용하는 군요. 이 함수 내부를 살펴보면 db->exec() 함수를 이용합니다. Qt에서 SQL 명령을 보내기 위한 것과 동일한 함수를 사용하는 것을 알 수 있습니다.

저는 query() 함수에 DB 서버의 arduino 테이블에서 데이터를 몽땅 가져오라는 명령을 주었습니다. 정상적으로 명령이 수행되면 qtDatabase 객체에 정의된 result 변수에 (QVariant)형식의 데이터가 입력됩니다. 쿼리 수행결과에 에러가 발생하면 pvbrowser status에 다음과 같이 에러를 표시해 줍니다.

그림 8. Query 실행 에러 표시

그림 9는 Query가 정상적으로 처리되었을 때 나타난 화면입니다.

그림 9. Query 정상 처리

Arduino라는 테이블만 만들어 놓고, 데이터를 입력하지 않았기 때문에 이런식으로 나타나는 군요. Arduino 테이블의 column들이 제대로 표시되고 있습니다.


Database에 연결되었으면 데이터를 넣어보죠.
Database에 데이터를 입력하기 위한 INSERT 버튼과, DB를 다시 읽어 들이기 위한 RELOAD 버튼을 만들었습니다.

RELOAD 버튼 관련 함수는 지난번 것을 그대로 이용하면 되므로 패스...
INSERT 버튼 관련 함수는 다음과 같이 만들었습니다.

static int slotDatabaseInsert(PARAM *p, DATA *d) { dbmutex.lock(); int ret = db.query(p, "insert into Arduino (data00, data01, data02) values(10, 20, 30);"); printf("db.query = 'insert *' re=%d\n", ret); dbmutex.unlock(); return 0; }

똑같죠. 단지 db.query() 함수에 들어가는 것이 다르네요.

insert into Arduino (data00, data01, data02) values (10, 20, 30);

테이블에 데이터를 입력하기 위한 SQL 구문을 그대로 넣으면 됩니다.

그림 10. 실행화면

pvbrowser 실행화면입니다. 데이터가 잘 들어가네요.