grahamc/hydra2 - Change DKR2GXSAVIZGOR3HEAD46SZWTRXJO2EH43H57P2365Y5M2QCQHDAC

Update libpqxx usage to move away from deprecated API interactions.

Created by Kevin Quick on January 12, 2020

DKR2GXSAVIZGOR3HEAD46SZWTRXJO2EH43H57P2365Y5M2QCQHDAC

Dependencies

In channels

main

Change contents

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 62 [10.575]
B:BD[10.1490] → [10.1490:1527]
```
        auto res = txn.parameterized
```
[10.1490]
[10.1527]
```
        auto res = txn.exec
```

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 64 [10.575]

B:BD[10.1664] → [10.1664:1728]

             "where j.enabled != 0 and p.enabled != 0").exec();

[10.1664]

[10.1728]

             "where j.enabled != 0 and p.enabled != 0");

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 110 [10.575]

B:BD[11.715] → [11.715:952]

            txn.parameterized
                ("update Jobsets set startTime = $1 where project = $2 and name = $3")
                (now)
                (jobset.name.first)
                (jobset.name.second)
                .exec();

[11.715]

[11.952]

            txn.exec_params0
                ("update Jobsets set startTime = $1 where project = $2 and name = $3",
                 now,
                 jobset.name.first,
                 jobset.name.second);

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 268 [10.575]

B:BD[11.1993] → [11.1993:2039]

B:BD[11.2039] → [5.0:162]

∅:D[5.162] → [11.2200:2346]

B:BD[11.2200] → [11.2200:2346]

                            txn.parameterized
                                ("update Jobsets set triggerTime = null where project = $1 and name = $2 and startTime is not null and triggerTime <= startTime")
                                (jobset.name.first)
                                (jobset.name.second)
                                .exec();

[11.1993]

[11.2346]

                            txn.exec_params0
                                ("update Jobsets set triggerTime = null where project = $1 and name = $2 and startTime is not null and triggerTime <= startTime",
                                 jobset.name.first,
                                 jobset.name.second);

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 274 [10.575]

B:BD[11.2403] → [11.2403:2700]

                            txn.parameterized
                                ("update Jobsets set startTime = null where project = $1 and name = $2")
                                (jobset.name.first)
                                (jobset.name.second)
                                .exec();

[11.2403]

[12.31]

                            txn.exec_params0
                                ("update Jobsets set startTime = null where project = $1 and name = $2",
                                 jobset.name.first,
                                 jobset.name.second);

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 280 [10.575]

B:BD[12.225] → [12.225:275]

B:BD[12.275] → [11.2701:2867]

∅:D[11.2867] → [12.364:447]

B:BD[12.364] → [12.364:447]

B:BD[12.447] → [11.2868:3023]

∅:D[11.3023] → [12.493:538]

B:BD[12.493] → [12.493:538]

                                txn.parameterized
                                    ("update Jobsets set errorMsg = $1, lastCheckedTime = $2, errorTime = $2, fetchErrorMsg = null where project = $3 and name = $4")
                                    (fmt("evaluation %s", statusToString(status)))
                                    (now)
                                    (jobset.name.first)
                                    (jobset.name.second)
                                    .exec();

[12.113]

[12.584]

                                txn.exec_params0
                                    ("update Jobsets set errorMsg = $1, lastCheckedTime = $2, errorTime = $2, fetchErrorMsg = null where project = $3 and name = $4",
                                     fmt("evaluation %s", statusToString(status)),
                                     now,
                                     jobset.name.first,
                                     jobset.name.second);

Replacement in src/hydra-evaluator/hydra-evaluator.cc at line 310 [10.575]

B:BD[11.3277] → [11.3277:3350]

        txn.parameterized("update Jobsets set startTime = null").exec();

[11.3277]

[11.3350]

        txn.exec("update Jobsets set startTime = null");

Replacement in src/hydra-queue-runner/builder.cc at line 427 [13.133]

