|
|
@ -117,9 +117,9 @@ from queue_member;", NULL }, |
|
|
|
{ Update_queuenumber, "update queue set queue_number=? where queue_name=?;", NULL }, |
|
|
|
{ Update_queuenumber, "update queue set queue_number=? where queue_name=?;", NULL }, |
|
|
|
|
|
|
|
|
|
|
|
/* bridge */ |
|
|
|
/* bridge */ |
|
|
|
{ Insert_bridge, "INSERT INTO bridge ( uniqueid, `type`, technology, creator, name, num_channels, vide_source_mode ) VALUES( ?, ?, ?, ?, ?, ?, ? );", NULL }, |
|
|
|
{ Insert_bridge, "INSERT INTO bridge ( uniqueid, `type`, technology, creator, name, num_channels, video_source_mode ) VALUES( ?, ?, ?, ?, ?, ?, ? );", NULL }, |
|
|
|
{ Select_bridge, "SELECT id, `type`, technology, creator, name, num_channels, vide_source_mode FROM bridge where uniqueid=?;", NULL }, |
|
|
|
{ Select_bridge, "SELECT id, `type`, technology, creator, name, num_channels, video_source_mode FROM bridge where uniqueid=?;", NULL }, |
|
|
|
{ Update_bridge, "UPDATE bridge SET `type`=?, technology=?, creator=?, name=?, num_channels=?, vide_source_mode=? WHERE uniqueid=?;", NULL }, |
|
|
|
{ Update_bridge, "UPDATE bridge SET `type`=?, technology=?, creator=?, name=?, num_channels=?, video_source_mode=? WHERE uniqueid=?;", NULL }, |
|
|
|
{ Delete_bridge, "DELETE FROM bridge WHERE uniqueid=?;", NULL }, |
|
|
|
{ Delete_bridge, "DELETE FROM bridge WHERE uniqueid=?;", NULL }, |
|
|
|
{ Delete_bridge_bridge_member, "DELETE FROM bridge_member WHERE bridge_id=( select id from bridge where uniqueid = ?);", NULL }, |
|
|
|
{ Delete_bridge_bridge_member, "DELETE FROM bridge_member WHERE bridge_id=( select id from bridge where uniqueid = ?);", NULL }, |
|
|
|
|
|
|
|
|
|
|
@ -283,7 +283,7 @@ int connect_db(s_manager *smanager){ |
|
|
|
time_loop++; |
|
|
|
time_loop++; |
|
|
|
} |
|
|
|
} |
|
|
|
else { |
|
|
|
else { |
|
|
|
_NOTICE("Banco de dados connectado"); |
|
|
|
_NOTICE("Conectado com o banco de dados"); |
|
|
|
|
|
|
|
|
|
|
|
_database.disconnected = 0; |
|
|
|
_database.disconnected = 0; |
|
|
|
_database.thread_id = mysql_thread_id(_database.mariadb); |
|
|
|
_database.thread_id = mysql_thread_id(_database.mariadb); |
|
|
@ -316,7 +316,7 @@ void *init_thread(void *param){ |
|
|
|
connect_db(smanager); |
|
|
|
connect_db(smanager); |
|
|
|
|
|
|
|
|
|
|
|
/* mandará informação para o systemd */ |
|
|
|
/* mandará informação para o systemd */ |
|
|
|
sd_notifyf( 0, "STATUS=Banco de dados conectado" ); |
|
|
|
sd_notifyf( 0, "STATUS=Conectado com o banco de dados" ); |
|
|
|
|
|
|
|
|
|
|
|
if(init_stmt() == -1){ |
|
|
|
if(init_stmt() == -1){ |
|
|
|
_exit(-1); /* Erro fatal não foi possível
|
|
|
|
_exit(-1); /* Erro fatal não foi possível
|
|
|
|