написание запроса в альпакка кассандра - PullRequest
Новая
       18

написание запроса в альпакка кассандра

0 голосов
/ 02 апреля 2020

Я новичок в Alpakka Cassandra и хочу написать простой запрос на вставку в моем приложении. В настоящее время я использую код ниже: `

val place = Place("ny", LocalDateTime.now(), "hi")
val source = Source.single(place)
val statementBinder: (Place, PreparedStatement) => BoundStatement =
  (elemToInsert, preparedStatement) => preparedStatement.bind(elemToInsert.dateTime, elemToInsert.city, elemToInsert.name)

val written = source
  .via(
    CassandraFlow.create(CassandraWriteSettings.defaults,
      "INSERT INTO test_app.places(date_available, city, name) VALUES (?, ?, ?)",
      statementBinder)
  )
  .runWith(Sink.ignore)

` Я знаю, что проблема в методе Source. потому что, когда я меняю вторую строку на:

val source = Source(1 until 3).map{_ => place}

, это работает, но теперь я заканчиваю тем, что вставляю две строки в таблицу. Как я могу вставить только одну строку, используя Alpakka Cassandra?

...