B:BD[13.12489] → [13.12489:12527]

B:BD[13.12527] → [14.0:190]

∅:D[15.184] → [13.12696:12733]

∅:D[14.190] → [13.12696:12733]

B:BD[13.12696] → [13.12696:12733]

B:BD[13.12733] → [16.3520:3660]

∅:D[16.3660] → [13.12855:12940]

B:BD[13.12855] → [13.12855:12940]

B:BD[13.12940] → [16.3661:3740]

                    txn.parameterized
                        ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $4, isCachedBuild = $5, notificationPendingSince = $4 where id = $1 and finished = 0")
                        (build2->id)
                        ((int) (build2->drvPath != step->drvPath && result.buildStatus() == bsFailed ? bsDepFailed : result.buildStatus()))
                        (result.startTime)
                        (result.stopTime)
                        (result.stepStatus == bsCachedFailure ? 1 : 0).exec();

[13.12489]

[13.12996]

                    txn.exec_params0
                        ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $4, isCachedBuild = $5, notificationPendingSince = $4 where id = $1 and finished = 0",
                         build2->id,
                         (int) (build2->drvPath != step->drvPath && result.buildStatus() == bsFailed ? bsDepFailed : result.buildStatus()),
                         result.startTime,
                         result.stopTime,
                         result.stepStatus == bsCachedFailure ? 1 : 0);

Replacement in src/hydra-queue-runner/builder.cc at line 441 [13.133]

∅:D[17.759] → [13.13314:13409]

B:BD[13.13314] → [13.13314:13409]

                        txn.parameterized("insert into FailedPaths values ($1)")(path).exec();

[17.759]

[13.13409]

                        txn.exec_params0("insert into FailedPaths values ($1)", path);

Insertion in src/hydra-queue-runner/hydra-queue-runner.cc at line 3 [19.4840]
[18.286]
[18.286]
```
#include <optional>
```

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 230 [19.4840]

∅:D[20.268] → [21.0:22]

∅:D[22.447] → [21.0:22]

B:BD[19.7845] → [21.0:22]

B:BD[21.22] → [8.813:900]

∅:D[8.900] → [23.425:451]

B:BD[19.7964] → [23.425:451]

∅:D[23.451] → [21.50:92]

B:BD[21.50] → [21.50:92]

    txn.parameterized
        ("update BuildSteps set busy = 0, status = $1, stopTime = $2 where busy != 0")
        ((int) bsAborted)
        (stopTime, stopTime != 0).exec();

[20.268]

[19.8053]

    txn.exec_params0
        ("update BuildSteps set busy = 0, status = $1, stopTime = $2 where busy != 0",
         (int) bsAborted,
         stopTime != 0 ? std::make_optional(stopTime) : std::nullopt);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 240 [19.4840]

B:BD[24.198] → [25.2702:2807]

∅:D[25.2807] → [26.63:125]

B:BD[19.8363] → [26.63:125]

    auto res = txn.parameterized("select max(stepnr) from BuildSteps where build = $1")(buildId).exec();
    return res[0][0].is_null() ? 1 : res[0][0].as<int>() + 1;

[19.8256]

[26.125]

    auto res = txn.exec_params1("select max(stepnr) from BuildSteps where build = $1", buildId);
    return res[0].is_null() ? 1 : res[0].as<int>() + 1;

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 251 [19.4840]

B:BD[19.8432] → [7.11:268]

∅:D[7.268] → [25.2963:2981]

B:BD[27.578] → [25.2963:2981]

∅:D[25.2981] → [26.405:470]

B:BD[26.405] → [26.405:470]

B:BD[26.470] → [23.560:595]

∅:D[26.506] → [28.73:138]

∅:D[23.595] → [28.73:138]

B:BD[28.73] → [28.73:138]

B:BD[28.138] → [23.596:637]

∅:D[23.637] → [21.262:343]

B:BD[21.262] → [21.262:343]

B:BD[21.343] → [23.638:694]

