Dpq2Connection

dpq2.Connection adopted for using with Vibe.d

class Dpq2Connection : dpq2.Connection {

Duration socketTimeout;

Duration statementTimeout;

this(ClientSettings settings);

void reset();

immutable(Answer) execStatement(string sqlCommand, ValueFormat resultFormat);

immutable(Answer) execStatement(QueryParams params);

void execStatementRbR(string sqlCommand, void delegate(immutable(Row)) answerRowProcessDg, ValueFormat resultFormat);

void execStatementRbR(QueryParams params, void delegate(immutable(Row)) answerRowProcessDg);

void prepareStatement(string statementName, string sqlStatement, Oid[] oids);

immutable(Answer) execPreparedStatement(QueryParams params);

immutable(Answer) describePreparedStatement(string preparedStatementName);

Notify waitForNotify(Duration timeout);

}

Constructors

this this(ClientSettings settings)

Members

Functions

describePreparedStatement immutable(Answer) describePreparedStatement(string preparedStatementName)
execPreparedStatement immutable(Answer) execPreparedStatement(QueryParams params)
execStatement immutable(Answer) execStatement(string sqlCommand, ValueFormat resultFormat)
execStatement immutable(Answer) execStatement(QueryParams params)
execStatementRbR void execStatementRbR(string sqlCommand, void delegate(immutable(Row)) answerRowProcessDg, ValueFormat resultFormat)
void execStatementRbR(QueryParams params, void delegate(immutable(Row)) answerRowProcessDg): Row-by-row version of execStatement
prepareStatement void prepareStatement(string statementName, string sqlStatement, Oid[] oids)
reset void reset(): Blocks while connection will be established or exception thrown
waitForNotify Notify waitForNotify(Duration timeout): Non blocking method to wait for next notification.

Variables

socketTimeout Duration socketTimeout;
statementTimeout Duration statementTimeout;

Meta

Source

See Implementation

vibe db postgresql modules

aliases

classes

functions

__integration_test

structs

ClientSettings