trait TxDAO[DbEntryType <: TxDB] extends CRUD[DbEntryType, DoubleSha256DigestBE] with TxCRUDComponent[DbEntryType] with SlickUtil[DbEntryType, DoubleSha256DigestBE]
- Alphabetic
- By Inheritance
- TxDAO
- SlickUtil
- SlickUtilAction
- TxCRUDComponent
- CRUD
- CRUDAction
- JdbcProfileComponent
- Logging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
Abstract Value Members
- abstract val table: slick.jdbc.JdbcProfile.API.TableQuery[_ <: DbTable]
The table inside our database we are inserting into
The table inside our database we are inserting into
- Definition Classes
- TxDAO → CRUDAction
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- implicit val appConfig: DbAppConfig
- Definition Classes
- CRUD → CRUDAction → JdbcProfileComponent
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def count(): Future[Int]
Returns number of rows in the table
Returns number of rows in the table
- Definition Classes
- CRUD
- def create(t: DbEntryType): Future[DbEntryType]
create a record in the database
create a record in the database
- t
- the record to be inserted
- returns
the inserted record
- Definition Classes
- CRUD
- def createAction(t: DbEntryType): slick.jdbc.JdbcProfile.API.DBIOAction[DbEntryType, slick.jdbc.JdbcProfile.API.NoStream, Write]
- Definition Classes
- CRUDAction
- def createAll(ts: Vector[DbEntryType]): Future[Vector[DbEntryType]]
- def createAllAction(ts: Vector[DbEntryType]): slick.jdbc.JdbcProfile.API.DBIOAction[Vector[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Write]
- Definition Classes
- SlickUtilAction
- def createAllNoAutoInc(ts: Vector[DbEntryType], database: SafeDatabase)(implicit ec: ExecutionContext): Future[Vector[DbEntryType]]
Creates rows in a database that are not auto incremented
Creates rows in a database that are not auto incremented
- Definition Classes
- SlickUtil
- lazy val database: slick.jdbc.JdbcProfile.API.Database
The database we are connecting to
The database we are connecting to
- Definition Classes
- JdbcProfileComponent
- lazy val dbConfig: DatabaseConfig[JdbcProfile]
The configuration details for connecting/using the database for our projects that require database connections
The configuration details for connecting/using the database for our projects that require database connections
- Definition Classes
- JdbcProfileComponent
- lazy val dbPassword: String
- Definition Classes
- JdbcProfileComponent
- lazy val dbUsername: String
- Definition Classes
- JdbcProfileComponent
- def debug(mkr: Marker, msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def debug(msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def debug(msg: => Any): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def delete(t: DbEntryType): Future[Int]
delete the corresponding record in the database
delete the corresponding record in the database
- t
- the record to be deleted
- returns
int - the number of rows affected by the deletion
- Definition Classes
- CRUD
- def deleteAction(t: DbEntryType): slick.jdbc.JdbcProfile.API.DBIOAction[Int, slick.jdbc.JdbcProfile.API.NoStream, Write]
- Definition Classes
- CRUDAction
- def deleteAll(): Future[Int]
delete all records from the table
delete all records from the table
- Definition Classes
- CRUD
- def deleteAll(ts: Vector[DbEntryType]): Future[Int]
- Definition Classes
- CRUD
- def deleteAllAction(): slick.jdbc.JdbcProfile.API.DBIOAction[Int, slick.jdbc.JdbcProfile.API.NoStream, Write with Transactional]
WARNING: Deletes all rows in table, use with care
WARNING: Deletes all rows in table, use with care
- Definition Classes
- CRUDAction
- def deleteAllAction(ts: Vector[DbEntryType]): slick.jdbc.JdbcProfile.API.DBIOAction[Int, slick.jdbc.JdbcProfile.API.NoStream, Write]
- Definition Classes
- CRUDAction
- implicit val ec: ExecutionContext
- Definition Classes
- CRUD → CRUDAction
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def error(mkr: Marker, msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def error(msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def error(msg: => Any): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- def find(t: DbEntryType): slick.jdbc.JdbcProfile.API.Query[slick.jdbc.JdbcProfile.API.Table[_], DbEntryType, Seq]
- Attributes
- protected
- Definition Classes
- CRUDAction
- def findAll(txs: Vector[DbEntryType]): slick.jdbc.JdbcProfile.API.Query[DbTable, DbEntryType, Seq]
- Definition Classes
- TxDAO → CRUDAction
- def findAll(): Future[Vector[DbEntryType]]
Finds all elements in the table
Finds all elements in the table
- Definition Classes
- CRUD
- def findAllAction(): slick.jdbc.JdbcProfile.API.DBIOAction[Vector[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Read]
- Definition Classes
- CRUDAction
- def findByOutPoint(outPoint: TransactionOutPoint): Future[Option[DbEntryType]]
- def findByOutPoints(outPoints: Vector[TransactionOutPoint]): Future[Vector[DbEntryType]]
- def findByPrimaryKey(txIdBE: DoubleSha256DigestBE): slick.jdbc.JdbcProfile.API.Query[DbTable, DbEntryType, Seq]
return all rows that have a certain primary key
return all rows that have a certain primary key
- returns
Query object corresponding to the selected rows
- Definition Classes
- TxDAO → CRUDAction
- def findByPrimaryKeyAction(id: DoubleSha256DigestBE): slick.jdbc.JdbcProfile.API.DBIOAction[Option[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Read]
- Definition Classes
- CRUDAction
- def findByPrimaryKeys(txIdBEs: Vector[DoubleSha256DigestBE]): slick.jdbc.JdbcProfile.API.Query[DbTable, DbEntryType, Seq]
Finds the rows that correlate to the given primary keys
Finds the rows that correlate to the given primary keys
- Definition Classes
- TxDAO → CRUDAction
- def findByPrimaryKeysAction(ids: Vector[DoubleSha256DigestBE]): slick.jdbc.JdbcProfile.API.DBIOAction[Vector[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Read]
- Definition Classes
- CRUDAction
- def findByTxId(txId: DoubleSha256Digest): Future[Option[DbEntryType]]
- def findByTxId(txIdBE: DoubleSha256DigestBE): Future[Option[DbEntryType]]
- def findByTxIdBEs(txIdBEs: Vector[DoubleSha256DigestBE]): Future[Vector[DbEntryType]]
- def findByTxIds(txIdBEs: Vector[DoubleSha256DigestBE]): Future[Vector[DbEntryType]]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def info(mkr: Marker, msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def info(msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def info(msg: => Any): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def isDebugEnabled: Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def isErrorEnabled: Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def isInfoEnabled: Boolean
- Attributes
- protected
- Definition Classes
- Logging
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isTraceEnabled: Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def isWarnEnabled: Boolean
- Attributes
- protected
- Definition Classes
- Logging
- def logger: Logger
- Attributes
- protected
- Definition Classes
- Logging
- def loggerName: String
- Attributes
- protected
- Definition Classes
- Logging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- lazy val numThreads: Int
- Definition Classes
- JdbcProfileComponent
- lazy val profile: JdbcProfile
- Definition Classes
- JdbcProfileComponent
- def read(id: DoubleSha256DigestBE): Future[Option[DbEntryType]]
read a record from the database
read a record from the database
- id
- the id of the record to be read
- returns
Option[T] - the record if found, else none
- Definition Classes
- CRUD
- def safeDatabase: SafeDatabase
Binding to the actual database itself, this is what is used to run querys
Binding to the actual database itself, this is what is used to run querys
- Definition Classes
- CRUD
- val schemaName: Option[String]
- Definition Classes
- CRUD
- def startHikariLogger(interval: Duration): HikariLogging
Starts the background logger for hikari
Starts the background logger for hikari
- interval
- how often hikari logs database connection pool information
- Attributes
- protected
- Definition Classes
- JdbcProfileComponent
- def stopHikariLogger(): Unit
- Attributes
- protected
- Definition Classes
- JdbcProfileComponent
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- implicit def tableQuerySafeSubtypeCast[SpecificT <: AbstractTable[_], SomeT <: SpecificT](tableQuery: slick.jdbc.JdbcProfile.API.TableQuery[SomeT]): slick.jdbc.JdbcProfile.API.TableQuery[SpecificT]
We need to cast from TableQuery's of internal types (e.g.
We need to cast from TableQuery's of internal types (e.g. AddressDAO#AddressTable) to external versions of them (e.g. AddressDAO().table). You'll notice that although the latter is a subtype of the first, this requires a cast since TableQuery is not covariant in its type parameter.
However, since Query is covariant in its first type parameter, I believe the cast from TableQuery[T1] to TableQuery[T2] will always be safe so long as T1 is a subtype of T2 AND T1#TableElementType is equal to T2#TableElementType.
The above conditions are always the case when this is called within DAOs as it is only ever used for things of the form TableQuery[XDAO().table] -> TableQuery[XDAO#XTable].
- Attributes
- protected
- Definition Classes
- CRUD
- def toString(): String
- Definition Classes
- AnyRef → Any
- def trace(mkr: Marker, msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def trace(msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def trace(msg: => Any): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def update(t: DbEntryType): Future[DbEntryType]
Update the corresponding record in the database
Update the corresponding record in the database
- Definition Classes
- CRUD
- def updateAction(t: DbEntryType): slick.jdbc.JdbcProfile.API.DBIOAction[DbEntryType, slick.jdbc.JdbcProfile.API.NoStream, Write]
- Definition Classes
- CRUDAction
- def updateAll(ts: Vector[DbEntryType]): Future[Vector[DbEntryType]]
- Definition Classes
- CRUD
- def updateAllAction(ts: Vector[DbEntryType]): slick.jdbc.JdbcProfile.API.DBIOAction[Vector[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Write]
Updates all of the given ts.
Updates all of the given ts. Returns all ts that actually existed in the database and got updated This method discards things that did not exist in the database, thus could not be updated
- Definition Classes
- CRUDAction
- def upsert(t: DbEntryType): Future[DbEntryType]
insert the record if it does not exist, update it if it does
insert the record if it does not exist, update it if it does
- t
- the record to inserted / updated
- returns
t - the record that has been inserted / updated
- Definition Classes
- CRUD
- def upsertAction(t: DbEntryType): slick.jdbc.JdbcProfile.API.DBIOAction[DbEntryType, slick.jdbc.JdbcProfile.API.NoStream, Write with Read]
- Definition Classes
- CRUDAction
- def upsertAll(ts: Vector[DbEntryType]): Future[Vector[DbEntryType]]
Upserts all of the given ts in the database, then returns the upserted values
Upserts all of the given ts in the database, then returns the upserted values
- Definition Classes
- CRUD
- def upsertAllAction(ts: Vector[DbEntryType]): slick.jdbc.JdbcProfile.API.DBIOAction[Vector[DbEntryType], slick.jdbc.JdbcProfile.API.NoStream, Write with Read]
Upsert all of the given ts.
Upsert all of the given ts. Returns all ts that were inserted or updated
- Definition Classes
- CRUDAction
- See also
https://scala-slick.org/doc/3.3.3/queries.html#upserting
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def warn(mkr: Marker, msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def warn(msg: => Any, t: => Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
- def warn(msg: => Any): Unit
- Attributes
- protected
- Definition Classes
- Logging