∅:D[28.196] → [29.49:75]

∅:D[23.694] → [29.49:75]

B:BD[27.618] → [29.49:75]

    auto r = txn.parameterized
        ("insert into BuildSteps (build, stepnr, type, drvPath, busy, startTime, system, status, propagatedFrom, errorMsg, stopTime, machine) values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) on conflict do nothing")
        (buildId)
        (stepNr)
        (0) // == build
        (step->drvPath)
        (status == bsBusy ? 1 : 0)
        (startTime, startTime != 0)
        (step->drv.platform)
        ((int) status, status != bsBusy)
        (propagatedFrom, propagatedFrom != 0)
        (errorMsg, errorMsg != "")
        (startTime, startTime != 0 && status != bsBusy)
        (machine).exec();

[19.8432]

[7.269]

    auto r = txn.exec_params
        ("insert into BuildSteps (build, stepnr, type, drvPath, busy, startTime, system, status, propagatedFrom, errorMsg, stopTime, machine) values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12) on conflict do nothing",
         buildId,
         stepNr,
         0, // == build
         step->drvPath,
         status == bsBusy ? 1 : 0,
         startTime != 0 ? std::make_optional(startTime) : std::nullopt,
         step->drv.platform,
         status != bsBusy ? std::make_optional((int) status) : std::nullopt,
         propagatedFrom != 0 ? std::make_optional(propagatedFrom) : std::nullopt, // internal::params
         errorMsg != "" ? std::make_optional(errorMsg) : std::nullopt,
         startTime != 0 && status != bsBusy ? std::make_optional(startTime) : std::nullopt,
         machine);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 269 [19.4840]

B:BD[19.9041] → [19.9041:9164]

B:BD[19.9164] → [25.2982:3054]

        txn.parameterized
            ("insert into BuildStepOutputs (build, stepnr, name, path) values ($1, $2, $3, $4)")
            (buildId)(stepNr)(output.first)(output.second.path).exec();

[19.9041]

[19.9238]

        txn.exec_params0
            ("insert into BuildStepOutputs (build, stepnr, name, path) values ($1, $2, $3, $4)",
             buildId, stepNr, output.first, output.second.path);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 282 [19.4840]

B:BD[8.1012] → [8.1012:1247]

    if (txn.parameterized
        ("update BuildSteps set busy = $1 where build = $2 and stepnr = $3 and busy != 0 and status is null")
        ((int) stepState)
        (buildId)
        (stepNr)
        .exec().affected_rows() != 1)

[8.1012]

[8.1247]

    if (txn.exec_params
        ("update BuildSteps set busy = $1 where build = $2 and stepnr = $3 and busy != 0 and status is null",
         (int) stepState,
         buildId,
         stepNr).affected_rows() != 1)

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 296 [19.4840]

∅:D[30.1496] → [21.391:413]

∅:D[31.9600] → [21.391:413]

B:BD[19.9438] → [21.391:413]

B:BD[21.413] → [30.1497:1848]

∅:D[30.1848] → [32.1316:1349]

B:BD[27.973] → [32.1316:1349]

B:BD[32.1349] → [30.1849:2024]

    txn.parameterized
        ("update BuildSteps set busy = 0, status = $1, errorMsg = $4, startTime = $5, stopTime = $6, machine = $7, overhead = $8, timesBuilt = $9, isNonDeterministic = $10 where build = $2 and stepnr = $3")
        ((int) result.stepStatus)(buildId)(stepNr)
        (result.errorMsg, result.errorMsg != "")
        (result.startTime)(result.stopTime)
        (machine, machine != "")
        (result.overhead, result.overhead != 0)
        (result.timesBuilt, result.timesBuilt > 0)
        (result.isNonDeterministic, result.timesBuilt > 1)
        .exec();

[30.1496]

