Connection

Connection

Constructors

this
this(string connString)
Undocumented in source.
this
this(ConnectionStart , string connString)

Connect to DB in a nonblocking manner

Destructor

~this
~this()
Undocumented in source.

Members

Functions

cancel
void cancel()

If the cancellation is effective, the current command will terminate early and return an error result (exception). If the cancellation fails (say, because the server was already done processing the command), then there will be no visible result at all.

consumeInput
void consumeInput()
Undocumented in source. Be warned that the author may not have intended to support it.
createResultContainer
immutable(ResultContainer) createResultContainer(PGresult* r)

Get result from PQexec* functions or throw error if pull is empty

dbName
string dbName()
Undocumented in source. Be warned that the author may not have intended to support it.
errorMessage
string errorMessage()
Undocumented in source. Be warned that the author may not have intended to support it.
escapeIdentifier
string escapeIdentifier(string msg)
Undocumented in source. Be warned that the author may not have intended to support it.
escapeLiteral
string escapeLiteral(string msg)
Undocumented in source. Be warned that the author may not have intended to support it.
flush
bool flush()
Undocumented in source. Be warned that the author may not have intended to support it.
getResult
immutable(Result) getResult()

Get for the next result from a sendQuery. Can return null.

host
string host()
Undocumented in source. Be warned that the author may not have intended to support it.
isBusy
bool isBusy()
Undocumented in source. Be warned that the author may not have intended to support it.
isNonBlocking
bool isNonBlocking()
Undocumented in source. Be warned that the author may not have intended to support it.
parameterStatus
string parameterStatus(string paramName)
Undocumented in source. Be warned that the author may not have intended to support it.
poll
PostgresPollingStatusType poll()
Undocumented in source. Be warned that the author may not have intended to support it.
posixSocket
int posixSocket()
Undocumented in source. Be warned that the author may not have intended to support it.
posixSocketDuplicate
socket_t posixSocketDuplicate()
Undocumented in source. Be warned that the author may not have intended to support it.
protocolVersion
int protocolVersion()
Undocumented in source. Be warned that the author may not have intended to support it.
resetPoll
PostgresPollingStatusType resetPoll()
Undocumented in source. Be warned that the author may not have intended to support it.
resetStart
void resetStart()
Undocumented in source. Be warned that the author may not have intended to support it.
serverVersion
int serverVersion()
Undocumented in source. Be warned that the author may not have intended to support it.
setClientEncoding
void setClientEncoding(string encoding)
Undocumented in source. Be warned that the author may not have intended to support it.
setNoticeProcessor
PQnoticeProcessor setNoticeProcessor(PQnoticeProcessor proc, void* arg)

returns the previous notice receiver or processor function pointer, and sets the new value. If you supply a null function pointer, no action is taken, but the current pointer is returned.

setSingleRowMode
bool setSingleRowMode()
Undocumented in source. Be warned that the author may not have intended to support it.
socket
Socket socket()
Undocumented in source. Be warned that the author may not have intended to support it.
status
ConnStatusType status()
Undocumented in source. Be warned that the author may not have intended to support it.
trace
void trace(File stream)
Undocumented in source. Be warned that the author may not have intended to support it.
untrace
void untrace()
Undocumented in source. Be warned that the author may not have intended to support it.

Mixins

__anonymous
mixin Queries
Undocumented in source.

Variables

conn
PGconn* conn;
Undocumented in source.

Mixed In Members

From mixin Queries

exec
immutable(Answer) exec(string SQLcmd)

Perform SQL query to DB

execParams
immutable(Answer) execParams(QueryParams qp)

Perform SQL query to DB

sendQuery
void sendQuery(string SQLcmd)

Submits a command to the server without waiting for the result(s)

sendQueryParams
void sendQueryParams(QueryParams qp)

Submits a command and separate parameters to the server without waiting for the result(s)

sendQueryPrepared
void sendQueryPrepared(QueryParams qp)

Sends a request to execute a prepared statement with given parameters, without waiting for the result(s)

getNextNotify
Notify getNextNotify()

Returns null if no notifies was received

prepare
immutable(Result) prepare(string statementName, string sqlStatement, Oid[] oids)

Submits a request to create a prepared statement with the given parameters, and waits for completion.

execPrepared
immutable(Answer) execPrepared(QueryParams qp)

Submits a request to execute a prepared statement with given parameters, and waits for completion.

sendPrepare
void sendPrepare(string statementName, string sqlStatement, Oid[] oids)

Sends a request to create a prepared statement with the given parameters, without waiting for completion.

describePrepared
immutable(Answer) describePrepared(string statementName)
Undocumented in source. Be warned that the author may not have intended to support it.
sendDescribePrepared
void sendDescribePrepared(string statementName)
Undocumented in source. Be warned that the author may not have intended to support it.
waitEndOf
bool waitEndOf(WaitType type, Duration timeout)

Waiting for completion of reading or writing Return: timeout not occured

Meta