Skip to content

Commit 7b1b312

Browse files
committed
Updated SQL parameter strings.
1 parent d99cdc2 commit 7b1b312

File tree

2 files changed

+21
-12
lines changed

2 files changed

+21
-12
lines changed

src/dm_db.f90

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4317,11 +4317,11 @@ logical function db_has(db, table, id) result(has)
43174317

43184318
sql_block: block
43194319
select case (table)
4320-
case (SQL_TABLE_LOGS); rc = db_prepare(db, db_stmt, SQL_EXISTS_LOG)
4321-
case (SQL_TABLE_NODES); rc = db_prepare(db, db_stmt, SQL_EXISTS_NODE)
4322-
case (SQL_TABLE_OBSERVS); rc = db_prepare(db, db_stmt, SQL_EXISTS_OBSERV)
4323-
case (SQL_TABLE_SENSORS); rc = db_prepare(db, db_stmt, SQL_EXISTS_SENSOR)
4324-
case (SQL_TABLE_TARGETS); rc = db_prepare(db, db_stmt, SQL_EXISTS_TARGET)
4320+
case (SQL_TABLE_LOGS); rc = db_prepare(db, db_stmt, SQL_HAS_LOG)
4321+
case (SQL_TABLE_NODES); rc = db_prepare(db, db_stmt, SQL_HAS_NODE)
4322+
case (SQL_TABLE_OBSERVS); rc = db_prepare(db, db_stmt, SQL_HAS_OBSERV)
4323+
case (SQL_TABLE_SENSORS); rc = db_prepare(db, db_stmt, SQL_HAS_SENSOR)
4324+
case (SQL_TABLE_TARGETS); rc = db_prepare(db, db_stmt, SQL_HAS_TARGET)
43254325
case default; return
43264326
end select
43274327
if (dm_is_error(rc)) exit sql_block

src/dm_sql.f90

Lines changed: 16 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -497,31 +497,31 @@ module dm_sql
497497
! **************************************************************************
498498
! Query to check if log exists.
499499
! Arguments: logs.id
500-
character(len=*), parameter, public :: SQL_EXISTS_LOG = &
500+
character(len=*), parameter, public :: SQL_HAS_LOG = &
501501
"SELECT EXISTS(SELECT 1 FROM logs WHERE logs.id = ? LIMIT 1)"
502502

503503
! Query to check if node exists.
504504
! Arguments: nodes.id
505-
character(len=*), parameter, public :: SQL_EXISTS_NODE = &
505+
character(len=*), parameter, public :: SQL_HAS_NODE = &
506506
"SELECT EXISTS(SELECT 1 FROM nodes WHERE nodes.id = ? LIMIT 1)"
507507

508508
! Query to check if observation exists.
509509
! Arguments: observs.id
510-
character(len=*), parameter, public :: SQL_EXISTS_OBSERV = &
510+
character(len=*), parameter, public :: SQL_HAS_OBSERV = &
511511
"SELECT EXISTS(SELECT 1 FROM observs WHERE observs.id = ? LIMIT 1)"
512512

513513
! Query to check if sensor exists.
514514
! Arguments: sensors.id
515-
character(len=*), parameter, public :: SQL_EXISTS_SENSOR = &
515+
character(len=*), parameter, public :: SQL_HAS_SENSOR = &
516516
"SELECT EXISTS(SELECT 1 FROM sensors WHERE sensors.id = ? LIMIT 1)"
517517

518518
! Query to check if target exists.
519519
! Arguments: targets.id
520-
character(len=*), parameter, public :: SQL_EXISTS_TARGET = &
520+
character(len=*), parameter, public :: SQL_HAS_TARGET = &
521521
"SELECT EXISTS(SELECT 1 FROM targets WHERE targets.id = ? LIMIT 1)"
522522

523523
! **************************************************************************
524-
! SELECT QUERIES.
524+
! SELECT COUNT QUERIES.
525525
! **************************************************************************
526526
character(len=*), parameter, public :: SQL_SELECT_NBEATS = &
527527
"SELECT COUNT(row_id) FROM beats"
@@ -558,6 +558,9 @@ module dm_sql
558558
"SELECT COUNT(sensors.row_id) FROM sensors " // &
559559
"INNER JOIN nodes ON nodes.row_id = sensors.node_id"
560560

561+
! **************************************************************************
562+
! SELECT QUERIES.
563+
! **************************************************************************
561564
! Query to select beats.
562565
character(len=*), parameter, public :: SQL_SELECT_BEATS = &
563566
"SELECT " // &
@@ -612,7 +615,7 @@ module dm_sql
612615
"nodes.alt " // &
613616
"FROM nodes"
614617

615-
! Query to select of observation ids.
618+
! Query to select observation ids.
616619
character(len=*), parameter, public :: SQL_SELECT_OBSERV_IDS = &
617620
"SELECT observs.id FROM observs " // &
618621
"INNER JOIN nodes ON nodes.row_id = observs.node_id " // &
@@ -840,6 +843,9 @@ module dm_sql
840843
"code = excluded.code, " // &
841844
"attempts = excluded.attempts"
842845

846+
! **************************************************************************
847+
! SELECT SYNC COUNT QUERIES.
848+
! **************************************************************************
843849
! Query to select the number of logs to synchronise.
844850
character(len=*), parameter, public :: SQL_SELECT_NSYNC_LOGS = &
845851
"SELECT COUNT(logs.row_id) FROM logs " // &
@@ -870,6 +876,9 @@ module dm_sql
870876
"LEFT JOIN sync_targets ON sync_targets.target_id = targets.row_id " // &
871877
"WHERE sync_targets.target_id IS NULL OR sync_targets.code NOT IN (201, 409)"
872878

879+
! **************************************************************************
880+
! SELECT SYNC QUERIES.
881+
! **************************************************************************
873882
! Query to select logs.id and sync_logs meta data of unsynchronised logs.
874883
character(len=*), parameter, public :: SQL_SELECT_SYNC_LOGS = &
875884
"SELECT " // &

0 commit comments

Comments
 (0)