JDBC Feeder Empty

Gatling (Open-Source)
1

Maven Project
mssql jdbc driver

Was able to get this to work using Java classes, but not using gatling jdbc library.

package tests.performance.sites

import io.gatling.http.Predef._
import io.gatling.core.Predef._
import io.gatling.core.feeder.RecordSeqFeederBuilder
import io.gatling.jdbc.Predef._
import utils.CredsDecryption

class get_sites_baseline extends Simulation {

  val decryptPass = new CredsDecryption("ad_password.properties", "stgPass")
  val adPass = decryptPass.decryptedUserPassword

  val getGatewayKey = new CredsDecryption("api_key.properties", "gatewayKey")
  val gatewayKey = getGatewayKey.decryptedUserPassword

  val accountId = "${ACCOUNT_ID}"

  val sqlQueryFeeder: RecordSeqFeederBuilder[Any] = jdbcFeeder(
    "jdbc:sqlserver://stagesqlserver", "stgRead", s"${adPass}",
    "SELECT TOP (40000) [ACCOUNT_ID] FROM [DB].[dbo].[vw_ACCOUNT] " +
      "WHERE ACCOUNT_STATUS = 'OPEN' " +
      "AND EFFECTIVE_START_DATE < GETDATE() " +
      "ORDER BY EFFECTIVE_START_DATE desc")

  val protocol = http.baseURL("https://stg.api.mycompany.com")

  val getSites = scenario(scenarioName = "Get Sites for Account").feed(sqlQueryFeeder).repeat(1) {
    exec(http("GET Sites")
        .get("/accounts/" + accountId + "/sites")
        .header("api-key", gatewayKey)
        .check(status.is(200))
        .check(jsonPath("$.data[0]").exists))
  }

…
ERROR:

11:09:28.479 [GatlingSystem-akka.actor.default-dispatcher-7] ERROR io.gatling.core.action.SingletonFeed - Feed failed: Feeder is now empty, stopping engine, please report.

2

Was able to fix it by changing password to a variable value, and removed the RecordSeqFeederBuilder, as I believe from docs, this is builtin, and not needed to be called out.

package tests.performance.sites

import io.gatling.http.Predef._
import io.gatling.core.Predef._
import io.gatling.jdbc.Predef._
import utils.CredsDecryption

class get_sites_baseline extends Simulation {

  val decryptPass = new CredsDecryption("ad_password.properties", "stgPass")
  val adPass = decryptPass.decryptedUserPassword

  val getGatewayKey = new CredsDecryption("api_key.properties", "gatewayKey")
  val gatewayKey = getGatewayKey.decryptedUserPassword

  val accountId = "${ACCOUNT_ID}"

  val sqlQueryFeeder = jdbcFeeder(
    "jdbc:sqlserver://stagesqlserver", "stgRead", adPass,
    "SELECT TOP (40000) [ACCOUNT_ID] FROM [DB].[dbo].[vw_ACCOUNT] " +
      "WHERE ACCOUNT_STATUS = 'OPEN' " +
      "AND EFFECTIVE_START_DATE < GETDATE() " +
      "ORDER BY EFFECTIVE_START_DATE desc")

  val protocol = http.baseURL("https://stg.api.mycompany.com")

  val getSites = scenario(scenarioName = "Get Sites for Account").feed(sqlQueryFeeder).repeat(200) {
    exec(http("GET Sites")
        .get("/account/v1/accounts/" + accountId + "/sites")
        .header("api-key", gatewayKey)
        .check(status.is(200))
        .check(jsonPath("$.data[0]").exists))
  }