Connection

A class representing a database connection.

If you are using Vibe.d, consider using mysql.pool.MySQLPool instead of creating a new Connection directly. That will provide certain benefits, such as reusing old connections and automatic cleanup (no need to close the connection when done).

// Suggested usage:

{
	auto con = new Connection("host=localhost;port=3306;user=joe;pwd=pass123;db=myappsdb");
	scope(exit) con.close();

	// Use the connection
	...
}

class Connection {

enum OpenState;

OpenState _open;

MySQLSocket _socket;

SvrCapFlags _sCaps;

SvrCapFlags _cCaps;

uint _sThread;

ushort _serverStatus;

ubyte _sCharSet;

ubyte _protocol;

string _serverVersion;

string _host;

string _user;

ushort _port;

MySQLSocketType _socketType;

OpenSocketCallbackPhobos _openSocketPhobos;

OpenSocketCallbackVibeD _openSocketVibeD;

ulong _insertID;

ulong _lastCommandID;

bool _rowsPending;

bool _headersPending;

bool _binaryPending;

ushort _fieldCount;

ResultSetHeaders _rsh;

ubyte pktNumber [@property getter];

void bumpPacket();

void resetPacket();

ubyte[] getPacket();

void send(const(ubyte)[] packet);

void send(const(ubyte)[] header, const(ubyte)[] data);

void sendCmd(CommandType cmd, const(T)[] data);

OKErrorPacket getCmdResponse(bool asString);

ubyte[] buildAuthPacket(ubyte[] token);

void consumeServerInfo(ubyte[] packet);

ubyte[] parseGreeting();

static PlainPhobosSocket defaultOpenSocketPhobos(string host, ushort port);

static PlainVibeDSocket defaultOpenSocketVibeD(string host, ushort port);

void initConnection();

ubyte[] makeToken(ubyte[] authBuf);

SvrCapFlags getCommonCapabilities(SvrCapFlags server, SvrCapFlags client);

void setClientFlags(SvrCapFlags capFlags);

void authenticate(ubyte[] greeting);

SvrCapFlags _clientCapabilities;

void connect(SvrCapFlags clientCapabilities);

void autoPurge();

struct StatementsToRelease(alias doRelease);

StatementsToRelease!(PreparedImpl.immediateRelease) statementsToRelease;

debug(MYSQL_INTEGRATION_TESTS)

uint[] fakeRelease_released;

this(string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags);

this(MySQLSocketType socketType, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags);

this(OpenSocketCallbackPhobos openSocket, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags);

this(OpenSocketCallbackVibeD openSocket, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags);

this(string cs, SvrCapFlags capFlags);

this(MySQLSocketType socketType, string cs, SvrCapFlags capFlags);

this(OpenSocketCallbackPhobos openSocket, string cs, SvrCapFlags capFlags);

this(OpenSocketCallbackVibeD openSocket, string cs, SvrCapFlags capFlags);

bool closed [@property getter];

version(Have_vibe_d_core)

void acquire();

version(Have_vibe_d_core)

void release();

version(Have_vibe_d_core)

bool isOwner();

version(Have_vibe_d_core)

bool amOwner();

version(!Have_vibe_d_core)

void acquire();

version(!Have_vibe_d_core)

void release();

version(!Have_vibe_d_core)

bool isOwner();

version(!Have_vibe_d_core)

bool amOwner();

void close();

void reconnect();

void reconnect(SvrCapFlags clientCapabilities);

static string[] parseConnectionString(string cs);

void selectDB(string dbName);

OKErrorPacket pingServer();

OKErrorPacket refreshServer(RefreshFlags flags);

Row getNextRow();

ulong purgeResult();

string serverStats();

void enableMultiStatements(bool on);

ubyte protocol [@property getter];

string serverVersion [@property getter];

uint serverCapabilities [@property getter];

ushort serverStatus [@property getter];

ubyte charSet [@property getter];

string currentDB [@property getter];

MySQLSocketType socketType [@property getter];

ulong lastInsertID [@property getter];

ulong lastCommandID [@property getter];

bool rowsPending [@property getter];

bool hasPending [@property getter];

FieldDescription[] resultFieldDescriptions [@property getter];

}

