Packages

c

molecule.api.Molecule

Molecule07

abstract class Molecule07[A, B, C, D, E, F, G] extends Molecule[(A, B, C, D, E, F, G)]

Source
Molecule.scala
Linear Supertypes
Molecule[(A, B, C, D, E, F, G)], ShowDebug[(A, B, C, D, E, F, G)], GetAsyncJson, GetAsyncRaw, GetAsyncList[(A, B, C, D, E, F, G)], GetAsyncIterable[(A, B, C, D, E, F, G)], GetAsyncArray[(A, B, C, D, E, F, G)], GetJson, GetRaw, GetList[(A, B, C, D, E, F, G)], GetIterable[(A, B, C, D, E, F, G)], GetArray[(A, B, C, D, E, F, G)], JsonBuilder, CastHelpers[(A, B, C, D, E, F, G)], Helpers, DateHandling, RegexMatching, MoleculeBase, AnyRef, Any
Ordering
  1. Grouped
  2. Alphabetic
  3. By Inheritance
Inherited
  1. Molecule07
  2. Molecule
  3. ShowDebug
  4. GetAsyncJson
  5. GetAsyncRaw
  6. GetAsyncList
  7. GetAsyncIterable
  8. GetAsyncArray
  9. GetJson
  10. GetRaw
  11. GetList
  12. GetIterable
  13. GetArray
  14. JsonBuilder
  15. CastHelpers
  16. Helpers
  17. DateHandling
  18. RegexMatching
  19. MoleculeBase
  20. AnyRef
  21. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Molecule07(_model: Model, queryData: (Query, Option[Query]))