[9.0]

    txn.exec_params0
        ("update BuildSteps set busy = 0, status = $1, errorMsg = $4, startTime = $5, stopTime = $6, machine = $7, overhead = $8, timesBuilt = $9, isNonDeterministic = $10 where build = $2 and stepnr = $3",
         (int) result.stepStatus, buildId, stepNr,
         result.errorMsg != "" ? std::make_optional(result.errorMsg) : std::nullopt,
         result.startTime, result.stopTime,
         machine != "" ? std::make_optional(machine) : std::nullopt,
         result.overhead != 0 ? std::make_optional(result.overhead) : std::nullopt,
         result.timesBuilt > 0 ? std::make_optional(result.timesBuilt) : std::nullopt,
         result.timesBuilt > 1 ? std::make_optional(result.isNonDeterministic) : std::nullopt);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 317 [19.4840]

B:BD[26.737] → [7.328:523]

∅:D[7.523] → [26.900:1057]

B:BD[26.900] → [26.900:1057]

    auto r = txn.parameterized
        ("insert into BuildSteps (build, stepnr, type, drvPath, busy, status, startTime, stopTime) values ($1, $2, $3, $4, $5, $6, $7, $8) on conflict do nothing")
        (build->id)
        (stepNr)
        (1) // == substitution
        (drvPath)
        (0)
        (0)
        (startTime)
        (stopTime).exec();

[26.737]

[7.524]

    auto r = txn.exec_params
        ("insert into BuildSteps (build, stepnr, type, drvPath, busy, status, startTime, stopTime) values ($1, $2, $3, $4, $5, $6, $7, $8) on conflict do nothing",
         build->id,
         stepNr,
         1, // == substitution
         drvPath,
         0,
         0,
         startTime,
         stopTime);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 330 [19.4840]

B:BD[26.1058] → [26.1058:1232]

    txn.parameterized
        ("insert into BuildStepOutputs (build, stepnr, name, path) values ($1, $2, $3, $4)")
        (build->id)(stepNr)(outputName)(storePath).exec();

[26.1058]

[26.1232]

    txn.exec_params0
        ("insert into BuildStepOutputs (build, stepnr, name, path) values ($1, $2, $3, $4)",
         build->id, stepNr, outputName, storePath);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 399 [19.4840]

B:BD[2.1] → [2.1:117]

    if (txn.parameterized("select 1 from Builds where id = $1 and finished = 0")(build->id).exec().empty()) return;

[2.1]

[31.14683]

    if (txn.exec_params("select 1 from Builds where id = $1 and finished = 0", build->id).empty()) return;

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 401 [19.4840]

∅:D[31.14684] → [21.578:600]

B:BD[19.17826] → [21.578:600]

B:BD[21.600] → [14.191:395]

∅:D[33.183] → [19.18032:18052]

∅:D[15.358] → [19.18032:18052]

∅:D[14.395] → [19.18032:18052]

∅:D[34.878] → [19.18032:18052]

∅:D[35.1909] → [19.18032:18052]

B:BD[19.18032] → [19.18032:18052]

B:BD[19.18052] → [36.296:358]

∅:D[36.358] → [19.18078:18136]

B:BD[19.18078] → [19.18078:18136]

B:BD[19.18136] → [21.601:716]

    txn.parameterized
        ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $4, size = $5, closureSize = $6, releaseName = $7, isCachedBuild = $8, notificationPendingSince = $4 where id = $1")
        (build->id)
        ((int) (res.failed ? bsFailedWithOutput : bsSuccess))
        (startTime)
        (stopTime)
        (res.size)
        (res.closureSize)
        (res.releaseName, res.releaseName != "")
        (isCachedBuild ? 1 : 0).exec();

[31.14684]

[2.118]

    txn.exec_params0
        ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $4, size = $5, closureSize = $6, releaseName = $7, isCachedBuild = $8, notificationPendingSince = $4 where id = $1",
         build->id,
         (int) (res.failed ? bsFailedWithOutput : bsSuccess),
         startTime,
         stopTime,
         res.size,
         res.closureSize,
         res.releaseName != "" ? std::make_optional(res.releaseName) : std::nullopt,
         isCachedBuild ? 1 : 0);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 412 [19.4840]

B:BD[2.119] → [2.119:206]

    txn.parameterized("delete from BuildProducts where build = $1")(build->id).exec();

[2.119]

[19.18276]

    txn.exec_params0("delete from BuildProducts where build = $1", build->id);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 416 [19.4840]

B:BD[19.18351] → [21.717:743]

∅:D[21.743] → [19.18388:18647]

B:BD[19.18388] → [19.18388:18647]

B:BD[19.18647] → [21.744:824]

B:BD[21.824] → [6.174:326]

∅:D[6.326] → [19.18912:19008]

∅:D[21.948] → [19.18912:19008]

B:BD[19.18912] → [19.18912:19008]

        txn.parameterized
            ("insert into BuildProducts (build, productnr, type, subtype, fileSize, sha1hash, sha256hash, path, name, defaultPath) values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)")
            (build->id)
            (productNr++)
            (product.type)
            (product.subtype)
            (product.fileSize, product.isRegular)
            (product.sha1hash.to_string(Base16, false), product.isRegular)
            (product.sha256hash.to_string(Base16, false), product.isRegular)
            (product.path)
            (product.name)
            (product.defaultPath).exec();

[19.18351]

[19.19008]

        txn.exec_params0
            ("insert into BuildProducts (build, productnr, type, subtype, fileSize, sha1hash, sha256hash, path, name, defaultPath) values ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10)",
             build->id,
             productNr++,
             product.type,
             product.subtype,
             product.isRegular ? std::make_optional(product.fileSize) : std::nullopt,
             product.isRegular ? std::make_optional(product.sha1hash.to_string(Base16, false)) : std::nullopt,
             product.isRegular ? std::make_optional(product.sha256hash.to_string(Base16, false)) : std::nullopt,
             product.path,
             product.name,
             product.defaultPath);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 430 [19.4840]

B:BD[19.19015] → [2.207:293]

    txn.parameterized("delete from BuildMetrics where build = $1")(build->id).exec();

[19.19015]

[2.293]

    txn.exec_params0("delete from BuildMetrics where build = $1", build->id);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 433 [19.4840]

B:BD[37.1372] → [37.1372:1822]

        txn.parameterized
            ("insert into BuildMetrics (build, name, unit, value, project, jobset, job, timestamp) values ($1, $2, $3, $4, $5, $6, $7, $8)")
            (build->id)
            (metric.second.name)
            (metric.second.unit, metric.second.unit != "")
            (metric.second.value)
            (build->projectName)
            (build->jobsetName)
            (build->jobName)
            (build->timestamp).exec();

[37.1372]

[37.1822]

        txn.exec_params0
            ("insert into BuildMetrics (build, name, unit, value, project, jobset, job, timestamp) values ($1, $2, $3, $4, $5, $6, $7, $8)",
             build->id,
             metric.second.name,
             metric.second.unit != "" ? std::make_optional(metric.second.unit) : std::nullopt,
             metric.second.value,
             build->projectName,
             build->jobsetName,
             build->jobName,
             build->timestamp);

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 453 [19.4840]

∅:D[17.808] → [38.1437:1535]

B:BD[38.1437] → [38.1437:1535]

        if (!txn.parameterized("select 1 from FailedPaths where path = $1")(path).exec().empty())

[17.808]

[38.1535]

        if (!txn.exec_params("select 1 from FailedPaths where path = $1", path).empty())

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 679 [19.4840]

B:BD[20.2168] → [20.2168:2269]

        txn.parameterized("insert into SystemStatus values ('queue-runner', $1)")(out.str()).exec();

[20.2168]

[20.2269]

        txn.exec_params0("insert into SystemStatus values ('queue-runner', $1)", out.str());

Replacement in src/hydra-queue-runner/hydra-queue-runner.cc at line 809 [19.4840]

B:BD[39.1064] → [39.1064:1102]

B:BD[39.1102] → [8.1335:1454]

∅:D[8.1454] → [39.1220:1345]

B:BD[39.1220] → [39.1220:1345]

                    txn.parameterized
                        ("update BuildSteps set busy = 0, status = $1 where build = $2 and stepnr = $3 and busy != 0")
                        ((int) bsAborted)
                        (step.first)
                        (step.second).exec();

[39.1064]

[39.1345]

                    txn.exec_params0
                        ("update BuildSteps set busy = 0, status = $1 where build = $2 and stepnr = $3 and busy != 0",
                         (int) bsAborted,
                         step.first,
                         step.second);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 93 [13.20067]
B:BD[13.21931] → [40.133:170]
```
        auto res = txn.parameterized
```
[13.21931]
[3.1211]
```
        auto res = txn.exec_params
```

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 95 [13.20067]

∅:D[3.1337] → [40.286:400]

B:BD[40.286] → [40.286:400]

             "where id > $1 and finished = 0 order by globalPriority desc, id")
            (lastBuildId).exec();

[3.1337]

[13.22108]

             "where id > $1 and finished = 0 order by globalPriority desc, id",
            lastBuildId);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 140 [13.20067]

B:BD[13.23410] → [13.23410:23444]

B:BD[13.23444] → [4.0:135]

∅:D[4.135] → [13.23604:23674]

∅:D[15.509] → [13.23604:23674]

B:BD[13.23604] → [13.23604:23674]

B:BD[13.23674] → [4.136:174]

                txn.parameterized
                    ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $3 where id = $1 and finished = 0")
                    (build->id)
                    ((int) bsAborted)
                    (time(0)).exec();

[13.23410]

[13.23784]

                txn.exec_params0
                    ("update Builds set finished = 1, buildStatus = $2, startTime = $3, stopTime = $3 where id = $1 and finished = 0",
                     build->id,
                     (int) bsAborted,
                     time(0));

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 172 [13.20067]

B:BD[41.931] → [41.931:1236]

                auto res = txn.parameterized
                    ("select max(build) from BuildSteps where drvPath = $1 and startTime != 0 and stopTime != 0 and status = 1")
                    (ex.step->drvPath).exec();
                if (!res[0][0].is_null()) propagatedFrom = res[0][0].as<BuildID>();

[41.931]

[41.1236]

                auto res = txn.exec_params1
                    ("select max(build) from BuildSteps where drvPath = $1 and startTime != 0 and stopTime != 0 and status = 1",
                     ex.step->drvPath);
                if (!res[0].is_null()) propagatedFrom = res[0].as<BuildID>();

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 179 [13.20067]

B:BD[41.1341] → [41.1341:1634]

                        auto res = txn.parameterized
                            ("select max(s.build) from BuildSteps s join BuildStepOutputs o on s.build = o.build where path = $1 and startTime != 0 and stopTime != 0 and status = 1")
                            (output.second.path).exec();

[41.1341]

[41.1634]

                        auto res = txn.exec_params
                            ("select max(s.build) from BuildSteps s join BuildStepOutputs o on s.build = o.build where path = $1 and startTime != 0 and stopTime != 0 and status = 1",
                             output.second.path);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 190 [13.20067]
∅:D[25.3295] → [41.1956:1990]
B:BD[41.1956] → [41.1956:1990]
```
                txn.parameterized
```
[25.3295]
[14.1281]
```
                txn.exec_params
```

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 192 [13.20067]

B:BD[14.1435] → [14.1435:1490]

∅:D[14.1490] → [41.2144:2304]

B:BD[41.2144] → [41.2144:2304]

                     "where id = $1 and finished = 0")
                    (build->id)
                    ((int) (ex.step->drvPath == build->drvPath ? bsFailed : bsDepFailed))
                    (time(0)).exec();

[14.1435]

[42.1146]

                     "where id = $1 and finished = 0",
                     build->id,
                     (int) (ex.step->drvPath == build->drvPath ? bsFailed : bsDepFailed),
                     time(0));

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 557 [13.20067]

