diff options
author | OpenGnSys Support Team <soporte-og@soleta.eu> | 2019-05-17 16:56:41 +0200 |
---|---|---|
committer | OpenGnSys Support Team <soporte-og@soleta.eu> | 2020-03-04 14:54:21 +0100 |
commit | ecff9948e762e42889e35a358fae5131ba443ebc (patch) | |
tree | 468961d3bded5ca59af9db00c65860b64c09256a /sources | |
parent | 0fbdcf260cbbd2e8a267342eff3b10ea13919319 (diff) |
#941 use dbi layer from AutoexecCliente()
Diffstat (limited to 'sources')
-rw-r--r-- | sources/ogAdmServer.cpp | 52 | ||||
-rw-r--r-- | sources/ogAdmServer.h | 4 |
2 files changed, 25 insertions, 31 deletions
diff --git a/sources/ogAdmServer.cpp b/sources/ogAdmServer.cpp index 46e2211..1c0d4b6 100644 --- a/sources/ogAdmServer.cpp +++ b/sources/ogAdmServer.cpp @@ -790,11 +790,11 @@ static bool AutoexecCliente(TRAMA *ptrTrama, struct og_client *cli) { int socket_c = og_client_socket(cli); int lon; - char *iph, *exe, msglog[LONSTD]; - Database db; + char *iph, *exe; FILE *fileexe; char fileautoexec[LONPRM]; char parametros[LONGITUD_PARAMETROS]; + struct og_dbi *dbi; iph = copiaParametro("iph",ptrTrama); // Toma dirección IP del cliente exe = copiaParametro("exe",ptrTrama); // Toma identificador del procedimiento inicial @@ -807,14 +807,14 @@ static bool AutoexecCliente(TRAMA *ptrTrama, struct og_client *cli) return false; } - if (!db.Open(usuario, pasguor, datasource, catalog)) { - db.GetErrorErrStr(msglog); - syslog(LOG_ERR, "cannot open connection database (%s:%d) %s\n", - __func__, __LINE__, msglog); + dbi = og_dbi_open(&dbi_config); + if (!dbi) { + syslog(LOG_ERR, "cannot open connection database (%s:%d)\n", + __func__, __LINE__); return false; } initParametros(ptrTrama,0); - if (recorreProcedimientos(db, parametros, fileexe, exe)) { + if (recorreProcedimientos(dbi, parametros, fileexe, exe)) { lon = sprintf(ptrTrama->parametros, "nfn=RESPUESTA_AutoexecCliente\r"); lon += sprintf(ptrTrama->parametros + lon, "nfl=%s\r", fileautoexec); lon += sprintf(ptrTrama->parametros + lon, "res=1\r"); @@ -823,7 +823,7 @@ static bool AutoexecCliente(TRAMA *ptrTrama, struct og_client *cli) lon += sprintf(ptrTrama->parametros + lon, "res=0\r"); } - db.Close(); + og_dbi_close(dbi); fclose(fileexe); if (!mandaTrama(&socket_c, ptrTrama)) { @@ -847,46 +847,38 @@ static bool AutoexecCliente(TRAMA *ptrTrama, struct og_client *cli) // true: Si el proceso es correcto // false: En caso de ocurrir algún error // ________________________________________________________________________________________________________ -bool recorreProcedimientos(Database db, char *parametros, FILE *fileexe, char *idp) +bool recorreProcedimientos(struct og_dbi *dbi, char *parametros, FILE *fileexe, char *idp) { + char idprocedimiento[LONPRM]; int procedimientoid, lsize; - char idprocedimiento[LONPRM], msglog[LONSTD], sqlstr[LONSQL]; - Table tbl; + const char *msglog, *param; + dbi_result result; - /* Busca procedimiento */ - sprintf(sqlstr, + result = dbi_conn_queryf(dbi->conn, "SELECT procedimientoid,parametros FROM procedimientos_acciones" " WHERE idprocedimiento=%s ORDER BY orden", idp); - // Ejecuta consulta - if (!db.Execute(sqlstr, tbl)) { - db.GetErrorErrStr(msglog); + if (!result) { + dbi_conn_error(dbi->conn, &msglog); syslog(LOG_ERR, "failed to query database (%s:%d) %s\n", __func__, __LINE__, msglog); return false; } - while (!tbl.ISEOF()) { // Recorre procedimientos - if (!tbl.Get("procedimientoid", procedimientoid)) { // Toma dato - tbl.GetErrorErrStr(msglog); // Error al acceder al registro - og_info(msglog); - return false; - } + while (dbi_result_next_row(result)) { + procedimientoid = dbi_result_get_uint(result, "procedimientoid"); if (procedimientoid > 0) { // Procedimiento recursivo sprintf(idprocedimiento, "%d", procedimientoid); - if (!recorreProcedimientos(db, parametros, fileexe, idprocedimiento)) { + if (!recorreProcedimientos(dbi, parametros, fileexe, idprocedimiento)) { return false; } } else { - if (!tbl.Get("parametros", parametros)) { // Toma dato - tbl.GetErrorErrStr(msglog); // Error al acceder al registro - og_info(msglog); - return false; - } - strcat(parametros, "@"); + param = dbi_result_get_string(result, "parametros"); + sprintf(parametros, "%s@", param); lsize = strlen(parametros); fwrite(parametros, 1, lsize, fileexe); // Escribe el código a ejecutar } - tbl.MoveNext(); } + dbi_result_free(result); + return true; } // ________________________________________________________________________________________________________ diff --git a/sources/ogAdmServer.h b/sources/ogAdmServer.h index 22ffd30..bc3e612 100644 --- a/sources/ogAdmServer.h +++ b/sources/ogAdmServer.h @@ -36,13 +36,15 @@ typedef struct{ // Estructura usada para guardar información de los clientes }SOCKETCL; SOCKETCL tbsockets[MAXIMOS_CLIENTES]; +struct og_dbi; + bool registraCliente(char *); bool procesoInclusionClienteWinLnx(int socket, TRAMA*,int*,char*); bool procesoInclusionCliente(struct og_client *, TRAMA*); bool clienteExistente(char *,int *); bool clienteDisponible(char *,int *); bool actualizaConfiguracion(Database , Table ,char* ,int); -bool recorreProcedimientos(Database ,char* ,FILE*,char*); +bool recorreProcedimientos(struct og_dbi *,char* ,FILE*,char*); bool buscaComandos(char *,TRAMA *,int *); bool respuestaConsola(int socket, TRAMA *,int); bool enviaComando(TRAMA *ptrTrama,const char*); |