Constructors

this this(string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags)
this(MySQLSocketType socketType, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags)
this(OpenSocketCallbackPhobos openSocket, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags)
this(OpenSocketCallbackVibeD openSocket, string host, string user, string pwd, string db, ushort port, SvrCapFlags capFlags)
this(string cs, SvrCapFlags capFlags)
this(MySQLSocketType socketType, string cs, SvrCapFlags capFlags)
this(OpenSocketCallbackPhobos openSocket, string cs, SvrCapFlags capFlags)
this(OpenSocketCallbackVibeD openSocket, string cs, SvrCapFlags capFlags): Construct opened connection.

Members

Enums

OpenState enum OpenState: Undocumented in source.

Functions

acquire void acquire(): Used by Vibe.d's ConnectionPool, ignore this.
acquire void acquire()
amOwner bool amOwner(): Used by Vibe.d's ConnectionPool, ignore this.
authenticate void authenticate(ubyte[] greeting): Undocumented in source.
autoPurge void autoPurge(): Called whenever mysql-native needs to send a command to the server and be sure there aren't any pending results (which would prevent a new command from being sent).
buildAuthPacket ubyte[] buildAuthPacket(ubyte[] token): Undocumented in source.
bumpPacket void bumpPacket(): Undocumented in source. Be warned that the author may not have intended to support it.
close void close(): Explicitly close the connection.
connect void connect(SvrCapFlags clientCapabilities): Undocumented in source.
consumeServerInfo void consumeServerInfo(ubyte[] packet): Undocumented in source. Be warned that the author may not have intended to support it.
enableMultiStatements void enableMultiStatements(bool on): Enable multiple statement commands
getCmdResponse OKErrorPacket getCmdResponse(bool asString): Undocumented in source. Be warned that the author may not have intended to support it.
getCommonCapabilities SvrCapFlags getCommonCapabilities(SvrCapFlags server, SvrCapFlags client): Undocumented in source. Be warned that the author may not have intended to support it.
getNextRow Row getNextRow(): Get the next Row of a pending result set.
getPacket ubyte[] getPacket(): Undocumented in source. Be warned that the author may not have intended to support it.
initConnection void initConnection(): Undocumented in source. Be warned that the author may not have intended to support it.
isOwner bool isOwner(): Used by Vibe.d's ConnectionPool, ignore this.
kill void kill(): Forcefully close the socket without sending the quit command. Needed in case an error leaves communatations in an undefined or non-recoverable state.
makeToken ubyte[] makeToken(ubyte[] authBuf): Undocumented in source. Be warned that the author may not have intended to support it.
parseGreeting ubyte[] parseGreeting(): Undocumented in source. Be warned that the author may not have intended to support it.
pingServer OKErrorPacket pingServer(): Check the server status
purgeResult ulong purgeResult(): Flush any outstanding result set elements.
reconnect void reconnect()
void reconnect(SvrCapFlags clientCapabilities): Reconnects to the server using the same connection settings originally used to create the Connection.
refreshServer OKErrorPacket refreshServer(RefreshFlags flags): Refresh some feature(s) of the server.
release void release(): Used by Vibe.d's ConnectionPool, ignore this.
resetPacket void resetPacket(): Undocumented in source. Be warned that the author may not have intended to support it.
selectDB void selectDB(string dbName): Select a current database.
send void send(const(ubyte)[] packet): Undocumented in source.
send void send(const(ubyte)[] header, const(ubyte)[] data): Undocumented in source.
sendCmd void sendCmd(CommandType cmd, const(T)[] data): Undocumented in source.
serverStats string serverStats(): Get a textual report on the server status.
setClientFlags void setClientFlags(SvrCapFlags capFlags): Undocumented in source. Be warned that the author may not have intended to support it.