Type Members

  1. trait checkInsertModel extends AnyRef

    Insert data is verified on instantiation of insert object in each arity molecule

    Insert data is verified on instantiation of insert object in each arity molecule

    Attributes
    protected
    Definition Classes
    Molecule
  2. trait debugInsert extends AnyRef

    Debug call to insert on a molecule (without affecting the db).

    Debug call to insert on a molecule (without affecting the db).

    Prints internal molecule transformation representations to output:

    Model --> Generic statements --> Datomic statements

    Definition Classes
    Molecule
  3. trait getInsertTx extends AnyRef

    Get transaction statements of a call to insert on a molecule (without affecting the db).

    Get transaction statements of a call to insert on a molecule (without affecting the db).

    returns

    Transaction statements

    Definition Classes
    Molecule
  4. trait insert extends AnyRef

    Insert one or more rows of data matching molecule.

    Insert one or more rows of data matching molecule.

    Returns Future with TxReport having info about the result of the insert transaction.

    Data matching the types of the molecule can be inserted either as individual args or an Iterable (List, Set etc) of tuples:

    // Insert single row of data with individual args
    Person.name.age.insert("Ann", 28)
    
    // Insert multiple rows of data. Accepts Iterable[Tpl]
    Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    // Data was inserted
    Person.name.age.get.sorted === List(
      ("Ann", 28),
      ("Ben", 42),
      ("Liz", 37)
    )

    Each insert apply method returns a TxReport with info about the result of the transaction.

    Since insert is an object of each arity 1-22 Molecule implementation, we can make an "insert-molecule" at compile time that we can re-use for inserting data at runtime matching the molecule type:

    // At compiletime:
    
    // Make insert-molecule
    val insertPersonsWithAge = Person.name.age.insert
    
    // At runtime:
    
    // Apply individual args matching insert-molecule to insert single row
    insertPersonsWithAge("Ann", 28)
    
    // .. or apply Iterable of tuples matching insert-molecule to insert multiple rows
    insertPersonsWithAge(
      List(
        ("Ben", 42),
        ("Liz", 37)
      )
    )
    
    // Data was inserted
    Person.name.age.get.sorted === List(
      ("Ann", 28),
      ("Ben", 42),
      ("Liz", 37)
    )

    The insert operation is synchronous and blocking. Use insertAsync for non-blocking asynchronous inserts.

    Definition Classes
    Molecule
  5. trait insertAsync extends AnyRef

    Asynchronously insert one or more rows of data matching molecule.

    Asynchronously insert one or more rows of data matching molecule.

    Returns Future with TxReport having info about the result of the insert transaction.

    Data matching the types of the molecule can be inserted either as individual args or an Iterable (List, Set etc) of tuples:

    // Insert single row of data with individual args
    val singleInsertFuture: Future[TxReport] = Person.name.age.insertAsync("Ann", 28)
    
    // Insert multiple rows of data. Accepts Iterable[Tpl]
    val multipleInsertFuture: Future[TxReport] = Person.name.age insertAsync List(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    for {
      _ <- singleInsertFuture
      _ <- multipleInsertFuture
      result <- Person.name.age.getAsync
    } yield {
      // Both inserts applied
      result === List(
        ("Ann", 28),
        ("Ben", 42),
        ("Liz", 37)
      )
    }

    The insert operation is asynchronous and non-blocking. Internally calls Datomic's asynchronous API.

    Definition Classes
    Molecule
  6. implicit class Regex extends AnyRef
    Definition Classes
    RegexMatching

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def _debugInsert(conn: Conn, dataRows: Iterable[Seq[Any]]): Unit
    Attributes
    protected
    Definition Classes
    ShowDebug
  5. def _getInsertTx(conn: Conn, dataRows: Iterable[Seq[Any]]): Seq[Seq[Statement]]
    Attributes
    protected
    Definition Classes
    Molecule
  6. def _insert(conn: Conn, model: Model, dataRows: Iterable[Seq[Any]]): TxReport
    Attributes
    protected
    Definition Classes
    Molecule
  7. def _insertAsync(conn: Conn, model: Model, dataRows: Iterable[Seq[Any]])(implicit ec: ExecutionContext): Future[TxReport]
    Attributes
    protected
    Definition Classes
    Molecule
  8. val _model: Model

    Internal Model representation of molecule.

    Internal Model representation of molecule.

    Molecule transforms custom boilerplate DSL constructs to Datomic queries in 3 steps:

    Custom DSL molecule --> Model --> Query --> Datomic query string

    Definition Classes
    Molecule07MoleculeBase
  9. val _nestedQuery: Option[Query]

    Internal optional Query representation of nested molecule with added entity search for each level.

    Internal optional Query representation of nested molecule with added entity search for each level.

    Molecule transforms custom boilerplate DSL constructs to Datomic queries in 3 steps:

    Custom DSL molecule --> Model --> Query --> Datomic query string

    Definition Classes
    Molecule07MoleculeBase
  10. val _query: Query

    Internal Query representation of molecule.

    Internal Query representation of molecule.

    Molecule transforms custom boilerplate DSL constructs to Datomic queries in 3 steps:

    Custom DSL molecule --> Model --> Query --> Datomic query string

    Definition Classes
    Molecule07MoleculeBase
  11. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  12. def cast(value: Any): String
    Attributes
    protected
    Definition Classes
    Helpers
  13. def castAggrManyList[T](row: List[_], i: Int): List[Set[T]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  14. def castAggrManyListBigDecimal(row: List[_], i: Int): List[Set[BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  15. def castAggrManyListBigInt(row: List[_], i: Int): List[Set[BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  16. def castAggrManyListDistinct[T](row: List[_], i: Int): List[Set[T]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  17. def castAggrManyListDistinctBigDecimal(row: List[_], i: Int): List[Set[BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  18. def castAggrManyListDistinctBigInt(row: List[_], i: Int): List[Set[BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  19. def castAggrManyListDistinctFloat(row: List[_], i: Int): List[Set[Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  20. def castAggrManyListDistinctInt(row: List[_], i: Int): List[Set[Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  21. def castAggrManyListFloat(row: List[_], i: Int): List[Set[Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  22. def castAggrManyListInt(row: List[_], i: Int): List[Set[Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  23. def castAggrManyListRand[T](row: List[_], i: Int): List[Set[T]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  24. def castAggrManyListRandBigDecimal(row: List[_], i: Int): List[Set[BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  25. def castAggrManyListRandBigInt(row: List[_], i: Int): List[Set[BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  26. def castAggrManyListRandFloat(row: List[_], i: Int): List[Set[Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  27. def castAggrManyListRandInt(row: List[_], i: Int): List[Set[Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  28. def castAggrManySingle[T](row: List[_], i: Int): Set[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  29. def castAggrManySingleBigDecimal(row: List[_], i: Int): Set[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  30. def castAggrManySingleBigInt(row: List[_], i: Int): Set[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  31. def castAggrManySingleFloat(row: List[_], i: Int): Set[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  32. def castAggrManySingleInt(row: List[_], i: Int): Set[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  33. def castAggrOneList[T](row: List[_], i: Int): List[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  34. def castAggrOneListBigDecimal(row: List[_], i: Int): List[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  35. def castAggrOneListBigInt(row: List[_], i: Int): List[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  36. def castAggrOneListDistinct[T](row: List[_], i: Int): List[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  37. def castAggrOneListDistinctBigDecimal(row: List[_], i: Int): List[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  38. def castAggrOneListDistinctBigInt(row: List[_], i: Int): List[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  39. def castAggrOneListDistinctFloat(row: List[_], i: Int): List[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  40. def castAggrOneListDistinctInt(row: List[_], i: Int): List[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  41. def castAggrOneListFloat(row: List[_], i: Int): List[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  42. def castAggrOneListInt(row: List[_], i: Int): List[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  43. def castAggrOneListRand[T](row: List[_], i: Int): List[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  44. def castAggrOneListRandBigDecimal(row: List[_], i: Int): List[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  45. def castAggrOneListRandBigInt(row: List[_], i: Int): List[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  46. def castAggrOneListRandFloat(row: List[_], i: Int): List[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  47. def castAggrOneListRandInt(row: List[_], i: Int): List[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  48. def castAggrSingleSample[T](row: List[_], i: Int): T
    Attributes
    protected
    Definition Classes
    CastHelpers
  49. def castAggrSingleSampleBigDecimal(row: List[_], i: Int): BigDecimal
    Attributes
    protected
    Definition Classes
    CastHelpers
  50. def castAggrSingleSampleBigInt(row: List[_], i: Int): BigInt
    Attributes
    protected
    Definition Classes
    CastHelpers
  51. def castAggrSingleSampleFloat(row: List[_], i: Int): Float
    Attributes
    protected
    Definition Classes
    CastHelpers
  52. def castAggrSingleSampleInt(row: List[_], i: Int): Int
    Attributes
    protected
    Definition Classes
    CastHelpers
  53. def castMany[T](row: List[_], i: Int): Set[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  54. def castManyBigDecimal(row: List[_], i: Int): Set[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  55. def castManyBigInt(row: List[_], i: Int): Set[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  56. def castManyEnum(row: List[_], i: Int): Set[String]
    Attributes
    protected
    Definition Classes
    CastHelpers
  57. def castManyFloat(row: List[_], i: Int): Set[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  58. def castManyInt(row: List[_], i: Int): Set[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  59. def castMapBigDecimal(row: List[_], i: Int): Map[String, BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  60. def castMapBigInt(row: List[_], i: Int): Map[String, BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  61. def castMapBoolean(row: List[_], i: Int): Map[String, Boolean]
    Attributes
    protected
    Definition Classes
    CastHelpers
  62. def castMapDate(row: List[_], i: Int): Map[String, Date]
    Attributes
    protected
    Definition Classes
    CastHelpers
  63. def castMapDouble(row: List[_], i: Int): Map[String, Double]
    Attributes
    protected
    Definition Classes
    CastHelpers
  64. def castMapFloat(row: List[_], i: Int): Map[String, Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  65. def castMapInt(row: List[_], i: Int): Map[String, Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  66. def castMapLong(row: List[_], i: Int): Map[String, Long]
    Attributes
    protected
    Definition Classes
    CastHelpers
  67. def castMapString(row: List[_], i: Int): Map[String, String]
    Attributes
    protected
    Definition Classes
    CastHelpers
  68. def castMapURI(row: List[_], i: Int): Map[String, URI]
    Attributes
    protected
    Definition Classes
    CastHelpers
  69. def castMapUUID(row: List[_], i: Int): Map[String, UUID]
    Attributes
    protected
    Definition Classes
    CastHelpers
  70. def castOne[T](row: List[_], i: Int): T
    Attributes
    protected
    Definition Classes
    CastHelpers
  71. def castOneBigDecimal(row: List[_], i: Int): BigDecimal
    Attributes
    protected
    Definition Classes
    CastHelpers
  72. def castOneBigInt(row: List[_], i: Int): BigInt
    Attributes
    protected
    Definition Classes
    CastHelpers
  73. def castOneFloat(row: List[_], i: Int): Float
    Attributes
    protected
    Definition Classes
    CastHelpers
  74. def castOneInt(row: List[_], i: Int): Int
    Attributes
    protected
    Definition Classes
    CastHelpers
  75. def castOneInt2(row: List[_], i: Int): Int
    Attributes
    protected
    Definition Classes
    CastHelpers
  76. def castOptMany[T](row: List[_], i: Int): Option[Set[T]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  77. def castOptManyApply[T](row: List[_], i: Int): Option[Set[T]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  78. def castOptManyApplyBigDecimal(row: List[_], i: Int): Option[Set[BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  79. def castOptManyApplyBigInt(row: List[_], i: Int): Option[Set[BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  80. def castOptManyApplyDouble(row: List[_], i: Int): Option[Set[Double]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  81. def castOptManyApplyFloat(row: List[_], i: Int): Option[Set[Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  82. def castOptManyApplyInt(row: List[_], i: Int): Option[Set[Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  83. def castOptManyApplyLong(row: List[_], i: Int): Option[Set[Long]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  84. def castOptManyBigDecimal(row: List[_], i: Int): Option[Set[BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  85. def castOptManyBigInt(row: List[_], i: Int): Option[Set[BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  86. def castOptManyDouble(row: List[_], i: Int): Option[Set[Double]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  87. def castOptManyEnum(row: List[_], i: Int): Option[Set[String]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  88. def castOptManyFloat(row: List[_], i: Int): Option[Set[Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  89. def castOptManyInt(row: List[_], i: Int): Option[Set[Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  90. def castOptManyLong(row: List[_], i: Int): Option[Set[Long]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  91. def castOptManyRefAttr(row: List[_], i: Int): Option[Set[Long]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  92. def castOptMapApplyBigDecimal(row: List[_], i: Int): Option[Map[String, BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  93. def castOptMapApplyBigInt(row: List[_], i: Int): Option[Map[String, BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  94. def castOptMapApplyBoolean(row: List[_], i: Int): Option[Map[String, Boolean]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  95. def castOptMapApplyDate(row: List[_], i: Int): Option[Map[String, Date]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  96. def castOptMapApplyDouble(row: List[_], i: Int): Option[Map[String, Double]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  97. def castOptMapApplyFloat(row: List[_], i: Int): Option[Map[String, Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  98. def castOptMapApplyInt(row: List[_], i: Int): Option[Map[String, Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  99. def castOptMapApplyLong(row: List[_], i: Int): Option[Map[String, Long]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  100. def castOptMapApplyString(row: List[_], i: Int): Option[Map[String, String]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  101. def castOptMapApplyURI(row: List[_], i: Int): Option[Map[String, URI]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  102. def castOptMapApplyUUID(row: List[_], i: Int): Option[Map[String, UUID]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  103. def castOptMapBigDecimal(row: List[_], i: Int): Option[Map[String, BigDecimal]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  104. def castOptMapBigInt(row: List[_], i: Int): Option[Map[String, BigInt]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  105. def castOptMapBoolean(row: List[_], i: Int): Option[Map[String, Boolean]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  106. def castOptMapDate(row: List[_], i: Int): Option[Map[String, Date]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  107. def castOptMapDouble(row: List[_], i: Int): Option[Map[String, Double]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  108. def castOptMapFloat(row: List[_], i: Int): Option[Map[String, Float]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  109. def castOptMapInt(row: List[_], i: Int): Option[Map[String, Int]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  110. def castOptMapLong(row: List[_], i: Int): Option[Map[String, Long]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  111. def castOptMapString(row: List[_], i: Int): Option[Map[String, String]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  112. def castOptMapURI(row: List[_], i: Int): Option[Map[String, URI]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  113. def castOptMapUUID(row: List[_], i: Int): Option[Map[String, UUID]]
    Attributes
    protected
    Definition Classes
    CastHelpers
  114. def castOptOne[T](row: List[_], i: Int): Option[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  115. def castOptOneApply[T](row: List[_], i: Int): Option[T]
    Attributes
    protected
    Definition Classes
    CastHelpers
  116. def castOptOneApplyBigDecimal(row: List[_], i: Int): Option[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  117. def castOptOneApplyBigInt(row: List[_], i: Int): Option[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  118. def castOptOneApplyDouble(row: List[_], i: Int): Option[Double]
    Attributes
    protected
    Definition Classes
    CastHelpers
  119. def castOptOneApplyFloat(row: List[_], i: Int): Option[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  120. def castOptOneApplyInt(row: List[_], i: Int): Option[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  121. def castOptOneApplyLong(row: List[_], i: Int): Option[Long]
    Attributes
    protected
    Definition Classes
    CastHelpers
  122. def castOptOneBigDecimal(row: List[_], i: Int): Option[BigDecimal]
    Attributes
    protected
    Definition Classes
    CastHelpers
  123. def castOptOneBigInt(row: List[_], i: Int): Option[BigInt]
    Attributes
    protected
    Definition Classes
    CastHelpers
  124. def castOptOneDouble(row: List[_], i: Int): Option[Double]
    Attributes
    protected
    Definition Classes
    CastHelpers
  125. def castOptOneEnum(row: List[_], i: Int): Option[String]
    Attributes
    protected
    Definition Classes
    CastHelpers
  126. def castOptOneFloat(row: List[_], i: Int): Option[Float]
    Attributes
    protected
    Definition Classes
    CastHelpers
  127. def castOptOneInt(row: List[_], i: Int): Option[Int]
    Attributes
    protected
    Definition Classes
    CastHelpers
  128. def castOptOneLong(row: List[_], i: Int): Option[Long]
    Attributes
    protected
    Definition Classes
    CastHelpers
  129. def castOptOneRefAttr(row: List[_], i: Int): Option[Long]
    Attributes
    protected
    Definition Classes
    CastHelpers
  130. def castRow(row: List[AnyRef]): (A, B, C, D, E, F, G)
    Attributes
    protected
    Definition Classes
    CastHelpers
  131. def clean(attr: String): String
    Definition Classes
    Helpers
  132. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  133. def date2datomicStr(date: Date, zoneOffset: ZoneOffset = localZoneOffset): String
    Definition Classes
    DateHandling
  134. def date2str(date: Date, zoneOffset: ZoneOffset = localZoneOffset): String
    Definition Classes
    DateHandling
  135. def daylight(ms: Long): Int
    Definition Classes
    DateHandling
  136. def debugGet(implicit conn: Conn): Unit

    Debug call to get on a molecule (without affecting the db).

    Debug call to get on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows). OBS: printing raw Date's (Clojure Instant) will miss the time-zone

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  137. def debugGetAsOf(date: Date)(implicit conn: Conn): Unit

    Debug call to getAsOf(date) on a molecule (without affecting the db).

    Debug call to getAsOf(date) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    conn

    Implicit Conn value in scsope

    Definition Classes
    ShowDebug
  138. def debugGetAsOf(tx: TxReport)(implicit conn: Conn): Unit

    Debug call to getAsOf(tx) on a molecule (without affecting the db).

    Debug call to getAsOf(tx) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    tx

    TxReport

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  139. def debugGetAsOf(t: Long)(implicit conn: Conn): Unit

    Debug call to getAsOf(t) on a molecule (without affecting the db).

    Debug call to getAsOf(t) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  140. def debugGetHistory(implicit conn: Conn): Unit

    Debug call to getHistory on a molecule (without affecting the db).

    Debug call to getHistory on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  141. def debugGetSince(date: Date)(implicit conn: Conn): Unit

    Debug call to getSince(date) on a molecule (without affecting the db).

    Debug call to getSince(date) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  142. def debugGetSince(tx: TxReport)(implicit conn: Conn): Unit

    Debug call to getSince(tx) on a molecule (without affecting the db).

    Debug call to getSince(tx) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    tx

    TxReport

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  143. def debugGetSince(t: Long)(implicit conn: Conn): Unit

    Debug call to getSince(t) on a molecule (without affecting the db).

    Debug call to getSince(t) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  144. def debugGetWith(txData: List[List[_]])(implicit conn: Conn): Unit

    Debug call to getWith(txData) on a molecule (without affecting the db).

    Debug call to getWith(txData) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    3. Transactions of applied transaction data.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  145. def debugGetWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Unit

    Debug call to getWith(txMolecules) on a molecule (without affecting the db).

    Debug call to getWith(txMolecules) on a molecule (without affecting the db).

    Prints the following to output:

    1. Internal molecule transformation representations:
    Molecule DSL --> Model --> Query --> Datomic query

    2. Data returned from get query (max 500 rows).

    3. Transactions of applied transaction molecules.

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  146. def debugSave(implicit conn: Conn): Unit

    Debug call to save on a molecule (without affecting the db).

    Debug call to save on a molecule (without affecting the db).

    Prints internal molecule transformation representations to output:

    Model --> Generic statements --> Datomic statements

    conn

    Implicit Conn value in scope

    returns

    Unit

    Definition Classes
    ShowDebug
  147. def debugUpdate(implicit conn: Conn): Unit

    Debug call to update on a molecule (without affecting the db).

    Debug call to update on a molecule (without affecting the db).

    Prints internal molecule transformation representations to output:

    Model --> Generic statements --> Datomic statements

    conn

    Implicit Conn value in scope

    Definition Classes
    ShowDebug
  148. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  149. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  150. def expandDateStr(dateStr: String): String
    Definition Classes
    DateHandling
  151. final def f(a: Any): Any
    Attributes
    protected
    Definition Classes
    Helpers
  152. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  153. def get(n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule.

    Get List of n rows as tuples matching molecule.

    Only n rows are type-casted.

    Person.name.age.get(1) === List(
      ("Ben", 42)
    )

    Since retrieving a List is considered the default fetch format, the getter method is simply named get (and not getList).

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetList
    See also

    Equivalent asynchronous getAsync method.

  154. def get(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule.

    Get List of all rows as tuples matching molecule.

    Person.name.age.get === List(
      ("Ben", 42),
      ("Liz", 37),
    )

    Since retrieving a List is considered the default fetch format, the getter method is simply named get (and not getList).

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetList
    See also

    Equivalent asynchronous getAsync method.

  155. def getArray(n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule.

    Get Array of n rows as tuples matching molecule.

    Person.name.age.getArray(1) === Array(
      ("Ben", 42)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples. Setting n to -1 fetches all rows (same as calling getArray without any number of rows parameter).

    n

    Number of rows. If -1, all rows are fetched.

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetArray
    See also

    Equivalent asynchronous getAsyncArray method.

  156. def getArray(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule.

    Get Array of all rows as tuples matching molecule.

    Person.name.age.getArray === Array(
      ("Ben", 42),
      ("Liz", 37)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetArray
    See also

    Equivalent asynchronous getAsyncArray method.

  157. def getArrayAsOf(date: Date, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule as of date.

    Get Array of n rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Get Array of all rows as of afterUpdate
    Person.name.age.getArrayAsOf(afterUpdate) === Array(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get Array of n rows as of afterUpdate
    Person.name.age.getArrayAsOf(afterUpdate, 1) === Array(
      ("Ben", 43)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  158. def getArrayAsOf(date: Date)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule as of date.

    Get Array of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // No data yet before insert
    Person.name.age.getArrayAsOf(beforeInsert) === Array()
    
    // Get Array of all rows as of afterInsert
    Person.name.age.getArrayAsOf(afterInsert) === Array(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    // Get Array of all rows as of afterUpdate
    Person.name.age.getArrayAsOf(afterUpdate) === Array(
      ("Ben", 43), // Ben now 43
      ("Liz", 37)
    )
    
    // Get Array of all rows as of afterRetract
    Person.name.age.getArrayAsOf(afterRetract) === Array(
      ("Liz", 37) // Ben gone
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  159. def getArrayAsOf(tx: TxReport, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule as of tx.

    Get Array of n rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Get Array of all rows as of tx2 (after update)
    Person.name.age.getArrayAsOf(tx2) === Array(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get Array of n rows as of tx2 (after update)
    Person.name.age.getArrayAsOf(tx2, 1) === Array(
      ("Ben", 43)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  160. def getArrayAsOf(tx: TxReport)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule as of tx.

    Get Array of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get Array of all rows as of tx1 (after insert)
    Person.name.age.getArrayAsOf(tx1) === Array(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    // Get Array of all rows as of tx2 (after update)
    Person.name.age.getArrayAsOf(tx2) === Array(
      ("Ben", 43), // Ben now 43
      ("Liz", 37)
    )
    
    // Get Array of all rows as of tx3 (after retract)
    Person.name.age.getArrayAsOf(tx3) === Array(
      ("Liz", 37) // Ben gone
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  161. def getArrayAsOf(t: Long, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule as of transaction time t.

    Get Array of n rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
    )
    
    // Get Array of all rows as of transaction t 1031 (after update)
    Person.name.age.getArrayAsOf(1031) === Array(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get Array of n rows as of transaction t 1031 (after update)
    Person.name.age.getArrayAsOf(1031, 1) === Array(
      ("Ben", 43)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    t

    Long Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  162. def getArrayAsOf(t: Long)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule as of transaction time t.

    Get Array of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    
    // Get Array of data as of transaction t 1028 (after insert)
    Person.name.age.getArrayAsOf(1028) === Array(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    // Get Array of all rows as of transaction t 1031 (after update)
    Person.name.age.getArrayAsOf(1031) === Array(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get Array of all rows as of transaction t 1032 (after retract)
    Person.name.age.getArrayAsOf(1032) === Array(
      ("Liz", 37)
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArrayAsOf method.

  163. def getArraySince(date: Date, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule since date.

    Get Array of n rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getArraySince(date1) === Array("Ben", "Cay")
    
    // Ben and Cay added since date1 - only n (1) rows returned
    Person.name.getArraySince(date1, 1) === Array("Ben")

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  164. def getArraySince(date: Date)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule since date.

    Get Array of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getArraySince(date1) === Array("Ben", "Cay")
    
    // Cay added since date2
    Person.name.getArraySince(date2) === Array("Cay")
    
    // Nothing added since date3
    Person.name.getArraySince(date3) === Nil

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  165. def getArraySince(tx: TxReport, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule since tx.

    Get Array of n rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getArraySince(tx1) === Array("Ben", "Cay")
    
    // Ben and Cay added since tx1 - only n (1) rows returned
    Person.name.getArraySince(tx1, 1) === Array("Ben")

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    tx

    TxReport

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  166. def getArraySince(tx: TxReport)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule since tx.

    Get Array of all rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getArraySince(tx1) === Array("Ben", "Cay")
    
    // Cay added since tx2
    Person.name.getArraySince(tx2) === Array("Cay")
    
    // Nothing added since tx3
    Person.name.getArraySince(tx3) === Nil

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    tx

    TxReport

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  167. def getArraySince(t: Long, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule since transaction time t.

    Get Array of n rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getArraySince(t1) === Array("Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028 - only n (1) rows returned
    Person.name.getArraySince(t1, 1) === Array("Ben")

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  168. def getArraySince(t: Long)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule since transaction time t.

    Get Array of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getArraySince(t1) === Array("Ben", "Cay")
    
    // Cay added since transaction time t 1030
    Person.name.getArraySince(t2) === Array("Cay")
    
    // Nothing added since transaction time t 1032
    Person.name.getArraySince(t3) === Nil

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncArraySince method.

  169. def getArrayWith(txData: List[_], n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule with applied raw transaction data.

    Get Array of n rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getArrayWith(newDataTx).size === 250
    
    // Imagine future db - Let's just take 10
    Person.name.getArrayWith(newDataTx, 10).size === 10

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on with

    Equivalent asynchronous getAsyncArrayWith method.

  170. def getArrayWith(txData: List[_])(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule with applied raw transaction data.

    Get Array of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getArrayWith(newDataTx).size === 250

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on with

    Equivalent asynchronous getAsyncArrayWith method.

  171. def getArrayWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of n rows as tuples matching molecule with applied molecule transaction data.

    Get Array of n rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val List(ben, liz) = Person.name.likes.insert(
      ("Ben", "pasta"),
      ("Liz", "pizza")
    ).eids
    
    // Test multiple transactions
    Person.name.likes.getArrayWith(
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) === Array(
      ("Ben", "sushi")
      ("Liz", "cake")
    )
    
    // Same as above, but only n (1) rows returned:
    Person.name.likes.getArrayWith(
      1
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) === Array(
      ("Ben", "sushi")
    )

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

    Equivalent asynchronous getAsyncArrayWith method.

  172. def getArrayWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Array[(A, B, C, D, E, F, G)]

    Get Array of all rows as tuples matching molecule with applied molecule transaction data.

    Get Array of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val ben = Person.name("Ben").likes("pasta").save.eid
    
    // Base data
    Person.name.likes.getArrayWith(
      // apply imaginary transaction data
      Person(ben).likes("sushi").getUpdateTx
    ) === Array(
      // Effect: Ben would like sushi if tx was applied
      ("Ben", "sushi")
    )
    
    // Current state is still the same
    Person.name.likes.get === Array(
      ("Ben", "pasta")
    )

    Multiple transactions can be applied to test more complex what-if scenarios!

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetArray
    See also

    Manual on with

    Equivalent asynchronous getAsyncArrayWith method.

  173. def getAsOf(date: Date, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule as of date.

    Get List of n rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Get List of all rows as of afterUpdate
    Person.name.age.getAsOf(afterUpdate) === List(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get List of n rows as of afterUpdate
    Person.name.age.getAsOf(afterUpdate, 1) === List(
      ("Ben", 43)
    )
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  174. def getAsOf(date: Date)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule as of date.

    Get List of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // No data yet before insert
    Person.name.age.getAsOf(beforeInsert) === Nil
    
    // Get List of all rows as of afterInsert
    Person.name.age.getAsOf(afterInsert) === List(
      ("Ben", 42),
      ("Liz", 37)´
    )
    
    // Get List of all rows as of afterUpdate
    Person.name.age.getAsOf(afterUpdate) === List(
      ("Ben", 43), // Ben now 43
      ("Liz", 37)
    )
    
    // Get List of all rows as of afterRetract
    Person.name.age.getAsOf(afterRetract) === List(
      ("Liz", 37) // Ben gone
    )
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  175. def getAsOf(tx: TxReport, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule as of tx.

    Get List of n rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Current data
    Person.name.age.get === List(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get List of all rows as of tx2 (after update)
    Person.name.age.getAsOf(tx2) === List(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get List of n rows as of tx2 (after update)
    Person.name.age.getAsOf(tx2, 1) === List(
      ("Ben", 43)
    )
    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  176. def getAsOf(tx: TxReport)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule as of tx.

    Get List of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get List of all rows as of tx1 (after insert)
    Person.name.age.getAsOf(tx1) === List(
      ("Ben", 42),
      ("Liz", 37)
    )
    
    // Get List of all rows as of tx2 (after update)
    Person.name.age.getAsOf(tx2) === List(
      ("Ben", 43), // Ben now 43
      ("Liz", 37)
    )
    
    // Get List of all rows as of tx3 (after retract)
    Person.name.age.getAsOf(tx3) === List(
      ("Liz", 37) // Ben gone
    )
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  177. def getAsOf(t: Long, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule as of transaction time t.

    Get List of n rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
    )
    
    // Get List of all all rows as of transaction t 1031 (after update)
    Person.name.age.getAsOf(1031) === List(
      ("Ben", 43),
      ("Liz", 37)
    )
    
    // Get List of n rows as of transaction t 1031 (after update)
    Person.name.age.getAsOf(1031, 1) === List(
      ("Ben", 43)
    )
    t

    Long Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  178. def getAsOf(t: Long)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule as of transaction time t.

    Get List of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    
    // Get List of all rows as of transaction t 1028 (after insert)
    Person.name.age.getAsOf(1028) === List(
      ("Liz", 37),
      ("Ben", 42)
    )
    
    // Get List of all rows as of transaction t 1031 (after update)
    Person.name.age.getAsOf(1031) === List(
      ("Liz", 37),
      ("Ben", 43)
    )
    
    // Get List of all rows as of transaction t 1032 (after retract)
    Person.name.age.getAsOf(1032) === List(
      ("Liz", 37)
    )
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncAsOf method.

  179. def getAsync(n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule.

    Get Future with List of n rows as tuples matching molecule.

    For more info and code examples see equivalent synchronous get method.

    Since retrieving a List is considered the default fetch format, the getter method is simply named get (and not getList).

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetAsyncList
  180. def getAsync(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule.

    Get Future with List of all rows as tuples matching molecule.

    For more info and code examples see equivalent synchronous get method.

    Since retrieving a List is considered the default fetch format, the getter method is simply named get (and not getList).

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetAsyncList
  181. def getAsyncArray(n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule.

    Get Future with Array of n rows as tuples matching molecule.

    For more info and code examples see equivalent synchronous getArray method.

    n

    Number of rows

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Future[Array[Tpl]] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetAsyncArray
  182. def getAsyncArray(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule.

    Get Future with Array of all rows as tuples matching molecule.

    For more info and code examples see equivalent synchronous getArray method.

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Future[Array[Tpl]] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetAsyncArray
  183. def getAsyncArrayAsOf(date: Date, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule as of date.

    Get Future with Array of n rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  184. def getAsyncArrayAsOf(date: Date)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule as of date.

    Get Future with Array of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  185. def getAsyncArrayAsOf(tx: TxReport, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule as of tx.

    Get Future with Array of n rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  186. def getAsyncArrayAsOf(tx: TxReport)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule as of tx.

    Get Future with Array of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  187. def getAsyncArrayAsOf(t: Long, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule as of transaction time t.

    Get Future with Array of n rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    t

    Long Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  188. def getAsyncArrayAsOf(t: Long)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule as of transaction time t.

    Get Future with Array of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getArrayAsOf method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  189. def getAsyncArraySince(date: Date, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule since date.

    Get Future with Array of n rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  190. def getAsyncArraySince(date: Date)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule since date.

    Get Future with Array of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  191. def getAsyncArraySince(tx: TxReport, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule since tx.

    Get Future with Array of n rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    tx

    TxReport

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  192. def getAsyncArraySince(tx: TxReport)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule since tx.

    Get Future with Array of all rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    tx

    TxReport

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  193. def getAsyncArraySince(t: Long, n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule since transaction time t.

    Get Future with Array of n rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction).

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  194. def getAsyncArraySince(t: Long)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule since transaction time t.

    Get Future with Array of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction).

    For more info and code examples see equivalent synchronous getArraySince method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on asof/since

  195. def getAsyncArrayWith(txData: List[_], n: Int)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule with applied raw transaction data.

    Get Future with Array of n rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getArrayWith method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on with

  196. def getAsyncArrayWith(txData: List[_])(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule with applied raw transaction data.

    Get Future with Array of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getArrayWith method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on with

  197. def getAsyncArrayWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of n rows as tuples matching molecule with applied molecule transaction data.

    Get Future with Array of n rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getArrayWith method.

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    The Array is only populated with n rows of type-casted tuples.

    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

  198. def getAsyncArrayWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn, tplType: ClassTag[(A, B, C, D, E, F, G)]): Future[Array[(A, B, C, D, E, F, G)]]

    Get Future with Array of all rows as tuples matching molecule with applied molecule transaction data.

    Get Future with Array of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getArrayWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    Getting a pre-allocated Array populated with typed data is the fastest way to query Datomic with Molecule. Looping the Array in a while loop with a mutable index pointer will also be the fastest way to traverse the data set.

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    tplType

    Implicit ClassTag[Tpl] to capture Tuple type for Array

    returns

    Array[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncArray
    See also

    Manual on with

  199. def getAsyncAsOf(date: Date, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule as of date.

    Get Future with List of n rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getAsOf method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  200. def getAsyncAsOf(date: Date)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule as of date.

    Get Future with List of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getAsOf method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  201. def getAsyncAsOf(tx: TxReport, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule as of tx.

    Get Future with List of n rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  202. def getAsyncAsOf(tx: TxReport)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule as of tx.

    Get Future with List of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  203. def getAsyncAsOf(t: Long, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule as of transaction time t.

    Get Future with List of n rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getAsOf method.

    t

    Long Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  204. def getAsyncAsOf(t: Long)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule as of transaction time t.

    Get Future with List of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getAsOf method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  205. def getAsyncHistory(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with history of operations as List on an attribute in the db.

    Get Future with history of operations as List on an attribute in the db.

    For more info and code examples see equivalent synchronous getHistory method.

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    manual for more info on generic attributes.

  206. def getAsyncIterable(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching the molecule.

    Get Future with Iterable of all rows as tuples matching the molecule.

    Rows are lazily type-casted on each call to iterator.next().

    For more info and code examples see equivalent synchronous getIterable method.

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetAsyncIterable
  207. def getAsyncIterableAsOf(date: Date)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule as of date.

    Get Future with Iterable of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getIterableAsOf method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  208. def getAsyncIterableAsOf(tx: TxReport)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule as of tx.

    Get Future with Iterable of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getIterableAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  209. def getAsyncIterableAsOf(t: Long)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule as of transaction time t.

    Get Future with Iterable of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    Call getIterableAsOf for large result sets to maximize runtime performance. Data is lazily type-casted on each call to next on the iterator.

    For more info and code examples see equivalent synchronous getIterableAsOf method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  210. def getAsyncIterableSince(date: Date)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule since date.

    Get Future with Iterable of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getIterableSince method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  211. def getAsyncIterableSince(tx: TxReport)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule since tx.

    Get Future with Iterable of all rows as tuples matching molecule since tx.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getIterableSince method.

    tx

    TxReport

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  212. def getAsyncIterableSince(t: Long)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule since transaction time t.

    Get Future with Iterable of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    Call getIterableSince for large result sets to maximize runtime performance. Data is lazily type-casted on each call to next on the iterator.

    For more info and code examples see equivalent synchronous getIterableSince method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetAsyncIterable
    See also

    Manual on asof/since

  213. def getAsyncIterableWith(txData: List[_])(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule with applied raw transaction data.

    Get Future with Iterable of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db. *

    * For more info and code examples see equivalent synchronous * getIterableWith method.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    Iterable of molecule data

    Definition Classes
    GetAsyncIterable
    See also

    Manual on with

  214. def getAsyncIterableWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[Iterable[(A, B, C, D, E, F, G)]]

    Get Future with Iterable of all rows as tuples matching molecule with applied molecule transaction data.

    Get Future with Iterable of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getIterableWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    Iterable of molecule data

    Definition Classes
    GetAsyncIterable
    See also

    Manual on with

  215. def getAsyncJson(n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule.

    Get Future with json data for n rows matching molecule.

    Namespace.Attribute is used as json fields. Values are quoted when necessary. Nested data becomes json objects etc.

    For more info and code examples see equivalent synchronous getJson method.

    n

    Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on getJson

  216. def getAsyncJson(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule.

    Get Future with json data for all rows matching molecule.

    Namespace.Attribute is used as json fields. Values are quoted when necessary. Nested data becomes json objects etc.

    For more info and code examples see equivalent synchronous getJson method.

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on getJson

  217. def getAsyncJsonAsOf(date: Date, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule as of tx.

    Get Future with json data for n rows matching molecule as of tx.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  218. def getAsyncJsonAsOf(date: Date)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule as of date.

    Get Future with json data for all rows matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  219. def getAsyncJsonAsOf(tx: TxReport, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule as of tx.

    Get Future with json data for n rows matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  220. def getAsyncJsonAsOf(tx: TxReport)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule as of tx.

    Get Future with json data for all rows matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  221. def getAsyncJsonAsOf(t: Long, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule as of transaction time t.

    Get Future with json data for n rows matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  222. def getAsyncJsonAsOf(t: Long)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule as of transaction time t.

    Get Future with json data for all rows matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getJsonAsOf method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  223. def getAsyncJsonSince(date: Date, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule since date.

    Get Future with json data for n rows matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getJsonSince method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  224. def getAsyncJsonSince(date: Date)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule since date.

    Get Future with json data for all rows matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getJsonSince method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  225. def getAsyncJsonSince(tx: TxReport, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule since tx.

    Get Future with json data for n rows matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getJsonSince method.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  226. def getAsyncJsonSince(tx: TxReport)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule since tx.

    Get Future with json data for all rows matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getJsonSince method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  227. def getAsyncJsonSince(t: Long, n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule since transaction time t.

    Get Future with json data for n rows matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    For more info and code examples see equivalent synchronous getJsonSince method.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  228. def getAsyncJsonSince(t: Long)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule since transaction time t.

    Get Future with json data for all rows matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    For more info and code examples see equivalent synchronous getJsonSince method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on asof/since

  229. def getAsyncJsonWith(txData: List[_], n: Int)(implicit conn: Conn): Future[String]

    Get Future with json data for n rows matching molecule with applied raw transaction data.

    Get Future with json data for n rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getJsonWith method.

    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on with

  230. def getAsyncJsonWith(txData: List[_])(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule with applied raw transaction data.

    Get Future with json data for all rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getJsonWith method.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on with

  231. def getAsyncJsonWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule with applied molecule transaction data.

    Get Future with json data for all rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getJsonWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on with

  232. def getAsyncJsonWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[String]

    Get Future with json data for all rows matching molecule with applied molecule transaction data.

    Get Future with json data for all rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getJsonWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetAsyncJson
    See also

    Manual on with

  233. def getAsyncRaw(n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule.

    Get Future with java.util.Collection of n untyped rows matching molecule.

    Person.name.age.getRaw(1).toString === """[["Ben" 42]]"""



    For more info and code examples see equivalent synchronous getRaw method.

    n

    Number of rows

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
  234. def getAsyncRaw(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule.

    Get Future with java.util.Collection of all untyped rows matching molecule.

    Person.name.age.getRaw.toString === """`[["Ben" 42], ["Liz" 37]]"""



    For more info and code examples see equivalent synchronous getRaw method.

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
  235. def getAsyncRawAsOf(date: Date, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule as of date.

    Get Future with java.util.Collection of n untyped rows matching molecule as of date.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getRawAsOf method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  236. def getAsyncRawAsOf(date: Date)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule as of date.

    Get Future with java.util.Collection of all untyped rows matching molecule as of date.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data at a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getRawAsOf method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  237. def getAsyncRawAsOf(tx: TxReport, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule as of tx.

    Get Future with java.util.Collection of n untyped rows matching molecule as of tx.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getRawAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  238. def getAsyncRawAsOf(tx: TxReport)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule as of tx.

    Get Future with java.util.Collection of all untyped rows matching molecule as of tx.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getRawAsOf method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  239. def getAsyncRawAsOf(t: Long, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule as of transaction time t.

    Get Future with java.util.Collection of n untyped rows matching molecule as of transaction time t.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getRawAsOf method.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  240. def getAsyncRawAsOf(t: Long)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule as of transaction time t.

    Get Future with java.util.Collection of all untyped rows matching molecule as of transaction time t.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction).

    For more info and code examples see equivalent synchronous getRawAsOf method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  241. def getAsyncRawSince(date: Date, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule since date.

    Get Future with java.util.Collection of n untyped rows matching molecule since date.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getRawSince method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  242. def getAsyncRawSince(date: Date)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule since date.

    Get Future with java.util.Collection of all untyped rows matching molecule since date.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getRawSince method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  243. def getAsyncRawSince(tx: TxReport, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule since tx.

    Get Future with java.util.Collection of n untyped rows matching molecule since tx.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getRawSince method.

    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  244. def getAsyncRawSince(tx: TxReport)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule since tx.

    Get Future with java.util.Collection of all untyped rows matching molecule since tx.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getRawSince method.

    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  245. def getAsyncRawSince(t: Long, n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule since transaction time t.

    Get Future with java.util.Collection of n untyped rows matching molecule since transaction time t.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction).

    For more info and code examples see equivalent synchronous getRawSince method.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  246. def getAsyncRawSince(t: Long)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule since transaction time t.

    Get Future with java.util.Collection of all untyped rows matching molecule since transaction time t.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction).

    For more info and code examples see equivalent synchronous getRawSince method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on asof/since

  247. def getAsyncRawWith(txData: List[_], n: Int)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule with applied raw transaction data.

    Get Future with java.util.Collection of n untyped rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getRawWith method.

    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on with

  248. def getAsyncRawWith(txData: List[_])(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule with applied raw transaction data.

    Get Future with java.util.Collection of all untyped rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getRawWith method.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on with

  249. def getAsyncRawWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of n untyped rows matching molecule with applied molecule transaction data.

    Get Future with java.util.Collection of n untyped rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getRawWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

  250. def getAsyncRawWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[Collection[List[AnyRef]]]

    Get Future with java.util.Collection of all untyped rows matching molecule with applied molecule transaction data.

    Get Future with java.util.Collection of all untyped rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getRawWith method.

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetAsyncRaw
    See also

    Manual on with

  251. def getAsyncSince(date: Date, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule since date.

    Get Future with List of n rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getSince method.

    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  252. def getAsyncSince(date: Date)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule since date.

    Get Future with List of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    For more info and code examples see equivalent synchronous getSince method.

    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  253. def getAsyncSince(tx: TxReport, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule since tx.

    Get Future with List of n rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getSince method.

    tx

    TxReport

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  254. def getAsyncSince(tx: TxReport)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule since tx.

    Get Future with List of all rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    For more info and code examples see equivalent synchronous getSince method.

    tx

    TxReport

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  255. def getAsyncSince(t: Long, n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule since transaction time t.

    Get Future with List of n rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    For more info and code examples see equivalent synchronous getSince method.

    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  256. def getAsyncSince(t: Long)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule since transaction time t.

    Get Future with List of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    For more info and code examples see equivalent synchronous getSince method.

    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on asof/since

  257. def getAsyncWith(txData: List[_], n: Int)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule with applied raw transaction data.

    Get Future with List of n rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getWith method.

    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on with

  258. def getAsyncWith(txData: List[_])(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule with applied raw transaction data.

    Get Future with List of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getWith method.

    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on with

  259. def getAsyncWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of n rows as tuples matching molecule with applied molecule transaction data.

    Get Future with List of n rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getWith method.

    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

  260. def getAsyncWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Future[List[(A, B, C, D, E, F, G)]]

    Get Future with List of all rows as tuples matching molecule with applied molecule transaction data.

    Get Future with List of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db.

    For more info and code examples see equivalent synchronous getWith method. Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetAsyncList
    See also

    Manual on with

  261. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  262. def getHistory(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get history of operations as List on an attribute in the db.

    Get history of operations as List on an attribute in the db.

    Generic datom attributes that can be called when getHistory is called:

    e - Entity id
    a - Attribute name
    v - Attribute value
    ns - Namespace name
    tx - TxReport
    t - Transaction time t
    txInstant - Transaction time as java.util.Date
    op - Operation: true (add) or false (retract)

    Example:

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    manual for more info on generic attributes.

    Equivalent asynchronous getAsyncHistory method.

  263. def getIterable(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching the molecule.

    Get Iterable of all rows as tuples matching the molecule.

    Rows are lazily type-casted on each call to iterator.next().

    Person.name.age.getIterable.toList === List(
      ("Ben", 42),
      ("Liz", 37),
    )
    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is a tuple of types matching the attributes of the molecule

    Definition Classes
    GetIterable
    See also

    Equivalent asynchronous getAsyncIterable method.

  264. def getIterableAsOf(date: Date)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule as of date.

    Get Iterable of all rows as tuples matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // Get Iterable of all rows as of beforeInsert
    val iterable0: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(beforeInsert)
    val iterator0: Iterator[(String, Int)] = iterable0.iterator
    iterator0.hasNext === false // Nothing yet
    
    // Get Iterable of all rows as of afterInsert
    val iterable1: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(afterInsert)
    val iterator1: Iterator[(String, Int)] = iterable1.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator1.next === ("Ben", 42)
    iterator1.next === ("Liz", 37)
    
    // Get Iterable of all rows as of afterUpdate
    val iterable2: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(afterUpdate)
    val iterator2: Iterator[(String, Int)] = iterable2.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator2.next === ("Ben", 43) // Ben now 43
    iterator2.next === ("Liz", 37)
    
    // Get Iterable of all rows as of afterRetract
    val iterable3: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(afterRetract)
    val iterator3: Iterator[(String, Int)] = iterable3.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator3.next === ("Liz", 37)
    iterator3.hasNext === false // Ben gone
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableAsOf method.

  265. def getIterableAsOf(tx: TxReport)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule as of tx.

    Get Iterable of all rows as tuples matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get Iterable of all rows as of tx1 (after insert)
    val iterable1: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(tx1)
    val iterator1: Iterator[(String, Int)] = iterable1.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator1.next === ("Ben", 42)
    iterator1.next === ("Liz", 37)
    
    // Get Iterable of all rows as of tx2 (after update)
    val iterable2: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(tx2)
    val iterator2: Iterator[(String, Int)] = iterable2.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator2.next === ("Ben", 43) // Ben now 43
    iterator2.next === ("Liz", 37)
    
    // Get Iterable of all rows as of tx3 (after retract)
    val iterable3: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(tx3)
    val iterator3: Iterator[(String, Int)] = iterable3.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator3.next === ("Liz", 37)
    iterator3.hasNext === false // Ben gone
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableAsOf method.

  266. def getIterableAsOf(t: Long)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule as of transaction time t.

    Get Iterable of all rows as tuples matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    Call getIterableAsOf for large result sets to maximize runtime performance. Data is lazily type-casted on each call to next on the iterator.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    
    // Get Iterable of all rows as of transaction t 1028 (after insert)
    val iterable1: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(1028)
    val iterator1: Iterator[(String, Int)] = iterable1.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator1.next === ("Liz", 37)
    iterator1.next === ("Ben", 42)
    
    // Get Iterable of all rows as of transaction t 1031 (after update)
    val iterable2: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(1031)
    val iterator2: Iterator[(String, Int)] = iterable2.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator2.next === ("Liz", 37)
    iterator2.next === ("Ben", 43) // Ben now 43
    
    // Get Iterable of all rows as of transaction t 1032 (after retract)
    val iterable3: Iterable[(String, Int)] = Person.name.age.getIterableAsOf(1032)
    val iterator3: Iterator[(String, Int)] = iterable3.iterator
    
    // Type casting lazily performed with each call to `next`
    iterator3.next === ("Liz", 37)
    iterator3.hasNext === false // Ben gone
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableAsOf method.

  267. def getIterableSince(date: Date)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule since date.

    Get Iterable of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.getIterable.iterator.toList === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getIterableSince(date1).iterator.toList === List("Ben", "Cay")
    
    // Cay added since date2
    Person.name.getIterableSince(date2).iterator.toList === List("Cay")
    
    // Nothing added since date3
    Person.name.getIterableSince(date3).iterator.toList === Nil
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableSince method.

  268. def getIterableSince(tx: TxReport)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule since tx.

    Get Iterable of all rows as tuples matching molecule since tx.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.getIterable.iterator.toList === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getIterableSince(tx1).iterator.toList === List("Ben", "Cay")
    
    // Cay added since tx2
    Person.name.getIterableSince(tx2).iterator.toList === List("Cay")
    
    // Nothing added since tx3
    Person.name.getIterableSince(tx3).iterator.toList === Nil
    tx

    TxReport

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableSince method.

  269. def getIterableSince(t: Long)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule since transaction time t.

    Get Iterable of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    Call getIterableSince for large result sets to maximize runtime performance. Data is lazily type-casted on each call to next on the iterator.

    t can for instance be retrieved calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values as Iterable
    Person.name.getIterable.iterator.toList === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t1
    Person.name.getIterableSince(t1).iterator.toList === List("Ben", "Cay")
    
    // Cay added since transaction time t2
    Person.name.getIterableSince(t2).iterator.toList === List("Cay")
    
    // Nothing added since transaction time t3
    Person.name.getIterableSince(t3).iterator.toList === Nil
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    Iterable[Tpl] where Tpl is tuple of data matching molecule

    Definition Classes
    GetIterable
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncIterableSince method.

  270. def getIterableWith(txData: List[_])(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule with applied raw transaction data.

    Get Iterable of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getIterableWith(newDataTx).size === 250
    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    Iterable of molecule data

    Definition Classes
    GetIterable
    See also

    Manual on with

    Equivalent asynchronous getAsyncIterableWith method.

  271. def getIterableWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Iterable[(A, B, C, D, E, F, G)]

    Get Iterable of all rows as tuples matching molecule with applied molecule transaction data.

    Get Iterable of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val ben = Person.name("Ben").likes("pasta").save.eid
    
    // Base data
    Person.name.likes.getIterableWith(
      // apply imaginary transaction data
      Person(ben).likes("sushi").getUpdateTx
    ).iterator.toList === List(
      // Effect: Ben would like sushi if tx was applied
      ("Ben", "sushi")
    )
    
    // Current state is still the same
    Person.name.likes.get === List(
      ("Ben", "pasta")
    )

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    Iterable of molecule data

    Definition Classes
    GetIterable
    See also

    Manual on with

    Equivalent asynchronous getAsyncIterableWith method.

  272. def getJson(n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule

    Get json data for n rows matching molecule

    Person.name.age.getJson(1) ===
      """[
        |{"person.name": "Ben", "person.age": 42}
        |]""".stripMargin

    Namespace.Attribute is used as json fields. Values are quoted when necessary. Nested data becomes json objects etc.

    n

    Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on getJson

    Equivalent asynchronous getAsyncJson method.

  273. def getJson(implicit conn: Conn): String

    Get json data for all rows matching molecule.

    Get json data for all rows matching molecule.

    Person.name.age.getJson ===
      """[
        |{"person.name": "Ben", "person.age": 42},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin

    Namespace.Attribute is used as json fields. Values are quoted when necessary. Nested data becomes json objects etc.

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on getJson

    Equivalent asynchronous getAsyncJson method.

  274. def getJsonAsOf(date: Date, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule as of tx.

    Get json data for n rows matching molecule as of tx.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Get List of all rows as of afterUpdate
    Person.name.age.getJsonAsOf(afterUpdate) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get List of n rows as of afterUpdate
    Person.name.age.getJsonAsOf(afterUpdate, 1) ===
      """[
        |{"person.name": "Ben", "person.age": 43}
        |]""".stripMargin
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  275. def getJsonAsOf(date: Date)(implicit conn: Conn): String

    Get json data for all rows matching molecule as of date.

    Get json data for all rows matching molecule as of date.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val List(ben, liz) = tx1.eids
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // No data yet before insert
    Person.name.age.getJsonAsOf(beforeInsert) === ""
    
    // Get List of all rows as of afterInsert
    Person.name.age.getJsonAsOf(afterInsert) ===
      """[
        |{"person.name": "Ben", "person.age": 42},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get List of all rows as of afterUpdate
    Person.name.age.getJsonAsOf(afterUpdate) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get List of all rows as of afterRetract
    Person.name.age.getJsonAsOf(afterRetract) ===
      """[
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  276. def getJsonAsOf(tx: TxReport, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule as of tx.

    Get json data for n rows matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Get json for all rows as of transaction tx2 (after update) - Ben now 43
    Person.name.age.getJsonAsOf(tx2) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for n rows as of transaction tx2 (after update) - Ben now 43
    Person.name.age.getJsonAsOf(tx2, 1) ===
      """[
        |{"person.name": "Ben", "person.age": 43}
        |]""".stripMargin
    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  277. def getJsonAsOf(tx: TxReport)(implicit conn: Conn): String

    Get json data for all rows matching molecule as of tx.

    Get json data for all rows matching molecule as of tx.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we get a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    )
    val List(ben, liz) = tx1.eids
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get json for all rows as of transaction tx1 (after insert)
    Person.name.age.getJsonAsOf(tx1) ===
      """[
        |{"person.name": "Ben", "person.age": 42},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for all rows as of transaction tx2 (after update) - Ben now 43
    Person.name.age.getJsonAsOf(tx2) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for all rows as of transaction tx3 (after retract) - Ben gone
    Person.name.age.getJsonAsOf(tx3) ===
      """[
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  278. def getJsonAsOf(t: Long, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule as of transaction time t.

    Get json data for n rows matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
    )
    
    // Get json for all rows as of transaction t 1031 (after update)
    Person.name.age.getJsonAsOf(1031) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for n (1) rows as of transaction t 1031 (after update)
    Person.name.age.getJsonAsOf(1031, 1) ===
      """[
        |{"person.name": "Ben", "person.age": 43}
        |]""".stripMargin
    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  279. def getJsonAsOf(t: Long)(implicit conn: Conn): String

    Get json data for all rows matching molecule as of transaction time t.

    Get json data for all rows matching molecule as of transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37)
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    
    // Get json for all rows as of transaction t 1028 (after insert)
    Person.name.age.getJsonAsOf(1028) ===
      """[
        |{"person.name": "Ben", "person.age": 42},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for all rows as of transaction t 1031 (after update) - Ben now 43
    Person.name.age.getJsonAsOf(1031) ===
      """[
        |{"person.name": "Ben", "person.age": 43},
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    
    // Get json for all rows as of transaction t 1032 (after retract) - Ben gone
    Person.name.age.getJsonAsOf(1032) ===
      """[
        |{"person.name": "Liz", "person.age": 37}
        |]""".stripMargin
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonAsOf method.

  280. def getJsonComposite(conn: Conn, n: Int): String
    Attributes
    protected
    Definition Classes
    GetJson
  281. def getJsonFlat(conn: Conn, n: Int): String
    Attributes
    protected
    Definition Classes
    GetJson
  282. def getJsonSince(date: Date, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule since date.

    Get json data for n rows matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getJsonSince(date1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Ben and Cay added since date1 - only n (1) rows returned
    Person.name.getJsonSince(date1, 1) ===
      """[
        |{"person.name": "Ben"}
        |]""".stripMargin
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  283. def getJsonSince(date: Date)(implicit conn: Conn): String

    Get json data for all rows matching molecule since date.

    Get json data for all rows matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getJsonSince(date1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Cay added since date2
    Person.name.getJsonSince(date2) ===
      """[
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Nothing added since date3
    Person.name.getJsonSince(date3) === ""
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  284. def getJsonSince(tx: TxReport, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule since tx.

    Get json data for n rows matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getJsonSince(tx1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Ben and Cay added since tx1 - only n (1) rows returned
    Person.name.getJsonSince(tx1, 1) ===
      """[
        |{"person.name": "Ben"}
        |]""".stripMargin
    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  285. def getJsonSince(tx: TxReport)(implicit conn: Conn): String

    Get json data for all rows matching molecule since tx.

    Get json data for all rows matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getJsonSince(tx1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Cay added since tx2
    Person.name.getJsonSince(tx2) ===
      """[
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Nothing added since tx3
    Person.name.getJsonSince(tx3) === ""
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  286. def getJsonSince(t: Long, n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule since transaction time t.

    Get json data for n rows matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getJsonSince(t1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Ben and Cay added since transaction time t 1028 - only n (1) rows returned
    Person.name.getJsonSince(t1, 1) ===
      """[
        |{"person.name": "Ben"}
        |]""".stripMargin
    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  287. def getJsonSince(t: Long)(implicit conn: Conn): String

    Get json data for all rows matching molecule since transaction time t.

    Get json data for all rows matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getJsonSince(t1) ===
      """[
        |{"person.name": "Ben"},
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Cay added since transaction time t 1030
    Person.name.getJsonSince(t2) ===
      """[
        |{"person.name": "Cay"}
        |]""".stripMargin
    
    // Nothing added since transaction time t 1032
    Person.name.getJsonSince(t3) === ""
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncJsonSince method.

  288. def getJsonWith(txData: List[_], n: Int)(implicit conn: Conn): String

    Get json data for n rows matching molecule with applied raw transaction data.

    Get json data for n rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getJsonWith(newDataTx).size === 250
    
    // Imagine future db - Let's just take 10
    Person.name.getJsonWith(newDataTx, 10).size === 10
    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on with

    Equivalent asynchronous getAsyncJsonWith method.

  289. def getJsonWith(txData: List[_])(implicit conn: Conn): String

    Get json data for all rows matching molecule with applied raw transaction data.

    Get json data for all rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getJsonWith(newDataTx).size === 250
    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on with

    Equivalent asynchronous getAsyncJsonWith method.

  290. def getJsonWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): String

    Get json data for all rows matching molecule with applied molecule transaction data.

    Get json data for all rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val List(ben, liz) = Person.name.likes.insert(
      ("Ben", "pasta"),
      ("Liz", "pizza")
    ).eids
    
    // Test multiple transactions
    Person.name.likes.getJsonWith(
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) ===
      """[
        |{"person.name": "Ben", "person.likes": "sushi"},
        |{"person.name": "Liz", "person.likes": "cake"}
        |]""".stripMargin
    
    // Same as above, but only n (1) rows returned:
    Person.name.likes.getJsonWith(
      1
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) ===
      """[
        |{"person.name": "Ben", "person.likes": "sushi"}
        |]""".stripMargin

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on with

    Equivalent asynchronous getAsyncJsonWith method.

  291. def getJsonWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): String

    Get json data for all rows matching molecule with applied molecule transaction data.

    Get json data for all rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val ben = Person.name("Ben").likes("pasta").save.eid
    
    // Base data
    Person.name.likes.getJsonWith(
      // apply imaginary transaction data
      Person(ben).likes("sushi").getUpdateTx
    ) ===
      """[
        |{"person.name": "Ben", "person.likes": "sushi"}
        |]""".stripMargin
    
    // Current state is still the same
    Person.name.likes.get === List(("Ben", "pasta"))

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    String of json

    Definition Classes
    GetJson
    See also

    Manual on with

    Equivalent asynchronous getAsyncJsonWith method.

  292. def getListOf[T](implicit conn: Conn): List[T]
    Definition Classes
    GetList
  293. def getRaw(n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule.

    Get java.util.Collection of n untyped rows matching molecule.

    Person.name.age.getRaw(1).toString === """[["Ben" 42]]"""
    n

    Number of rows

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Equivalent asynchronous getAsyncRaw method.

  294. def getRaw(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule.

    Get java.util.Collection of all untyped rows matching molecule.

    Person.name.age.getRaw.toString === """[["Ben" 42], ["Liz" 37]]"""
    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Equivalent asynchronous getAsyncRaw method.

  295. def getRawAsOf(date: Date, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule as of date.

    Get java.util.Collection of n untyped rows matching molecule as of date.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val ben = tx1.eid
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // Get all rows of raw data as of beforeInsert
    Person.name.age.getRawAsOf(beforeInsert).toString === """[]"""
    
    // Get all rows of raw data as of afterInsert
    Person.name.age.getRawAsOf(afterInsert).toString === """[["Liz" 37], ["Ben" 42]]"""
    
    // Get n (1) rows of raw data as of afterInsert
    Person.name.age.getRawAsOf(afterInsert, 1).toString === """[["Liz" 37]]"""
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  296. def getRawAsOf(date: Date)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule as of date.

    Get java.util.Collection of all untyped rows matching molecule as of date.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data at a human point in time (a java.util.Date).

    val beforeInsert = new java.util.Date
    
    // Insert
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val ben = tx1.eid
    val afterInsert = new java.util.Date
    
    // Update
    val tx2 = Person(ben).age(43).update
    val afterUpdate = new java.util.Date
    
    // Retract
    val tx3 = ben.retract
    val afterRetract = new java.util.Date
    
    // Get raw data as of beforeInsert
    Person.name.age.getRawAsOf(beforeInsert).toString === """[]"""
    
    // Get raw data as of afterInsert
    Person.name.age.getRawAsOf(afterInsert).toString === """[["Liz" 37], ["Ben" 42]]"""
    
    // Get raw data as of afterUpdate
    Person.name.age.getRawAsOf(afterUpdate).toString === """[["Liz" 37], ["Ben" 43]]""" // Ben now 43
    
    // Get raw data as of afterRetract
    Person.name.age.getRawAsOf(afterRetract).toString === """[["Liz" 37]]""" // Ben gone
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  297. def getRawAsOf(tx: TxReport, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule as of tx.

    Get java.util.Collection of n untyped rows matching molecule as of tx.

    The Array is only populated with n rows of type-casted tuples. Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val ben = tx1.eid
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get all rows of raw data as of tx1 (after insert)
    Person.name.age.getRawAsOf(tx1).toString === """[["Liz" 37], ["Ben" 42]]"""
    
    // Get n (1) rows of raw data as of tx1 (after insert)
    Person.name.age.getRawAsOf(tx1, 1).toString === """[["Liz" 37]]"""
    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  298. def getRawAsOf(tx: TxReport)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule as of tx.

    Get java.util.Collection of all untyped rows matching molecule as of tx.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal asOf method can take a transaction entity id as argument to retrieve a database value as of that transaction (including).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Insert (tx report 1)
    val tx1 = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    )
    val ben = tx1.eid
    
    // Update (tx report 2)
    val tx2 = Person(ben).age(43).update
    
    // Retract (tx report 3)
    val tx3 = ben.retract
    
    // Get raw data as of tx1 (after insert)
    Person.name.age.getRawAsOf(tx1).toString === """[["Liz" 37], ["Ben" 42]]"""
    
    // Get raw data as of tx2 (after update)
    Person.name.age.getRawAsOf(tx2).toString === """[["Liz" 37], ["Ben" 43]]""" // Ben now 43
    
    // Get raw data as of tx3 (after retract)
    Person.name.age.getRawAsOf(tx3).toString === """[["Liz" 37]]""" // Ben gone
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  299. def getRawAsOf(t: Long, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule as of transaction time t.

    Get java.util.Collection of n untyped rows matching molecule as of transaction time t.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
    )
    
    // Get all rows of raw data as of transaction t 1031 (after update)
    Person.name.age.getRawAsOf(1028).toString === """[["Ben" 43], ["Liz" 37]]"""
    
    // Get n (1) rows of raw data as of transaction t 1031 (after update)
    Person.name.age.getRawAsOf(1031, 1).toString === """[["Ben" 43]]"""
    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  300. def getRawAsOf(t: Long)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule as of transaction time t.

    Get java.util.Collection of all untyped rows matching molecule as of transaction time t.

    Call getRawAsOf when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved in a getHistory call for an attribute and then be used to get data as of that point in time (including that transaction):

    // Insert (t 1028)
    val List(ben, liz) = Person.name.age insert List(
      ("Ben", 42),
      ("Liz", 37),
    ) eids
    
    // Update (t 1031)
    Person(ben).age(43).update
    
    // Retract (t 1032)
    ben.retract
    
    // History of Ben
    Person(ben).age.t.op.getHistory.sortBy(r => (r._2, r._3)) === List(
      (42, 1028, true),  // Insert:  42 asserted
      (42, 1031, false), // Update:  42 retracted
      (43, 1031, true),  //          43 asserted
      (43, 1032, false)  // Retract: 43 retracted
    )
    
    // Get raw data as of transaction t 1028 (after insert)
    Person.name.age.getRawAsOf(1028).toString === """[["Ben" 42], ["Liz" 37]]"""
    
    // Get raw data as of transaction t 1031 (after update)
    Person.name.age.getRawAsOf(1031).toString === """[["Ben" 43], ["Liz" 37]]""" // Ben now 43
    
    // Get raw data as of transaction t 1032 (after retract)
    Person.name.age.getRawAsOf(1032).toString === """[["Liz" 37]]""" // Ben gone
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawAsOf method.

  301. def getRawSince(date: Date, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule since date.

    Get java.util.Collection of n untyped rows matching molecule since date.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getRawSince(date1).toString === """[["Ben"], ["Cay"]]"""
    
    // Ben and Cay added since date1 - only n (1) rows returned
    Person.name.getRawSince(date1, 1).toString === """[["Ben"]]"""
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  302. def getRawSince(date: Date)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule since date.

    Get java.util.Collection of all untyped rows matching molecule since date.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getRawSince(date1).toString === """[["Ben"], ["Cay"]]"""
    
    // Cay added since date2
    Person.name.getRawSince(date2).toString === """[["Cay"]]"""
    
    // Nothing added since date3
    Person.name.getRawSince(date3).toString === """[]"""
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  303. def getRawSince(tx: TxReport, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule since tx.

    Get java.util.Collection of n untyped rows matching molecule since tx.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getRawSince(tx1).toString === """[["Ben"], ["Cay"]]"""
    
    // Ben and Cay added since tx1 - only n (1) rows returned
    Person.name.getRawSince(tx1, 1).toString === """[["Ben"]]"""
    tx

    TxReport (returned from all molecule transaction operations)

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  304. def getRawSince(tx: TxReport)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule since tx.

    Get java.util.Collection of all untyped rows matching molecule since tx.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Datomic's internal since method can take a transaction entity id as argument to retrieve a database value since that transaction (excluding).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getRawSince(tx1).toString === """[["Ben"], ["Cay"]]"""
    
    // Cay added since tx2
    Person.name.getRawSince(tx2).toString === """[["Cay"]]"""
    
    // Nothing added since tx3
    Person.name.getRawSince(tx3).toString === """[]"""
    tx

    TxReport (returned from all molecule transaction operations)

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  305. def getRawSince(t: Long, n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule since transaction time t.

    Get java.util.Collection of n untyped rows matching molecule since transaction time t.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values as Iterable
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t1
    Person.name.getRawSince(t1).toString === """[["Ben"], ["Cay"]]"""
    
    // Ben and Cay added since transaction time t1 - only n (1) rows returned
    Person.name.getRawSince(t1).toString === """[["Ben"]]"""
    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  306. def getRawSince(t: Long)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule since transaction time t.

    Get java.util.Collection of all untyped rows matching molecule since transaction time t.

    Call getRawSince when data doesn't need to be type-casted. Datomic's raw data is returned as-is.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values as Iterable
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t1
    Person.name.getRawSince(t1).toString === """[["Ben"], ["Cay"]]"""
    
    // Cay added since transaction time t2
    Person.name.getRawSince(t2).toString === """[["Cay"]]"""
    
    // Nothing added since transaction time t3
    Person.name.getRawSince(t3).toString === """[]"""
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncRawSince method.

  307. def getRawWith(txData: List[_], n: Int)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule with applied raw transaction data.

    Get java.util.Collection of n untyped rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getRawWith(newDataTx).size === 250
    
    // Imagine future db - Let's just take 10
    Person.name.getRawWith(newDataTx, 10).size === 10
    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on with

    Equivalent asynchronous getAsyncRawWith method.

  308. def getRawWith(txData: List[_])(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule with applied raw transaction data.

    Get java.util.Collection of all untyped rows matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getRawWith(newDataTx).size === 250
    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on with

    Equivalent asynchronous getAsyncRawWith method.

  309. def getRawWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of n untyped rows matching molecule with applied molecule transaction data.

    Get java.util.Collection of n untyped rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val List(ben, liz) = Person.name.likes.insert(
      ("Ben", "pasta"),
      ("Liz", "pizza")
    ).eids
    
    // Test multiple transactions
    Person.name.likes.getRawWith(
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ).toString === """[["Ben" "sushi"], ["Liz" "cake"]]"""
    
    // Same as above, but only n (1) rows returned:
    Person.name.likes.getRawWith(
      1
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ).toString === """[["Ben" "sushi"]]"""

    Multiple transactions can be applied to test more complex what-if scenarios!

    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

    Equivalent asynchronous getAsyncRawWith method.

  310. def getRawWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): Collection[List[AnyRef]]

    Get java.util.Collection of all untyped rows matching molecule with applied molecule transaction data.

    Get java.util.Collection of all untyped rows matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val ben = Person.name("Ben").likes("pasta").save.eid
    
    // Base data
    Person.name.likes.getRawWith(
      Person(ben).likes("sushi").getUpdateTx
    ).toString ==== """[["Ben" "sushi"]]"""
    
    // Current state is still the same
    Person.name.likes.get === List(("Ben", "pasta"))

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    java.util.Collection[java.util.List[AnyRef]]

    Definition Classes
    GetRaw
    See also

    Manual on with

    Equivalent asynchronous getAsyncRawWith method.

  311. def getSaveTx(implicit conn: Conn): Seq[Seq[Statement]]

    Get transaction statements of a call to save on a molecule (without affecting the db).

    Get transaction statements of a call to save on a molecule (without affecting the db).

    conn

    Implicit Conn value in scope

    returns

    Transaction statements

    Definition Classes
    Molecule
  312. def getSince(date: Date, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule since date.

    Get List of n rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getSince(date1) === List("Ben", "Cay")
    
    // Ben and Cay added since date1 - only n (1) rows returned
    Person.name.getSince(date1, 1) === List("Ben")
    date

    java.util.Date

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  313. def getSince(date: Date)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule since date.

    Get List of all rows as tuples matching molecule since date.

    Get data added/retracted since a human point in time (a java.util.Date).

    // Transact 3 times (`inst` retrieves transaction time/Date from tx report)
    val date1 = Person.name("Ann").save.inst
    val date2 = Person.name("Ben").save.inst
    val date3 = Person.name("Cay").save.inst
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since date1
    Person.name.getSince(date1) === List("Ben", "Cay")
    
    // Cay added since date2
    Person.name.getSince(date2) === List("Cay")
    
    // Nothing added since date3
    Person.name.getSince(date3) === Nil
    date

    java.util.Date

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  314. def getSince(tx: TxReport, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule since tx.

    Get List of n rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getSince(tx1) === List("Ben", "Cay")
    
    // Ben and Cay added since tx1 - only n (1) rows returned
    Person.name.getSince(tx1, 1) === List("Ben")
    tx

    TxReport

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  315. def getSince(tx: TxReport)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule since tx.

    Get List of all rows as tuples matching molecule since tx.

    Datomic's internal since can take a transaction entity id as argument to retrieve a database value since that transaction (excluding the transaction itself).

    Instead of supplying the transaction entity id, in Molecule we supply a TxReport that contains the transaction entity id (which is used as argument to Datomic internally). This is more convenient when using Molecule since we getAsync a TxReport from transaction operations like get, update, retract etc.

    // Get tx reports for 3 transactions
    val tx1 = Person.name("Ann").save
    val tx2 = Person.name("Ben").save
    val tx3 = Person.name("Cay").save
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since tx1
    Person.name.getSince(tx1) === List("Ben", "Cay")
    
    // Cay added since tx2
    Person.name.getSince(tx2) === List("Cay")
    
    // Nothing added since tx3
    Person.name.getSince(tx3) === Nil
    tx

    TxReport

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  316. def getSince(t: Long, n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule since transaction time t.

    Get List of n rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getSince(t1) === List("Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028 - only n (1) rows returned
    Person.name.getSince(t1, 1) === List("Ben")
    t

    Transaction time t

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  317. def getSince(t: Long)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule since transaction time t.

    Get List of all rows as tuples matching molecule since transaction time t.

    Transaction time t is an auto-incremented transaction number assigned internally by Datomic.

    t can for instance be retrieved by calling t on the tx report returned from transactional operations and then be used to get data since that point in time (excluding that transaction):

    // 3 transaction times `t`
    val t1 = Person.name("Ann").save.t
    val t2 = Person.name("Ben").save.t
    val t3 = Person.name("Cay").save.t
    
    // Current values
    Person.name.get === List("Ann", "Ben", "Cay")
    
    // Ben and Cay added since transaction time t 1028
    Person.name.getSince(t1) === List("Ben", "Cay")
    
    // Cay added since transaction time t 1030
    Person.name.getSince(t2) === List("Cay")
    
    // Nothing added since transaction time t 1032
    Person.name.getSince(t3) === Nil
    t

    Transaction time t

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on asof/since

    Equivalent asynchronous getAsyncSince method.

  318. def getUpdateTx(implicit conn: Conn): Seq[Seq[Statement]]

    Get transaction statements of a call to update on a molecule (without affecting the db).

    Get transaction statements of a call to update on a molecule (without affecting the db).

    conn

    Implicit Conn value in scope

    Definition Classes
    Molecule
  319. def getWith(txData: List[_], n: Int)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule with applied raw transaction data.

    Get List of n rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getWith(newDataTx).size === 250
    
    // Imagine future db - Let's just take 10
    Person.name.getWith(newDataTx, 10).size === 10
    txData

    Raw transaction data as java.util.List[Object]

    n

    Int Number of rows returned

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on with

    Equivalent asynchronous getAsyncWith method.

  320. def getWith(txData: List[_])(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule with applied raw transaction data.

    Get List of all rows as tuples matching molecule with applied raw transaction data.

    Apply raw transaction data to in-memory "branch" of db without affecting db to see how it would then look:

    // Live size of Person db
    Person.name.get.size === 150
    
    // Read some transaction data from file
    val data_rdr2 = new FileReader("examples/resources/seattle/seattle-data1a.dtm")
    val newDataTx = Util.readAll(data_rdr2).get(0).asInstanceOf[java.util.List[Object]]
    
    // Imagine future db - 100 persons would be added, apparently
    Person.name.getWith(newDataTx).size === 250
    txData

    Raw transaction data as java.util.List[Object]

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on with

    Equivalent asynchronous getAsyncWith method.

  321. def getWith(n: Int, txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of n rows as tuples matching molecule with applied molecule transaction data.

    Get List of n rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val List(ben, liz) = Person.name.likes.insert(
      ("Ben", "pasta"),
      ("Liz", "pizza")
    ).eids
    
    // Test multiple transactions
    Person.name.likes.getWith(
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) === List(
      ("Ben", "sushi")
      ("Liz", "cake")
    )
    
    // Same as above, but only n (1) rows returned:
    Person.name.likes.getWith(
      1
      Person(ben).likes("sushi").getUpdateTx,
      Person(liz).likes("cake").getUpdateTx
    ) === List(
      ("Ben", "sushi")
    )
    n

    Int Number of rows returned

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    Note

    Note how the n parameter has to come before the txMolecules vararg.

    See also

    Manual on with

    Equivalent asynchronous getAsyncWith method.

  322. def getWith(txMolecules: Seq[Seq[Statement]]*)(implicit conn: Conn): List[(A, B, C, D, E, F, G)]

    Get List of all rows as tuples matching molecule with applied molecule transaction data.

    Get List of all rows as tuples matching molecule with applied molecule transaction data.

    Apply one or more molecule transactions to in-memory "branch" of db without affecting db to see how it would then look:

    // Current state
    val ben = Person.name("Ben").likes("pasta").save.eid
    
    // Base data
    Person.name.likes.getWith(
      // apply imaginary transaction data
      Person(ben).likes("sushi").getUpdateTx
    ) === List(
      // Effect: Ben would like sushi if tx was applied
      ("Ben", "sushi")
    )
    
    // Current state is still the same
    Person.name.likes.get === List(("Ben", "pasta"))

    Multiple transactions can be applied to test more complex what-if scenarios!

    txMolecules

    Transaction statements from applied Molecules with test data

    conn

    Implicit Conn value in scope

    returns

    List[Tpl] where Tpl is a tuple of data matching molecule

    Definition Classes
    GetList
    See also

    Manual on with

    Equivalent asynchronous getAsyncWith method.

  323. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  324. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  325. def jsonAggr(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  326. def jsonAggrDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  327. def jsonAggrLazySeq(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  328. def jsonAggrLazySeqDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  329. def jsonAggrLazySeqQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  330. def jsonAggrLazySeqToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  331. def jsonAggrList(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  332. def jsonAggrListDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  333. def jsonAggrListQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  334. def jsonAggrListRand(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  335. def jsonAggrListRandDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  336. def jsonAggrListRandQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  337. def jsonAggrListRandToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  338. def jsonAggrListToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  339. def jsonAggrQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  340. def jsonAggrSingleSample(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  341. def jsonAggrSingleSampleDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  342. def jsonAggrSingleSampleQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  343. def jsonAggrSingleSampleToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  344. def jsonAggrToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  345. def jsonMany(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  346. def jsonManyDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  347. def jsonManyQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  348. def jsonManyToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  349. def jsonMap(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  350. def jsonMapDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  351. def jsonMapQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  352. def jsonOne(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  353. def jsonOneAny(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  354. def jsonOneDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  355. def jsonOneQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  356. def jsonOneToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  357. def jsonOptMany(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  358. def jsonOptManyDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  359. def jsonOptManyEnum(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  360. def jsonOptManyQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  361. def jsonOptManyToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  362. def jsonOptMap(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  363. def jsonOptMapDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  364. def jsonOptMapQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  365. def jsonOptOne(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  366. def jsonOptOneDate(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  367. def jsonOptOneEnum(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  368. def jsonOptOneQuoted(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  369. def jsonOptOneToString(sb: StringBuilder, field: String, row: List[_], i: Int): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  370. lazy val localOffset: String
    Definition Classes
    DateHandling
  371. lazy val localZoneOffset: ZoneOffset
    Definition Classes
    DateHandling
  372. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  373. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  374. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  375. final def o(opt: Option[Any]): String
    Attributes
    protected
    Definition Classes
    Helpers
  376. final def os(opt: Option[Set[_]]): String
    Attributes
    protected
    Definition Classes
    Helpers
  377. def pair(sb: StringBuilder, field: String, value: Any): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  378. def quote(sb: StringBuilder, s: String): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  379. def quotedPair(sb: StringBuilder, field: String, value: String): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  380. def row2json(sb: StringBuilder, row: List[AnyRef]): StringBuilder
    Attributes
    protected
    Definition Classes
    JsonBuilder
  381. def save(implicit conn: Conn): TxReport

    Save data applied to molecule attributes.

    Save data applied to molecule attributes.

    Returns TxReport having info about the result of the save transaction.

    val txReport = Person.name("Ben").age(42).save
    
    // Data has been saved in db
    Person.name.age.get === List(("Ben", 42))

    The save operation is synchronous and blocking. Use saveAsync for non-blocking asynchronous saves.

    conn

    Implicit Conn value in scope

    returns

    TxReport with info about the result of the save transaction.

    Definition Classes
    Molecule
  382. def saveAsync(implicit conn: Conn, ec: ExecutionContext): Future[TxReport]

    Asynchronously save data applied to molecule attributes.

    Asynchronously save data applied to molecule attributes.

    Returns Future with TxReport having info about the result of the save transaction.

    val futureSave: Future[TxReport] = Person.name("Ben").age(42).saveAsync
    
    for {
      _ <- futureSave
      result <- Person.name.age.getAsync
    } yield {
      // Data was saved
      result.head === ("Ben", 42)
    }

    The save operation is asynchronous and non-blocking. Internally calls Datomic's asynchronous API.

    conn

    Implicit Conn value in scope

    returns

    TxReport with info about the result of the save transaction.

    Definition Classes
    Molecule
  383. final def seq[T](values: Seq[T]): String
    Attributes
    protected
    Definition Classes
    Helpers
  384. def str2date(s: String, zoneOffset: ZoneOffset = localZoneOffset): Date
    Definition Classes
    DateHandling
  385. def str2zdt(s: String, zoneOffset: ZoneOffset = localZoneOffset): ZonedDateTime
    Definition Classes
    DateHandling
  386. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  387. final def time(n: Int, prev: Int = 0): Unit
    Attributes
    protected
    Definition Classes
    Helpers
  388. def toString(): String
    Definition Classes
    AnyRef → Any
  389. def truncateDateStr(dateStr: String): String
    Definition Classes
    DateHandling
  390. final def tupleToSeq(arg: Any): Seq[Any]
    Attributes
    protected
    Definition Classes
    Helpers
  391. def untupled(rawData: Iterable[Seq[Any]]): Seq[Seq[Any]]
    Attributes
    protected
    Definition Classes
    Molecule
  392. def update(implicit conn: Conn): TxReport

    Update entity with data applied to molecule attributes.

    Update entity with data applied to molecule attributes.

    Returns TxReport with info about the result of the update transaction.

    // Current data
    val ben = Person.name("Ben").age(42).save.eid
    
    // Update entity of of Ben with new age value
    Person(ben).age(43).update
    
    // Ben is now 43
    Person.name.age.get === List(("ben", 43))

    The update operation is synchronous and blocking. Use updateAsync for non-blocking asynchronous updates.

    conn

    Implicit Conn value in scope

    returns

    TxReport

    Definition Classes
    Molecule
  393. def updateAsync(implicit conn: Conn, ec: ExecutionContext): Future[TxReport]

    Asynchronously update entity with data applied to molecule attributes.

    Asynchronously update entity with data applied to molecule attributes. Returns Future with TxReport having info about the result of the update transaction.

    for {
      saveTx <- Person.name("Ben").age(42).saveAsync
      benId = saveTx.eid
      updateTx <- Person(benId).age(43).updateAsync
      result <- Person.name.age.getAsync
    } yield {
      // Ben is now 43
      result.head === ("ben", 43)
    }

    The update operation is asynchronous and non-blocking. Internally calls Datomic's asynchronous API.

    conn

    Implicit Conn value in scope

    returns

    TxReport

    Definition Classes
    Molecule
  394. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  395. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )