driver/io.github.octaviusframework.driver.copy/CopyManager

CopyManager

class CopyManager(stream: PgStream, queryExecutor: QueryExecutor)

Manages COPY IN and COPY OUT operations for a specific connection stream.

A COPY starts on the stream directly rather than through an exchange of queryExecutor, so it is the one place that has to ask for a waiting BEGIN itself: with auto-commit off, a COPY can be what begins the transaction.

Constructors

CopyManager

internal constructor(stream: PgStream, queryExecutor: QueryExecutor)

Types

Companion

object Companion

Functions

copyIn

fun copyIn(sql: String): CopyIn

Initiates a COPY IN operation allowing manual chunk writing.

fun copyIn(sql: String, inputStream: InputStream, bufferSize: Int = DEFAULT_BUFFER_SIZE): Long

Reads all data from the provided InputStream and writes it to the COPY IN operation.

copyOut

fun copyOut(sql: String): CopyOut

Initiates a COPY OUT operation allowing manual chunk reading.

fun copyOut(sql: String, outputStream: OutputStream): Long

Reads all data from the COPY OUT operation and writes it to the provided OutputStream.