mirror/motion
1
0
Fork 0
mirror of https://github.com/Motion-Project/motion.git synced 2026-01-05 21:39:07 -05:00
Code Issues Packages Projects Releases Wiki Activity
Files
bd1615e9f0dfbbc96f196e26adfd1b4af6a1cf2a
motion/src/dbse.cpp
Mr-Dave bd1615e9f0 Rewrite dbse module
2022-10-10 19:09:09 -06:00

1555 lines
52 KiB
C++
Raw Blame History

/*
* This file is part of MotionPlus.
*
* MotionPlus is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* MotionPlus is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with MotionPlus. If not, see <https://www.gnu.org/licenses/>.
*
* Copyright 2020-2022 MotionMrDave@gmail.com
*/
#include "motionplus.hpp"
#include "conf.hpp"
#include "util.hpp"
#include "logger.hpp"
#include "movie.hpp"
#include "dbse.hpp"
/* Forward Declares */
void dbse_close(struct ctx_motapp *motapp);
static int dbse_edits(struct ctx_motapp *motapp)
{
int retcd = 0;
if (motapp->dbse->database_dbname == "") {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Invalid database name"));
retcd = -1;
}
if (((motapp->dbse->database_type == "mysql") ||
(motapp->dbse->database_type == "mariadb") ||
(motapp->dbse->database_type == "pgsql")) &&
(motapp->dbse->database_port == 0)) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
,_("Must specify database port for mysql/mariadb/pgsql"));
retcd = -1;
}
if ((motapp->dbse->database_type == "sqlite3") &&
(motapp->dbse->database_dbname == "")) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
,_("Must specify database name for sqlite3"));
retcd = -1;
}
if (retcd == -1) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
,_("Database functionality disabled."));
motapp->dbse->database_type = "";
}
return retcd;
}
/* Free the cols lists*/
static void dbse_cols_free(struct ctx_motapp *motapp)
{
int indx;
if (motapp->dbse == NULL) {
return;
}
if (motapp->dbse->cols_list != NULL) {
for (indx=0; indx<motapp->dbse->cols_cnt; indx++) {
myfree(&motapp->dbse->cols_list[indx].col_nm);
myfree(&motapp->dbse->cols_list[indx].col_typ);
}
myfree(&motapp->dbse->cols_list);
}
motapp->dbse->cols_cnt = 0;
}
/* Create array of all the columns in current version */
static void dbse_cols_list(struct ctx_motapp *motapp)
{
int indx;
dbse_cols_free(motapp);
motapp->dbse->cols_cnt = 11;
motapp->dbse->cols_list =(ctx_dbse_col *)
mymalloc(sizeof(ctx_dbse_col) * motapp->dbse->cols_cnt);
/* The size of 30 is arbitrary */
for (indx=0; indx<motapp->dbse->cols_cnt; indx++) {
motapp->dbse->cols_list[indx].col_nm = (char*)mymalloc(30);
motapp->dbse->cols_list[indx].col_typ = (char*)mymalloc(30);
motapp->dbse->cols_list[indx].found = false;
}
indx=0;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "camid");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "movie_nm");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "text");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "movie_dir");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "text");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "full_nm");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "text");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "movie_sz");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "movie_dtl");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "movie_tmc");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "text");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "diff_avg");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "sdev_min");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "sdev_max");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
indx++;
snprintf(motapp->dbse->cols_list[indx].col_nm, 30, "%s", "sdev_avg");
snprintf(motapp->dbse->cols_list[indx].col_typ, 30, "%s", "int");
}
/* Free the movies lists*/
static void dbse_movies_free(struct ctx_motapp *motapp)
{
int indx;
if (motapp->dbse->movie_list != NULL) {
for (indx=0; indx<motapp->dbse->movie_cnt; indx++) {
myfree(&motapp->dbse->movie_list[indx].movie_nm);
myfree(&motapp->dbse->movie_list[indx].movie_dir);
myfree(&motapp->dbse->movie_list[indx].full_nm);
myfree(&motapp->dbse->movie_list[indx].movie_tmc);
}
myfree(&motapp->dbse->movie_list);
}
motapp->dbse->movie_cnt = 0;
}
static void dbse_rec_default(ctx_dbse_rec *rec)
{
rec->found = false;
rec->recordid = -1;
rec->camid = -1;
rec->movie_nm = (char*)mymalloc(5);
snprintf(rec->movie_nm, 5,"%s", "null");
rec->movie_dir = (char*)mymalloc(5);
snprintf(rec->movie_dir, 5,"%s", "null");
rec->full_nm = (char*)mymalloc(5);
snprintf(rec->full_nm, 5,"%s", "null");
rec->movie_sz = 0;
rec->movie_dtl = 0;
rec->movie_tmc = (char*)mymalloc(5);
snprintf(rec->movie_tmc, 5,"%s", "null");
rec->diff_avg = 0;
rec->sdev_min = 0;
rec->sdev_max = 0;
rec->sdev_avg = 0;
}
#ifdef HAVE_SQLITE3
static void dbse_sqlite3_exec(struct ctx_motapp *motapp, const char *sqlquery)
{
int retcd;
char *errmsg = NULL;
if(motapp->dbse->database_sqlite3 == NULL) {
return;
};
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "Executing query");
retcd = sqlite3_exec(
motapp->dbse->database_sqlite3
, sqlquery, NULL, 0, &errmsg);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("SQLite error was %s"), errmsg);
sqlite3_free(errmsg);
}
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "Finished query");
}
/* Process query list of columns in motionplus table*/
static int dbse_sqlite3_cb (
void *ptr, int arg_nb, char **arg_val, char **col_nm)
{
ctx_motapp *motapp = (ctx_motapp *)ptr;
int indx, indx2;
int rnbr, flen;
struct stat statbuf;
ctx_dbse_rec *rec;
if (motapp->dbse->dbse_action == DBSE_ACT_CHKTBL) {
for (indx=0; indx < arg_nb; indx++) {
if (mystrceq(arg_val[indx],"motionplus")) {
motapp->dbse->table_ok = true;
}
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCNT) {
for (indx=0; indx < arg_nb; indx++) {
if (mystrceq(col_nm[indx],"movie_cnt")) {
motapp->dbse->movie_cnt =atoi(arg_val[indx]);
}
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCOLS) {
for (indx=0; indx < arg_nb; indx++) {
if (mystrceq(col_nm[indx],"col_nm")) {
for (indx2=0; indx2 < motapp->dbse->cols_cnt; indx2++) {
if (mystrceq(arg_val[indx]
, motapp->dbse->cols_list[indx2].col_nm)) {
motapp->dbse->cols_list[indx2].found = true;
}
}
}
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETTBL) {
rnbr = motapp->dbse->rec_indx;
if (rnbr < motapp->dbse->movie_cnt) {
rec = &motapp->dbse->movie_list[rnbr];
dbse_rec_default(rec);
for (indx=0; indx < arg_nb; indx++) {
if (arg_val[indx] != NULL) {
if (arg_val[indx] != NULL) {
if (mystrceq(col_nm[indx],"recordid")) {
rec->recordid = atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"camid")) {
rec->camid = atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"movie_nm")) {
free(rec->movie_nm);
flen = strlen(arg_val[indx]);
rec->movie_nm = (char*)mymalloc(flen + 1);
snprintf(rec->movie_nm, flen+1,"%s",arg_val[indx]);
} else if (mystrceq(col_nm[indx],"movie_dir")) {
free(rec->movie_dir);
flen = strlen(arg_val[indx]);
rec->movie_dir = (char*)mymalloc(flen + 1);
snprintf(rec->movie_dir, flen+1,"%s",arg_val[indx]);
} else if (mystrceq(col_nm[indx],"full_nm")) {
free(rec->full_nm);
flen = strlen(arg_val[indx]);
rec->full_nm = (char*)mymalloc(flen + 1);
snprintf(rec->full_nm, flen+1,"%s",arg_val[indx]);
if (stat(rec->full_nm, &statbuf) == 0) {
rec->found = true;
}
} else if (mystrceq(col_nm[indx],"movie_sz")) {
rec->movie_sz =atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"movie_dtl")) {
rec->movie_dtl =atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"movie_tmc")) {
free(rec->movie_tmc);
flen = strlen(arg_val[indx]);
rec->movie_tmc =
(char*)mymalloc(flen + 1);
snprintf(rec->movie_tmc
,flen+1,"%s",arg_val[indx]);
} else if (mystrceq(col_nm[indx],"diff_avg")) {
rec->diff_avg =atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"sdev_min")) {
rec->sdev_min =atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"sdev_max")) {
rec->sdev_max =atoi(arg_val[indx]);
} else if (mystrceq(col_nm[indx],"sdev_avg")) {
rec->sdev_avg =atoi(arg_val[indx]);
}
}
}
}
}
motapp->dbse->rec_indx++;
}
return 0;
}
static void dbse_sqlite3_cols(struct ctx_motapp *motapp)
{
int retcd, indx;
char *errmsg = 0;
std::string sqlquery;
dbse_cols_list(motapp);
sqlquery =
" select name as col_nm "
" from pragma_table_info('motionplus');";
motapp->dbse->dbse_action = DBSE_ACT_GETCOLS;
retcd = sqlite3_exec(motapp->dbse->database_sqlite3
, sqlquery.c_str(), dbse_sqlite3_cb, motapp, &errmsg);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Error retrieving table columns: %s"), errmsg);
sqlite3_free(errmsg);
return;
}
for (indx=0; indx<motapp->dbse->cols_cnt; indx++) {
if (motapp->dbse->cols_list[indx].found == false) {
sqlquery = "Alter table motionplus add column ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_nm) + " ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_typ) + " ;";
dbse_sqlite3_exec(motapp, sqlquery.c_str());
}
}
dbse_cols_free(motapp);
}
static void dbse_sqlite3_init(struct ctx_motapp *motapp)
{
int retcd;
const char *err_open = NULL;
char *err_qry = NULL;
std::string sqlquery;
motapp->dbse->database_sqlite3 = NULL;
if (motapp->dbse->database_type != "sqlite3") {
return;
}
MOTION_LOG(NTC, TYPE_DB, NO_ERRNO
, _("SQLite3 Database filename %s")
, motapp->dbse->database_dbname.c_str());
retcd = sqlite3_open(
motapp->dbse->database_dbname.c_str()
, &motapp->dbse->database_sqlite3);
if (retcd != SQLITE_OK) {
err_open =sqlite3_errmsg(motapp->dbse->database_sqlite3);
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Can't open database %s : %s")
, motapp->dbse->database_dbname.c_str()
, err_open);
sqlite3_close(motapp->dbse->database_sqlite3);
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Could not initialize database %s")
, motapp->dbse->database_dbname.c_str());
motapp->dbse->database_type = "";
motapp->dbse->database_sqlite3 = NULL;
} else {
MOTION_LOG(NTC, TYPE_DB, NO_ERRNO
, _("database_busy_timeout %d msec")
, motapp->dbse->database_busy_timeout);
retcd = sqlite3_busy_timeout(
motapp->dbse->database_sqlite3
, motapp->dbse->database_busy_timeout);
if (retcd != SQLITE_OK) {
err_open = sqlite3_errmsg(
motapp->dbse->database_sqlite3);
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("database_busy_timeout failed %s"), err_open);
}
}
sqlquery =
"select name from sqlite_master"
" where type='table' "
" and name='motionplus';";
motapp->dbse->table_ok = false;
motapp->dbse->dbse_action = DBSE_ACT_CHKTBL;
retcd = sqlite3_exec(
motapp->dbse->database_sqlite3
, sqlquery.c_str(), dbse_sqlite3_cb, motapp, &err_qry);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Error checking table: %s"), err_qry);
sqlite3_free(err_qry);
return;
}
if (motapp->dbse->table_ok == false) {
/* Autoincrement is discouraged but I want compatibility across
* all the various DBS used in motionplus
*/
sqlquery =
"create table motionplus ("
" recordid integer primary key autoincrement "
");";
retcd = sqlite3_exec(motapp->dbse->database_sqlite3
, sqlquery.c_str(), 0, 0, &err_qry);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Error creating table: %s"), err_qry);
sqlite3_free(err_qry);
return;
}
}
dbse_sqlite3_cols(motapp);
}
static void dbse_sqlite3_movlst(struct ctx_motapp *motapp)
{
int retcd, indx;
char *errmsg = NULL;
std::string sqlquery, delimit;
sqlquery =
"select count(*) as movie_cnt "
" from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETCNT;
retcd = sqlite3_exec(
motapp->dbse->database_sqlite3
, sqlquery.c_str(), dbse_sqlite3_cb, motapp, &errmsg);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Error counting table: %s"), errmsg);
sqlite3_free(errmsg);
return;
}
if (motapp->dbse->movie_cnt > 0) {
motapp->dbse->movie_list =(ctx_dbse_rec *)
mymalloc(sizeof(ctx_dbse_rec)*motapp->dbse->movie_cnt);
motapp->dbse->rec_indx = 0;
sqlquery =" select * from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETTBL;
retcd = sqlite3_exec(
motapp->dbse->database_sqlite3
, sqlquery.c_str(), dbse_sqlite3_cb, motapp, &errmsg);
if (retcd != SQLITE_OK ) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Error retrieving table: %s"), errmsg);
sqlite3_free(errmsg);
return;
}
sqlquery =
" delete from motionplus "
" where recordid in (";
delimit = " ";
for (indx=0; indx<motapp->dbse->movie_cnt; indx++) {
if (motapp->dbse->movie_list[indx].found == false) {
sqlquery += delimit + std::to_string(
motapp->dbse->movie_list[indx].recordid);
delimit = ",";
}
/* 5000 is arbitrary */
if (sqlquery.length() > 5000) {
indx = motapp->dbse->movie_cnt;
}
}
sqlquery += ");";
if (delimit == ",") {
dbse_sqlite3_exec(motapp, sqlquery.c_str());
}
sqlquery ="vacuum";
dbse_sqlite3_exec(motapp, sqlquery.c_str());
}
return;
}
static void dbse_sqlite3_close(struct ctx_motapp *motapp)
{
if ((motapp->dbse->database_type == "sqlite3") &&
(motapp->dbse->database_sqlite3 != NULL)) {
sqlite3_close(motapp->dbse->database_sqlite3);
motapp->dbse->database_sqlite3 = NULL;
}
}
#endif /*HAVE_SQLITE3*/
#ifdef HAVE_MARIADB
static void dbse_mariadb_exec (struct ctx_motapp *motapp, const char *sqlquery)
{
int retcd;
if (motapp->dbse->database_mariadb == NULL) {
return;
}
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "Executing MariaDB query");
retcd = mysql_query(motapp->dbse->database_mariadb, sqlquery);
if (retcd != 0) {
retcd = mysql_errno(motapp->dbse->database_mariadb);
MOTION_LOG(ERR, TYPE_DB, SHOW_ERRNO
, _("MariaDB query '%s' failed. %s error code %d")
, sqlquery, mysql_error(motapp->dbse->database_mariadb)
, retcd);
/* Try to reconnect ONCE if fails continue and discard this sql query */
if (retcd >= 2000) {
mysql_close(motapp->dbse->database_mariadb);
motapp->dbse->database_mariadb = (MYSQL *) mymalloc(sizeof(MYSQL));
mysql_init(motapp->dbse->database_mariadb);
if (mysql_real_connect(
motapp->dbse->database_mariadb
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, motapp->dbse->database_password.c_str()
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_port, NULL, 0) == NULL) {
MOTION_LOG(ALR, TYPE_DB, NO_ERRNO
, _("Cannot reconnect to MariaDB database %s"
" on host %s with user %s MariaDB error was %s")
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, mysql_error(motapp->dbse->database_mariadb));
} else {
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("Re-Connection to MariaDB database '%s' Succeed")
, motapp->dbse->database_dbname.c_str());
retcd = mysql_query(motapp->dbse->database_mariadb, sqlquery);
if (retcd != 0) {
retcd = mysql_errno(motapp->dbse->database_mariadb);
MOTION_LOG(ERR, TYPE_DB, SHOW_ERRNO
, _("after re-connection MariaDB query failed %s"
" error code %d")
, mysql_error(motapp->dbse->database_mariadb), retcd);
}
}
}
}
}
static void dbse_mariadb_recs (struct ctx_motapp *motapp, const char *sqlquery)
{
int retcd, indx, indx2;
int qry_fields, rnbr, flen;
struct stat statbuf;
MYSQL_RES *qry_result;
MYSQL_ROW qry_row;
MYSQL_FIELD *qry_col;
ctx_dbse_rec *rec;
ctx_dbse_col *cols;
retcd = mysql_query(motapp->dbse->database_mariadb, sqlquery);
if (retcd != 0){
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Query error: %s"),sqlquery);
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
}
qry_result = mysql_store_result(motapp->dbse->database_mariadb);
if (qry_result == NULL) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Query store error: %s"),sqlquery);
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
}
qry_fields = mysql_num_fields(qry_result);
cols =(ctx_dbse_col *)
mymalloc(sizeof(ctx_dbse_col) * qry_fields);
for(indx = 0; indx < qry_fields; indx++) {
qry_col = mysql_fetch_field(qry_result);
cols[indx].col_nm = (char*)mymalloc(qry_col->name_length + 1);
snprintf(cols[indx].col_nm, qry_col->name_length + 1
, "%s", qry_col->name);
}
qry_row = mysql_fetch_row(qry_result);
if (motapp->dbse->dbse_action == DBSE_ACT_CHKTBL) {
motapp->dbse->table_ok = false;
while (qry_row != NULL) {
for(indx = 0; indx < qry_fields; indx++) {
if (qry_row[indx] != NULL) {
if (mystrceq(qry_row[indx], "motionplus")) {
motapp->dbse->table_ok = true;
}
}
}
qry_row = mysql_fetch_row(qry_result);
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCNT) {
motapp->dbse->movie_cnt = 0;
while (qry_row != NULL) {
for(indx = 0; indx < qry_fields; indx++) {
if (mystrceq(cols[indx].col_nm, "movie_cnt")) {
motapp->dbse->movie_cnt =atoi(qry_row[indx]);
}
}
qry_row = mysql_fetch_row(qry_result);
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCOLS) {
for(indx = 0; indx < qry_fields; indx++) {
for (indx2=0; indx2 < motapp->dbse->cols_cnt; indx2++) {
if (mystrceq(cols[indx].col_nm
, motapp->dbse->cols_list[indx2].col_nm)) {
motapp->dbse->cols_list[indx2].found = true;
}
}
}
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETTBL) {
motapp->dbse->rec_indx = 0;
while (qry_row != NULL) {
rnbr = motapp->dbse->rec_indx;
rec = &motapp->dbse->movie_list[rnbr];
dbse_rec_default(rec);
for(indx = 0; indx < qry_fields; indx++) {
if (qry_row[indx] != NULL) {
if (mystrceq(cols[indx].col_nm,"recordid")) {
rec->recordid = atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"camid")) {
rec->camid = atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"movie_nm")) {
free(rec->movie_nm);
flen = strlen(qry_row[indx]);
rec->movie_nm = (char*)mymalloc(flen + 1);
snprintf(rec->movie_nm, flen+1,"%s",qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"movie_dir")) {
free(rec->movie_dir);
flen = strlen(qry_row[indx]);
rec->movie_dir = (char*)mymalloc(flen + 1);
snprintf(rec->movie_dir, flen+1,"%s",qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"full_nm")) {
free(rec->full_nm);
flen = strlen(qry_row[indx]);
rec->full_nm = (char*)mymalloc(flen + 1);
snprintf(rec->full_nm, flen+1,"%s",qry_row[indx]);
if (stat(rec->full_nm, &statbuf) == 0) {
rec->found = true;
}
} else if (mystrceq(cols[indx].col_nm,"movie_sz")) {
rec->movie_sz =atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"movie_dtl")) {
rec->movie_dtl =atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"movie_tmc")) {
free(rec->movie_tmc);
flen = strlen(qry_row[indx]);
rec->movie_tmc =(char*)mymalloc(flen + 1);
snprintf(rec->movie_tmc, flen+1,"%s",qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"diff_avg")) {
rec->diff_avg =atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"sdev_min")) {
rec->sdev_min =atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"sdev_max")) {
rec->sdev_max =atoi(qry_row[indx]);
} else if (mystrceq(cols[indx].col_nm,"sdev_avg")) {
rec->sdev_avg =atoi(qry_row[indx]);
}
}
}
motapp->dbse->rec_indx++;
qry_row = mysql_fetch_row(qry_result);
}
}
mysql_free_result(qry_result);
for(indx = 0; indx < qry_fields; indx++) {
free(cols[indx].col_nm);
}
free(cols);
return;
}
static void dbse_mariadb_cols(struct ctx_motapp *motapp)
{
int indx;
std::string sqlquery;
dbse_cols_list(motapp);
sqlquery = " select * from motionplus;";
motapp->dbse->dbse_action = DBSE_ACT_GETCOLS;
dbse_mariadb_recs(motapp, sqlquery.c_str());
for (indx=0; indx<motapp->dbse->cols_cnt; indx++) {
if (motapp->dbse->cols_list[indx].found == false) {
sqlquery = "Alter table motionplus add column ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_nm) + " ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_typ) + " ;";
dbse_mariadb_exec(motapp,sqlquery.c_str());
}
}
dbse_cols_free(motapp);
}
static void dbse_mariadb_setup(struct ctx_motapp *motapp)
{
std::string sqlquery;
sqlquery =
"Select table_name "
" from information_schema.tables "
" where table_name = 'motionplus';";
motapp->dbse->dbse_action = DBSE_ACT_CHKTBL;
dbse_mariadb_recs(motapp,sqlquery.c_str());
if (motapp->dbse->table_ok == false) {
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("Creating motionplus table"));
sqlquery =
"create table motionplus ("
" recordid serial "
");";
dbse_mariadb_exec(motapp,sqlquery.c_str());
}
dbse_mariadb_cols(motapp);
}
static void dbse_mariadb_init(struct ctx_motapp *motapp)
{
bool my_true = true;
motapp->dbse->database_mariadb = NULL;
if (motapp->dbse->database_type != "mariadb") {
return;
}
if (mysql_library_init(0, NULL, NULL)) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Could not initialize database %s")
, motapp->dbse->database_type.c_str());
motapp->dbse->database_type = "";
return;
}
motapp->dbse->database_mariadb = (MYSQL *) mymalloc(sizeof(MYSQL));
mysql_init(motapp->dbse->database_mariadb);
if (mysql_real_connect(
motapp->dbse->database_mariadb
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, motapp->dbse->database_password.c_str()
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_port, NULL, 0) == NULL) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Cannot connect to MariaDB database %s on host %s with user %s")
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str());
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("MariaDB error was %s")
, mysql_error(motapp->dbse->database_mariadb));
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Disabling database functionality"));
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
}
mysql_options(motapp->dbse->database_mariadb
, MYSQL_OPT_RECONNECT, &my_true);
dbse_mariadb_setup(motapp);
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("%s database opened")
, motapp->dbse->database_dbname.c_str() );
}
static void dbse_mariadb_close(struct ctx_motapp *motapp)
{
if (motapp->dbse->database_type == "mariadb") {
mysql_library_end();
if (motapp->dbse->database_mariadb != NULL) {
mysql_close(motapp->dbse->database_mariadb);
free(motapp->dbse->database_mariadb);
motapp->dbse->database_mariadb = NULL;
}
}
}
static void dbse_mariadb_movlst(struct ctx_motapp *motapp)
{
int indx;
std::string sqlquery, delimit;
sqlquery =
"select count(*) as movie_cnt "
" from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETCNT;
dbse_mariadb_recs(motapp, sqlquery.c_str());
if (motapp->dbse->movie_cnt > 0) {
motapp->dbse->movie_list =(ctx_dbse_rec *)
mymalloc(sizeof(ctx_dbse_rec)*motapp->dbse->movie_cnt);
sqlquery =" select * from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETTBL;
dbse_mariadb_recs(motapp, sqlquery.c_str());
sqlquery =
" delete from motionplus "
" where recordid in (";
delimit = " ";
for (indx=0; indx<motapp->dbse->movie_cnt; indx++) {
if (motapp->dbse->movie_list[indx].found == false) {
sqlquery += delimit + std::to_string(
motapp->dbse->movie_list[indx].recordid);
delimit = ",";
}
/* 5000 is arbitrary */
if (sqlquery.length() > 5000) {
indx = motapp->dbse->movie_cnt;
}
}
sqlquery += ");";
if (delimit == ",") {
dbse_mariadb_exec(motapp, sqlquery.c_str());
}
}
}
#endif /*HAVE_MARIADB*/
#ifdef HAVE_MYSQL
static void dbse_mysql_init(struct ctx_motapp *motapp)
{
motapp->dbse->database_mysql = NULL;
if (motapp->dbse->database_type != "mysql") {
return;
}
if (mysql_library_init(0, NULL, NULL) != 0) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Could not initialize database %s")
, motapp->dbse->database_type.c_str());
motapp->dbse->database_type = "";
return;
}
motapp->dbse->database_mysql = (MYSQL *) mymalloc(sizeof(MYSQL));
mysql_init(motapp->dbse->database_mysql);
if (mysql_real_connect(
motapp->dbse->database_mysql
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, motapp->dbse->database_password.c_str()
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_port, NULL, 0) == NULL) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Cannot connect to MySQL database %s on host %s with user %s")
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str());
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("MySQL error was %s")
, mysql_error(motapp->dbse->database_mysql));
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Disabling database functionality"));
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
}
#if (defined(MYSQL_VERSION_ID)) && (MYSQL_VERSION_ID > 50012)
bool my_true = true;
mysql_options(motapp->dbse->database_mysql
, MYSQL_OPT_RECONNECT, &my_true);
#endif
}
static void dbse_mysql_exec(struct ctx_motapp *motapp, const char *sqlquery)
{
int retcd;
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "Executing mysql query");
retcd = mysql_query(motapp->dbse->database_mysql, sqlquery);
if (retcd != 0) {
retcd = mysql_errno(motapp->dbse->database_mysql);
MOTION_LOG(ERR, TYPE_DB, SHOW_ERRNO
, _("Mysql query failed %s error code %d")
, mysql_error(motapp->dbse->database_mysql), retcd);
if (retcd >= 2000) {
mysql_close(motapp->dbse->database_mysql);
motapp->dbse->database_mysql = (MYSQL *) mymalloc(sizeof(MYSQL));
mysql_init(motapp->dbse->database_mysql);
if (mysql_real_connect(
motapp->dbse->database_mysql
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, motapp->dbse->database_password.c_str()
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_port, NULL, 0) == NULL) {
MOTION_LOG(ALR, TYPE_DB, NO_ERRNO
,_("Cannot reconnect to MySQL"
" database %s on host %s with user %s MySQL error was %s")
, motapp->dbse->database_dbname.c_str()
, motapp->dbse->database_host.c_str()
, motapp->dbse->database_user.c_str()
, mysql_error(motapp->dbse->database_mysql));
dbse_deinit(motapp);
} else {
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("Re-Connection to Mysql database '%s' Succeed")
, motapp->dbse->database_dbname.c_str());
retcd = mysql_query(motapp->dbse->database_mysql, sqlquery);
if (retcd != 0) {
retcd = mysql_errno(motapp->dbse->database_mysql);
MOTION_LOG(ERR, TYPE_DB, SHOW_ERRNO
, _("after re-connection Mysql query failed "
" %s error code %d")
, mysql_error(motapp->dbse->database_mysql), retcd);
}
}
}
}
}
static void dbse_mysql_close(struct ctx_motapp *motapp)
{
if (motapp->dbse->database_type == "mysql") {
MOTION_LOG(DBG, TYPE_ALL, NO_ERRNO, _("Closing MYSQL"));
mysql_library_end();
if (motapp->dbse->database_mysql != NULL) {
mysql_close(motapp->dbse->database_mysql);
motapp->dbse->database_mysql = NULL;
}
}
}
int dbse_mysql_movlst(struct ctx_cam *cam)
{
(void)cam;
return 0;
}
#endif /*HAVE_MYSQL*/
#ifdef HAVE_PGSQL
static void dbse_pgsql_exec(struct ctx_motapp *motapp, const char *sqlquery)
{
PGresult *res;
if (motapp->dbse->database_pgsql == NULL) {
return;
}
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "Executing postgresql query");
res = PQexec(motapp->dbse->database_pgsql, sqlquery);
if (PQstatus(motapp->dbse->database_pgsql) == CONNECTION_BAD) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Connection to PostgreSQL database '%s' failed: %s")
, motapp->dbse->database_dbname.c_str()
, PQerrorMessage(motapp->dbse->database_pgsql));
PQreset(motapp->dbse->database_pgsql);
if (PQstatus(motapp->dbse->database_pgsql) == CONNECTION_BAD) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Re-Connection to PostgreSQL database '%s' failed: %s")
, motapp->dbse->database_dbname.c_str()
, PQerrorMessage(motapp->dbse->database_pgsql));
PQclear(res);
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
} else {
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("Re-Connection to PostgreSQL database '%s' Succeed")
, motapp->dbse->database_dbname.c_str());
}
} else if (!(PQresultStatus(res) == PGRES_COMMAND_OK || PQresultStatus(res) == PGRES_TUPLES_OK)) {
MOTION_LOG(ERR, TYPE_DB, SHOW_ERRNO
, "PGSQL query failed: [%s] %s %s"
, sqlquery
, PQresStatus(PQresultStatus(res))
, PQresultErrorMessage(res));
}
PQclear(res);
}
static void dbse_pgsql_close(struct ctx_motapp *motapp)
{
if ((motapp->dbse->database_type == "postgresql") &&
(motapp->dbse->database_pgsql != NULL)) {
PQfinish(motapp->dbse->database_pgsql);
motapp->dbse->database_pgsql = NULL;
}
}
static void dbse_pgsql_recs (struct ctx_motapp *motapp, const char *sqlquery)
{
PGresult *res;
int indx, indx2, rows, cols, rnbr, flen;
struct stat statbuf;
ctx_dbse_rec *rec;
if (motapp->dbse->database_pgsql == NULL) {
return;
}
res = PQexec(motapp->dbse->database_pgsql, sqlquery);
if (motapp->dbse->dbse_action == DBSE_ACT_CHKTBL) {
motapp->dbse->table_ok = false;
if (PQresultStatus(res) != PGRES_TUPLES_OK) {
PQclear(res);
return;
}
cols = PQnfields(res);
rows = PQntuples(res);
for(indx = 0; indx < rows; indx++) {
for (indx2 = 0; indx2 < cols; indx2++){
if (mystrceq("table_nm", PQfname(res, indx2)) &&
mystrceq("motionplus", PQgetvalue(res, indx, indx2))) {
motapp->dbse->table_ok = true;
}
}
}
PQclear(res);
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCNT) {
motapp->dbse->movie_cnt = 0;
if (PQresultStatus(res) != PGRES_TUPLES_OK) {
PQclear(res);
return;
}
cols = PQnfields(res);
rows = PQntuples(res);
for(indx = 0; indx < rows; indx++) {
for (indx2 = 0; indx2 < cols; indx2++){
if (mystrceq("movie_cnt", PQfname(res, indx2))) {
motapp->dbse->movie_cnt =atoi(PQgetvalue(res, indx, indx2));
}
}
}
PQclear(res);
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETCOLS) {
cols = PQnfields(res);
for(indx = 0; indx < cols; indx++) {
for (indx2=0; indx2 < motapp->dbse->cols_cnt; indx2++) {
if (mystrceq(PQfname(res, indx)
, motapp->dbse->cols_list[indx2].col_nm)) {
motapp->dbse->cols_list[indx2].found = true;
}
}
}
PQclear(res);
} else if (motapp->dbse->dbse_action == DBSE_ACT_GETTBL) {
motapp->dbse->rec_indx = 0;
if (PQresultStatus(res) != PGRES_TUPLES_OK) {
PQclear(res);
return;
}
cols = PQnfields(res);
rows = PQntuples(res);
for(indx = 0; indx < rows; indx++) {
rnbr = motapp->dbse->rec_indx;
rec = &motapp->dbse->movie_list[rnbr];
dbse_rec_default(rec);
for (indx2 = 0; indx2 < cols; indx2++) {
if (PQgetvalue(res, indx, indx2) != NULL) {
if (mystrceq(PQfname(res, indx2), "recordid")) {
rec->recordid = atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"camid")) {
rec->camid = atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"movie_nm")) {
free(rec->movie_nm);
flen = strlen(PQgetvalue(res, indx, indx2));
rec->movie_nm = (char*)mymalloc(flen + 1);
snprintf(rec->movie_nm, flen+1, "%s"
,PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"movie_dir")) {
free(rec->movie_dir);
flen = strlen(PQgetvalue(res, indx, indx2));
rec->movie_dir =(char*)mymalloc(flen + 1);
snprintf(rec->movie_dir, flen+1, "%s"
,PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"full_nm")) {
free(rec->full_nm);
flen = strlen(PQgetvalue(res, indx, indx2));
rec->full_nm =(char*)mymalloc(flen + 1);
snprintf(rec->full_nm, flen+1, "%s"
,PQgetvalue(res, indx, indx2));
if (stat(rec->full_nm, &statbuf) == 0) {
rec->found = true;
}
} else if (mystrceq(PQfname(res, indx2),"movie_sz")) {
rec->movie_sz =atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"movie_dtl")) {
rec->movie_dtl =atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"movie_tmc")) {
free(rec->movie_tmc);
flen = strlen(PQgetvalue(res, indx, indx2));
rec->movie_tmc =(char*)mymalloc(flen + 1);
snprintf(rec->movie_tmc, flen+1, "%s"
,PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"diff_avg")) {
rec->diff_avg =atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"sdev_min")) {
rec->sdev_min =atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"sdev_max")) {
rec->sdev_max =atoi(PQgetvalue(res, indx, indx2));
} else if (mystrceq(PQfname(res, indx2),"sdev_avg")) {
rec->sdev_avg =atoi(PQgetvalue(res, indx, indx2));
}
}
}
motapp->dbse->rec_indx++;
}
PQclear(res);
}
return;
}
static void dbse_pgsql_cols(struct ctx_motapp *motapp)
{
int indx;
std::string sqlquery;
dbse_cols_list(motapp);
sqlquery = " select * from motionplus;";
motapp->dbse->dbse_action = DBSE_ACT_GETCOLS;
dbse_pgsql_recs(motapp, sqlquery.c_str());
for (indx=0; indx<motapp->dbse->cols_cnt; indx++) {
if (motapp->dbse->cols_list[indx].found == false) {
sqlquery = "Alter table motionplus add column ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_nm) + " ";
sqlquery += std::string(motapp->dbse->cols_list[indx].col_typ) + " ;";
dbse_pgsql_exec(motapp,sqlquery.c_str());
}
}
dbse_cols_free(motapp);
}
static void dbse_pgsql_setup(struct ctx_motapp *motapp)
{
std::string sqlquery;
sqlquery =
" select tablename as table_nm "
" from pg_catalog.pg_tables "
" where schemaname != 'pg_catalog' "
" and schemaname != 'information_schema' "
" and tablename = 'motionplus';";
motapp->dbse->dbse_action = DBSE_ACT_CHKTBL;
dbse_pgsql_recs(motapp,sqlquery.c_str());
if (motapp->dbse->table_ok == false) {
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("Creating motionplus table"));
sqlquery =
"create table motionplus ("
" recordid serial "
");";
dbse_pgsql_exec(motapp,sqlquery.c_str());
}
dbse_pgsql_cols(motapp);
}
static void dbse_pgsql_init(struct ctx_motapp *motapp)
{
std::string constr;
motapp->dbse->database_pgsql = NULL;
if (motapp->dbse->database_type != "postgresql") {
return;
}
constr = "dbname='" + motapp->dbse->database_dbname + "' ";
constr += " host='" + motapp->dbse->database_host + "' ";
constr += " user='" + motapp->dbse->database_user + "' ";
constr += " password='" + motapp->dbse->database_password + "' ";
constr += " port="+std::to_string(motapp->dbse->database_port) + " ";
motapp->dbse->database_pgsql = PQconnectdb(constr.c_str());
if (PQstatus(motapp->dbse->database_pgsql) == CONNECTION_BAD) {
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
, _("Connection to PostgreSQL database '%s' failed: %s")
, motapp->dbse->database_dbname.c_str()
, PQerrorMessage(motapp->dbse->database_pgsql));
MOTION_LOG(ERR, TYPE_DB, NO_ERRNO
,_("Disabling database functionality"));
dbse_close(motapp);
motapp->dbse->database_type = "";
return;
}
dbse_pgsql_setup(motapp);
MOTION_LOG(INF, TYPE_DB, NO_ERRNO
, _("%s database opened")
, motapp->dbse->database_dbname.c_str() );
}
static void dbse_pgsql_movlst(struct ctx_motapp *motapp)
{
int indx;
std::string sqlquery, delimit;
sqlquery =
"select count(*) as movie_cnt "
" from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETCNT;
dbse_pgsql_recs(motapp, sqlquery.c_str());
if (motapp->dbse->movie_cnt > 0) {
motapp->dbse->movie_list =(ctx_dbse_rec *)
mymalloc(sizeof(ctx_dbse_rec)*motapp->dbse->movie_cnt);
sqlquery =" select * from motionplus ;";
motapp->dbse->dbse_action = DBSE_ACT_GETTBL;
dbse_pgsql_recs(motapp, sqlquery.c_str());
sqlquery =
" delete from motionplus "
" where recordid in (";
delimit = " ";
for (indx=0; indx<motapp->dbse->movie_cnt; indx++) {
if (motapp->dbse->movie_list[indx].found == false) {
sqlquery += delimit + std::to_string(
motapp->dbse->movie_list[indx].recordid);
delimit = ",";
}
/* 5000 is arbitrary */
if (sqlquery.length() > 5000) {
indx = motapp->dbse->movie_cnt;
}
}
sqlquery += ");";
if (delimit == ",") {
dbse_pgsql_exec(motapp, sqlquery.c_str());
}
}
return;
}
#endif /*HAVE_PGSQL*/
void dbse_init(struct ctx_motapp *motapp)
{
motapp->dbse = new ctx_dbse;
motapp->dbse->database_busy_timeout = motapp->cam_list[0]->conf->database_busy_timeout;
motapp->dbse->database_dbname = motapp->cam_list[0]->conf->database_dbname;
motapp->dbse->database_host = motapp->cam_list[0]->conf->database_host;
motapp->dbse->database_password = motapp->cam_list[0]->conf->database_password;
motapp->dbse->database_port = motapp->cam_list[0]->conf->database_port;
motapp->dbse->database_type = motapp->cam_list[0]->conf->database_type;
motapp->dbse->database_user = motapp->cam_list[0]->conf->database_user;
motapp->dbse->movie_cnt = 0;
motapp->dbse->movie_list = NULL;
motapp->dbse->cols_cnt = 0;
motapp->dbse->cols_list = NULL;
pthread_mutex_init(&motapp->dbse->mutex_dbse, NULL);
if (motapp->dbse->database_type != "") {
if (dbse_edits(motapp) == -1) {
return;
}
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO,_("Initializing database"));
pthread_mutex_lock(&motapp->dbse->mutex_dbse);
#ifdef HAVE_MYSQL
if (motapp->dbse->database_type == "mysql") {
dbse_mysql_init(motapp);
}
#endif
#ifdef HAVE_MARIADB
if (motapp->dbse->database_type == "mariadb") {
dbse_mariadb_init(motapp);
}
#endif
#ifdef HAVE_PGSQL
if (motapp->dbse->database_type == "postgresql") {
dbse_pgsql_init(motapp);
}
#endif
#ifdef HAVE_SQLITE3
if (motapp->dbse->database_type == "sqlite3") {
dbse_sqlite3_init(motapp);
}
#endif
pthread_mutex_unlock(&motapp->dbse->mutex_dbse);
}
}
/* Populate the list of the movies from the database*/
void dbse_movies_getlist(struct ctx_motapp *motapp)
{
if (motapp->dbse->database_type == "") {
return;
}
dbse_movies_free(motapp);
pthread_mutex_lock(&motapp->dbse->mutex_dbse);
#ifdef HAVE_MYSQL
if (cam->motapp->dbse->database_type == "mysql") {
}
#endif
#ifdef HAVE_MARIADB
if (motapp->dbse->database_type == "mariadb") {
dbse_mariadb_movlst(motapp);
}
#endif
#ifdef HAVE_PGSQL
if (motapp->dbse->database_type == "postgresql") {
dbse_pgsql_movlst(motapp);
}
#endif
#ifdef HAVE_SQLITE3
if (motapp->dbse->database_type == "sqlite3") {
dbse_sqlite3_movlst(motapp);
}
#endif
pthread_mutex_unlock(&motapp->dbse->mutex_dbse);
}
void dbse_close(struct ctx_motapp *motapp)
{
#ifdef HAVE_MYSQL
dbse_mysql_close(motapp);
#endif
#ifdef HAVE_MARIADB
dbse_mariadb_close(motapp);
#endif
#ifdef HAVE_PGSQL
dbse_pgsql_close(motapp);
#endif
#ifdef HAVE_SQLITE3
dbse_sqlite3_close(motapp);
#endif
}
void dbse_deinit(struct ctx_motapp *motapp)
{
dbse_movies_free(motapp);
dbse_cols_free(motapp);
dbse_close(motapp);
pthread_mutex_destroy(&motapp->dbse->mutex_dbse);
if (motapp->dbse != NULL) {
delete motapp->dbse;
}
}
/* Execute sql against database with mutex lock */
void dbse_exec_sql(struct ctx_motapp *motapp, const char *sqlquery)
{
if (motapp->dbse->database_type == "") {
return;
}
pthread_mutex_lock(&motapp->dbse->mutex_dbse);
#ifdef HAVE_MYSQL
if (motapp->dbse->database_type == "mysql") {
dbse_mysql_exec(motapp, sqlquery);
}
#endif
#ifdef HAVE_MARIADB
if (motapp->dbse->database_type == "mariadb") {
dbse_mariadb_exec(motapp, sqlquery);
}
#endif
#ifdef HAVE_PGSQL
if (motapp->dbse->database_type == "postgresql") {
dbse_pgsql_exec(motapp, sqlquery);
}
#endif
#ifdef HAVE_SQLITE3
if (motapp->dbse->database_type == "sqlite3") {
dbse_sqlite3_exec(motapp, sqlquery);
}
#endif
pthread_mutex_unlock(&motapp->dbse->mutex_dbse);
}
/* Create and execute user provided sql with mutex lock*/
void dbse_exec(struct ctx_cam *cam, char *filename
, int sqltype, struct timespec *ts1, const char *cmd)
{
char sqlquery[PATH_MAX];
if (cam->motapp->dbse->database_type == "") {
return;
}
if (mystrceq(cmd,"pic_save")) {
mystrftime(cam, sqlquery, sizeof(sqlquery)
, cam->conf->sql_pic_save.c_str()
, ts1, filename, sqltype);
} else if (mystrceq(cmd,"movie_start")) {
mystrftime(cam, sqlquery, sizeof(sqlquery)
, cam->conf->sql_movie_start.c_str()
, ts1, filename, sqltype);
} else if (mystrceq(cmd,"movie_end")) {
mystrftime(cam, sqlquery, sizeof(sqlquery)
, cam->conf->sql_movie_end.c_str()
, ts1, filename, sqltype);
} else if (mystrceq(cmd,"event_start")) {
mystrftime(cam, sqlquery, sizeof(sqlquery)
, cam->conf->sql_event_start.c_str()
, ts1, filename, sqltype);
} else if (mystrceq(cmd,"event_end")) {
mystrftime(cam, sqlquery, sizeof(sqlquery)
, cam->conf->sql_event_end.c_str()
, ts1, filename, sqltype);
}
if (strlen(sqlquery) <= 0) {
return;
}
MOTION_LOG(DBG, TYPE_DB, NO_ERRNO, "%s query: %s", cmd, sqlquery);
dbse_exec_sql(cam->motapp, sqlquery);
}
/* Add a record to motionplus table for new movies */
void dbse_movies_addrec(ctx_cam *cam, ctx_movie *movie, timespec *ts1)
{
std::string sqlquery;
struct stat statbuf;
int64_t bsz;
char dtl[12];
char tmc[12];
uint64_t diff_avg, sdev_avg;
struct tm timestamp_tm;
if (cam->motapp->dbse->database_type == "") {
return;
}
/* Movie file times */
if (stat(movie->full_nm, &statbuf) == 0) {
bsz = statbuf.st_size;
} else {
bsz = 0;
}
localtime_r(&ts1->tv_sec, &timestamp_tm);
strftime(dtl, 11, "%G%m%d", &timestamp_tm);
strftime(tmc, 11, "%I:%M%p", &timestamp_tm);
if (cam->info_diff_cnt != 0) {
diff_avg = (cam->info_diff_tot / cam->info_diff_cnt);
} else {
diff_avg =0;
}
if (cam->info_diff_cnt != 0) {
sdev_avg = (cam->info_sdev_tot / cam->info_diff_cnt);
} else {
sdev_avg =0;
}
sqlquery = "insert into motionplus ";
sqlquery += " (camid, movie_nm, movie_dir, full_nm, movie_sz, movie_dtl";
sqlquery += " , movie_tmc, diff_avg, sdev_min, sdev_max, sdev_avg)";
sqlquery += " values ("+std::to_string(cam->camera_id);
sqlquery += " ,'" + std::string(movie->movie_nm) + "'";
sqlquery += " ,'" + std::string(movie->movie_dir) + "'";
sqlquery += " ,'" + std::string(movie->full_nm) + "'";
sqlquery += " ," + std::to_string(bsz);
sqlquery += " ," + std::string(dtl);
sqlquery += " ,'" + std::string(tmc)+ "'";
sqlquery += " ," + std::to_string(diff_avg);
sqlquery += " ," + std::to_string(cam->info_sdev_min);
sqlquery += " ," + std::to_string(cam->info_sdev_max);
sqlquery += " ," + std::to_string(sdev_avg);
sqlquery += ")";
dbse_exec_sql(cam->motapp, sqlquery.c_str());
}
Reference in New Issue View Git Blame Copy Permalink