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);

Row getNextRow();

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();

void releaseQueued();

Nullable!PreparedServerInfo getPreparedServerInfo(string sql);

PreparedServerInfo registerIfNeeded(string sql);

PreparedServerInfo performRegister(string sql);

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];

void close();

void reconnect();

void reconnect(SvrCapFlags clientCapabilities);

static string[] parseConnectionString(string cs);

void selectDB(string dbName);

OKErrorPacket pingServer();

OKErrorPacket refreshServer(RefreshFlags flags);

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];

void register(Prepared prepared);

void register(string sql);

void release(Prepared prepared);

void release(string sql);

void releaseAll();

bool isRegistered(Prepared prepared);

bool isRegistered(string sql);

bool isRegistered(Nullable!PreparedServerInfo info);

}

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

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 mysql.result.Row of a pending result set.
getPacket ubyte[] getPacket(): Undocumented in source. Be warned that the author may not have intended to support it.
getPreparedServerInfo Nullable!PreparedServerInfo getPreparedServerInfo(string sql): Returns null if not found
initConnection void initConnection(): Undocumented in source. Be warned that the author may not have intended to support it.
isRegistered bool isRegistered(Prepared prepared)
bool isRegistered(string sql)
bool isRegistered(Nullable!PreparedServerInfo info): Is the given statement registered on this connection as a prepared statement?
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.
performRegister PreparedServerInfo performRegister(string sql): 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.
register void register(Prepared prepared)
void register(string sql): Manually register a prepared statement on this connection.
registerIfNeeded PreparedServerInfo registerIfNeeded(string sql): If already registered, simply returns the cached PreparedServerInfo.
release void release(Prepared prepared)
void release(string sql): Manually release a prepared statement on this connection.
releaseAll void releaseAll(): Manually release all prepared statements on this connection.
releaseQueued void releaseQueued(): Releases all prepared statements that are queued for release.
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 connection while anything is pending (the pending data will automatically be purged.)
lastCommandID ulong lastCommandID [@property getter]: This gets incremented every time a command is issued or results are purged, so a mysql.result.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, Phobos or Vibe.d

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"

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.

Meta

Source

See Implementation

mysql connection aliases

RCPrepared

classes

Connection

functions

structs

variables

defaultClientFlags