Использование автоматически увеличивающихся полей с PostgreSQL и Slick

Здесь работает:

object Application extends Table[(Long, String)]("application") {   
    def idlApplication = column[Long]("idlapplication", O.PrimaryKey, O.AutoInc)
    def appName = column[String]("appname")
    def * = idlApplication ~ appName
    def autoInc = appName returning idlApplication
}

var id = Application.autoInc.insert("App1")

Вот как выглядит мой SQL:

CREATE TABLE application
(idlapplication BIGSERIAL PRIMARY KEY,
appName VARCHAR(500));

Обновление:

Конкретная проблема с сопоставленной таблицей с пользователем (как в вопросе) может быть решена следующим образом:

  def forInsert = first ~ last <>
    ({ (f, l) => User(None, f, l) }, { u:User => Some((u.first, u.last)) })

Это из тестовые примеры в репозитории Slick git.

Я решил эту проблему по-другому. Поскольку я ожидаю, что мои объекты User всегда будут иметь идентификатор в логике моего приложения, и единственный момент, когда его не будет, - это во время вставки в базу данных, я использую вспомогательный класс case NewUser, у которого нет идентификатора.

case class User(id: Int, first: String, last: String)
case class NewUser(first: String, last: String)

object Users extends Table[User]("users") {
  def id = column[Int]("id", O.PrimaryKey, O.AutoInc)
  def first = column[String]("first")
  def last = column[String]("last")

  def * = id ~ first ~ last <> (User, User.unapply _)
  def autoInc = first ~ last <> (NewUser, NewUser.unapply _) returning id
}

val id = Users.autoInc.insert(NewUser("John", "Doe"))

Опять же, User сопоставляется 1:1 с записью/строкой базы данных, тогда как NewUser можно заменить кортежем, если вы хотите избежать дополнительного класса case, поскольку он используется только как контейнер данных для вызова insert.

EDIT: Если вам нужна большая безопасность (с несколько большей детализацией), вы можете использовать трейт для классов case, например:

trait UserT {
  def first: String
  def last: String
}
case class User(id: Int, first: String, last: String) extends UserT
case class NewUser(first: String, last: String) extends UserT
// ... the rest remains intact

В этом случае вы сначала примените изменения модели к трейту (включая любые примеси, которые вам могут понадобиться) и, возможно, добавите значения по умолчанию в файл NewUser.

Мнение автора: я по-прежнему предпочитаю решение без признаков, поскольку оно более компактно, а изменения в модели заключаются в копировании и вставке параметров User с последующим удалением id (первичный ключ auto-inc), как в случае объявление класса и в табличных проекциях.

Мы используем немного другой подход. Вместо того, чтобы создавать дополнительную проекцию, мы запрашиваем следующий идентификатор для таблицы, копируем его в класс case и используем проекцию по умолчанию «*» для вставки записи в таблицу.

Для постгреса это выглядит так:

Пусть ваши Table-Objects реализуют эту черту

trait TableWithId { this: Table[_] =>
  /**
   * can be overriden if the plural of tablename is irregular
   **/
  val idColName: String = s"${tableName.dropRight(1)}_id"
  def id = column[Int](s"${idColName}", O.PrimaryKey, O.AutoInc)
  def getNextId = (Q[Int] + s"""select nextval('"${tableName}_${idColName}_seq"')""").first
  }

Всем вашим классам сущностей нужен такой метод (также должен быть определен в трейте):

case class Entity (...) {
  def withId(newId: Id): Entity = this.copy(id = Some(newId)
}

Теперь новые объекты можно вставлять следующим образом:

object Entities extends Table[Entity]("entities") with TableWithId {
  override val idColName: String = "entity_id"
  ...
  def save(entity: Entity) = this insert entity.withId(getNextId) 
}

Код все еще не СУХОЙ, потому что вам нужно определить метод withId для каждой таблицы. Кроме того, вы должны запросить следующий идентификатор, прежде чем вставлять объект, который может привести к снижению производительности, но не должен быть заметным, если вы не вставите тысячи записей за раз.

Основное преимущество заключается в том, что нет необходимости во второй проекции, что делает код менее подверженным ошибкам, особенно для таблиц с большим количеством столбцов.

Самым простым решением было использовать тип SERIAL следующим образом:

def id = column[Long]("id", SqlType("SERIAL"), O.PrimaryKey, O.AutoInc)

Вот более конкретный блок:

// A case class to be used as table map
case class CaseTable( id: Long = 0L, dataType: String, strBlob: String)

// Class for our Table
class MyTable(tag: Tag) extends Table[CaseTable](tag, "mytable") {
  // Define the columns
  def dataType = column[String]("datatype")
  def strBlob = column[String]("strblob")

  // Auto Increment the id primary key column
  def id = column[Long]("id", SqlType("SERIAL"),  O.PrimaryKey,  O.AutoInc)

  // the * projection (e.g. select * ...) auto-transforms the tupled column values
  def * = (id, dataType, strBlob) <> (CaseTable.tupled, CaseTable.unapply _)

}


// Insert and  get auto incremented primary key
def insertData(dataType: String, strBlob: String, id: Long = 0L): Long = {
  // DB Connection
  val db = Database.forURL(jdbcUrl, pgUser, pgPassword, driver = driverClass)
  // Variable to run queries on our table
  val myTable = TableQuery[MyTable]

  val insert = try {
    // Form the query
    val query = myTable returning myTable.map(_.id) += CaseTable(id, dataType, strBlob)
    // Execute it and wait for result
    val autoId = Await.result(db.run(query), maxWaitMins)
    // Return ID
    autoId
  }
  catch {
    case e: Exception => {
      logger.error("Error in inserting using Slick: ", e.getMessage)
      e.printStackTrace()
      -1L
    }
  }
  insert
}

Я столкнулся с той же проблемой, пытаясь сделать образец компьютерной базы данных из play-slick-3.0, когда я изменил базу данных на Postgres. Что решило проблему, так это изменить тип столбца id (первичный ключ) на SERIAL в файле эволюции /conf/evolutions/default/1.sql (изначально был в BIGINT). Взгляните на https://groups.google.com/forum/?fromgroups=#%21topic/scalaquery/OEOF8HNzn2U
для всего обсуждения. Привет, Ренекс

Еще одна хитрость заключается в том, чтобы сделать идентификатор класса case переменным.

case class Entity(var id: Long)

Чтобы вставить экземпляр, создайте его, как показано ниже Entity(null.asInstanceOf[Long])

Я проверил, что это работает.

Решение, которое я нашел, состоит в том, чтобы использовать SqlType("Serial") в определении столбца. Я еще не тестировал его широко, но, похоже, он работает до сих пор.

Итак, вместо

def id: Rep[PK[SomeTable]] = column[PK[SomeTable]]("id", O.PrimaryKey, O.AutoInc)

Ты должен сделать:

def id: Rep[PK[SomeTable]] = column[PK[SomeTable]]("id", SqlType("SERIAL"), O.PrimaryKey, O.AutoInc)

Где PK определяется как пример в книге "Essential Slick":

final case class PK[A](value: Long = 0L) extends AnyVal with MappedTo[Long]