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.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

6.  final def eq(arg0: AnyRef): Boolean

   Definition Classes

   AnyRef

7.  def equals(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

8.  def finalize(): Unit

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( classOf[java.lang.Throwable] )

9.  final def getClass(): Class[_]

   Definition Classes

   AnyRef → Any

10.  def getQueryResultAsStream(sqlQuery: String, options: Map[String, String], pgVersion: PostgresVersion = PostgresVersion.Nine, outputStreamTransformer: (OutputStream) ⇒ OutputStream = identity)(implicit conn: PGConnection, ec: ExecutionContextForBlockingOps): Source[ByteString, Future[IOResult]]

    Execute a SQL query and get its result as a stream.

    Execute a SQL query and get its result as a stream.

    sqlQuery

    sql query

    options

    options of the Postgres COPY command. For example, Map("DELIMITER" -> "','")

    pgVersion

    PostgreSQL version (8.x or 9.x)

    outputStreamTransformer

    optional output stream transformer

    conn

    Postgres connection

    ec

    ec that will be used for Postgres' blocking operations

11.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

12.  def insertStreamToTable(schema: String, table: String, options: Map[String, String], pgVersion: PostgresVersion = PostgresVersion.Nine, nbLinesPerInsertionBatch: Int = 20000, chunkInsertionConcurrency: Int = 1)(implicit conn: PGConnection, ec: ExecutionContextForBlockingOps): Flow[ByteString, Long, NotUsed]

    Insert a stream in a Postgres table (one upstream chunk will correspond to one line).

    Insert a stream in a Postgres table (one upstream chunk will correspond to one line). Insertion order is not guaranteed with chunkInsertionConcurrency > 1.

    table

    can be table_name or table_name(column1, column2) to insert data in specific columns

    pgVersion

    PostgreSQL version (8.x or 9.x)

13.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

14.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

15.  final def notify(): Unit

    Definition Classes

    AnyRef

16.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

17.  def sqlConnAsPgConnUnsafe(conn: Connection): PGConnection
18.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

19.  def toString(): String

    Definition Classes

    AnyRef → Any

20.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

21.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

22.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )