Method processOnSchedule

extensions/sql/processors/PutSQL.cpp:75–79

}

void PutSQL::processOnSchedule(core::ProcessContext& context) {
  std::string sqlStatements;
  context.getProperty(s_sqlStatements.getName(), sqlStatements);
  sqlStatements_ = utils::StringUtils::split(sqlStatements, ";");
}

void PutSQL::processOnTrigger(core::ProcessSession& session) {
  const auto dbSession = connection_->getSession();