B:BD[43.2652] → [43.2652:2809]

    auto res = txn.parameterized
        ("select schedulingShares from Jobsets where project = $1 and name = $2")
        (projectName)(jobsetName).exec();

[43.2652]

[43.2809]

    auto res = txn.exec_params1
        ("select schedulingShares from Jobsets where project = $1 and name = $2",
         projectName,
         jobsetName);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 563 [13.20067]

B:BD[43.2877] → [43.2877:2942]

    auto shares = res[0]["schedulingShares"].as<unsigned int>();

[43.2877]

[43.2975]

    auto shares = res["schedulingShares"].as<unsigned int>();

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 569 [13.20067]
B:BD[43.3084] → [43.3084:3112]
```
    res = txn.parameterized
```
[43.3084]
[43.3112]
```
    auto res2 = txn.exec_params
```

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 571 [13.20067]

B:BD[43.3201] → [43.3201:3414]

         "where s.startTime is not null and s.stopTime > $1 and project = $2 and jobset = $3")
        (time(0) - Jobset::schedulingWindow * 10)(projectName)(jobsetName).exec();
    for (auto const & row : res) {

[43.3201]

[43.3414]

         "where s.startTime is not null and s.stopTime > $1 and project = $2 and jobset = $3",
         time(0) - Jobset::schedulingWindow * 10,
         projectName,
         jobsetName);
    for (auto const & row : res2) {

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 609 [13.20067]
B:BD[44.280] → [44.280:315]
```
        auto r = txn.parameterized
```
[44.280]
[44.315]
```
        auto r = txn.exec_params1
```

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 612 [13.20067]

B:BD[44.454] → [44.454:585]

             "where finished = 1 and (buildStatus = 0 or buildStatus = 6) and path = $1")
            (output.second.path).exec();

[44.454]

[44.585]

             "where finished = 1 and (buildStatus = 0 or buildStatus = 6) and path = $1",
             output.second.path);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 615 [13.20067]
B:BD[44.618] → [44.618:662]
```
        BuildID id = r[0][0].as<BuildID>();
```
[44.618]
[44.662]
```
        BuildID id = r[0].as<BuildID>();
```

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 620 [13.20067]

B:BD[44.762] → [44.762:1063]

        res.failed = r[0][1].as<int>() == bsFailedWithOutput;
        res.releaseName = r[0][2].is_null() ? "" : r[0][2].as<std::string>();
        res.closureSize = r[0][3].is_null() ? 0 : r[0][3].as<unsigned long long>();
        res.size = r[0][4].is_null() ? 0 : r[0][4].as<unsigned long long>();

[44.762]

[44.1063]

        res.failed = r[1].as<int>() == bsFailedWithOutput;
        res.releaseName = r[2].is_null() ? "" : r[2].as<std::string>();
        res.closureSize = r[3].is_null() ? 0 : r[3].as<unsigned long long>();
        res.size = r[4].is_null() ? 0 : r[4].as<unsigned long long>();

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 625 [13.20067]

B:BD[44.1064] → [44.1064:1280]

        auto products = txn.parameterized
            ("select type, subtype, fileSize, sha1hash, sha256hash, path, name, defaultPath from BuildProducts where build = $1 order by productnr")
            (id).exec();

[44.1064]

[44.1280]

        auto products = txn.exec_params
            ("select type, subtype, fileSize, sha1hash, sha256hash, path, name, defaultPath from BuildProducts where build = $1 order by productnr",
             id);

Replacement in src/hydra-queue-runner/queue-monitor.cc at line 651 [13.20067]

B:BD[44.2204] → [44.2204:2346]

        auto metrics = txn.parameterized
            ("select name, unit, value from BuildMetrics where build = $1")
            (id).exec();

[44.2204]

[44.2346]

        auto metrics = txn.exec_params
            ("select name, unit, value from BuildMetrics where build = $1",
             id);