Properties

charSet ubyte charSet [@property getter]: Current character set
closed bool closed [@property getter]: Check whether this Connection is still connected to the server, or if the connection has been closed.
currentDB string currentDB [@property getter]: Current database
hasPending bool hasPending [@property getter]: Gets whether anything (rows, headers or binary) is pending. New commands cannot be sent on a conncection while anything is pending.
lastCommandID ulong lastCommandID [@property getter]: This gets incremented every time a command is issued or results are purged, so a ResultRange can tell whether it's been invalidated.
lastInsertID ulong lastInsertID [@property getter]: After a command that inserted a row into a table with an auto-increment ID column, this method allows you to retrieve the last insert ID.
pktNumber ubyte pktNumber [@property getter]: ordering. First packet should have 0
protocol ubyte protocol [@property getter]: Return the in-force protocol number
resultFieldDescriptions FieldDescription[] resultFieldDescriptions [@property getter]: Gets the result header's field descriptions.
rowsPending bool rowsPending [@property getter]: Gets whether rows are pending
serverCapabilities uint serverCapabilities [@property getter]: Server capability flags
serverStatus ushort serverStatus [@property getter]: Server status
serverVersion string serverVersion [@property getter]: Server version
socketType MySQLSocketType socketType [@property getter]: Socket type being used

Static functions

defaultOpenSocketPhobos PlainPhobosSocket defaultOpenSocketPhobos(string host, ushort port): Undocumented in source. Be warned that the author may not have intended to support it.
defaultOpenSocketVibeD PlainVibeDSocket defaultOpenSocketVibeD(string host, ushort port): Undocumented in source. Be warned that the author may not have intended to support it.
parseConnectionString string[] parseConnectionString(string cs): Parses a connection string of the form "host=localhost;port=3306;user=joe;pwd=pass123;db=myappsdb"

Structs

StatementsToRelease struct StatementsToRelease(alias doRelease): Keeps track of prepared statements queued to be released from the server.

Variables

_binaryPending bool _binaryPending;
_cCaps SvrCapFlags _cCaps;: Undocumented in source.
_clientCapabilities SvrCapFlags _clientCapabilities;: Undocumented in source.
_cpn ubyte _cpn;: Packet Number in packet header. Serial number to ensure correct
_db string _db;: Undocumented in source.
_fieldCount ushort _fieldCount;
_headersPending bool _headersPending;: Undocumented in source.
_host string _host;: Undocumented in source.
_insertID ulong _insertID;: Undocumented in source.
_lastCommandID ulong _lastCommandID;: Undocumented in source.
_open OpenState _open;: Undocumented in source.
_openSocketPhobos OpenSocketCallbackPhobos _openSocketPhobos;: Undocumented in source.
_openSocketVibeD OpenSocketCallbackVibeD _openSocketVibeD;: Undocumented in source.
_port ushort _port;
_protocol ubyte _protocol;
_pwd string _pwd;: Undocumented in source.
_rowsPending bool _rowsPending;: Undocumented in source.
_rsh ResultSetHeaders _rsh;: Undocumented in source.
_sCaps SvrCapFlags _sCaps;: Undocumented in source.
_sCharSet ubyte _sCharSet;: Undocumented in source.
_sThread uint _sThread;: Undocumented in source.
_serverStatus ushort _serverStatus;: Undocumented in source.
_serverVersion string _serverVersion;: Undocumented in source.
_socket MySQLSocket _socket;: Undocumented in source.
_socketType MySQLSocketType _socketType;
_user string _user;: Undocumented in source.
fakeRelease_released uint[] fakeRelease_released;: Undocumented in source.
statementsToRelease StatementsToRelease!(PreparedImpl.immediateRelease) statementsToRelease;: Undocumented in source.

Meta

Source

See Implementation

mysql connection classes

Connection

variables

defaultClientFlags