package mysql
Import Path
github.com/go-sql-driver/mysql (on go.dev)
Dependency Relation
imports 30 packages, and imported by one package
Involved Source Files
atomic_bool.go
auth.go
buffer.go
collations.go
conncheck.go
connection.go
connector.go
const.go
Package mysql provides a MySQL driver for Go's database/sql package.
The driver should be used via the database/sql package:
import "database/sql"
import _ "github.com/go-sql-driver/mysql"
db, err := sql.Open("mysql", "user:password@/dbname")
See https://github.com/go-sql-driver/mysql#usage for details
dsn.go
errors.go
fields.go
infile.go
nulltime.go
packets.go
result.go
rows.go
statement.go
transaction.go
utils.go
Package-Level Type Names (total 7)
Config is a configuration parsed from a DSN string.
If a new Config is created instead of being parsed from a DSN string,
the NewConfig function should be used, which sets default values.
// Network address (requires Net)
// Allow all files to be used with LOAD DATA LOCAL INFILE
// Allows the cleartext client side plugin
// Allows fallback to unencrypted connection if server does not support TLS
// Allows the native password authentication method
// Allows the old insecure password method
// Check connections for liveness before using them
// Return number of matching rows instead of rows changed
// Connection collation
// Prepend table alias to column names
// Database name
// Interpolate placeholders into query string
// Location for time.Time values
// Max packet size allowed
// Allow multiple statements in one query
// Network type
// Connection parameters
// Parse time values to time.Time
// Password (requires User)
// I/O read timeout
// Reject read-only connections
// Server public key name
// TLS configuration, its priority is higher than TLSConfig
// TLS configuration name
// Dial timeout
// Username
// I/O write timeout
(*Config) Clone() *Config
FormatDSN formats the given Config into a DSN string which can be passed to
the driver.
func NewConfig() *Config
func ParseDSN(dsn string) (cfg *Config, err error)
func (*Config).Clone() *Config
func NewConnector(cfg *Config) (driver.Connector, error)
DialContextFunc is a function which can be used to establish the network connection.
Custom dial functions must be registered with RegisterDialContext
func RegisterDialContext(net string, dial DialContextFunc)
DialFunc is a function which can be used to establish the network connection.
Custom dial functions must be registered with RegisterDial
Deprecated: users should register a DialContextFunc instead
func RegisterDial(network string, dial DialFunc)
Logger is used to log critical error messages.
( Logger) Print(v ...interface{})
*log.Logger
func SetLogger(logger Logger) error
MySQLDriver is exported to make the driver directly accessible.
In general the driver is used via the database/sql package.
Open new Connection.
See https://github.com/go-sql-driver/mysql#dsn-data-source-name for how
the DSN string is formatted
OpenConnector implements driver.DriverContext.
MySQLDriver : database/sql/driver.Driver
MySQLDriver : database/sql/driver.DriverContext
MySQLError is an error type which represents a single MySQL error
Message string
Number uint16
SQLState [5]byte
(*MySQLError) Error() string
(*MySQLError) Is(err error) bool
*MySQLError : error
NullTime represents a time.Time that may be NULL.
NullTime implements the Scanner interface so
it can be used as a scan destination:
var nt NullTime
err := db.QueryRow("SELECT time FROM foo WHERE id=?", id).Scan(&nt)
...
if nt.Valid {
// use nt.Time
} else {
// NULL value
}
# This NullTime implementation is not driver-specific
Deprecated: NullTime doesn't honor the loc DSN parameter.
NullTime.Scan interprets a time as UTC, not the loc DSN parameter.
Use sql.NullTime instead.
Time time.Time
// Valid is true if Time is not NULL
Scan implements the Scanner interface.
The value type must be time.Time or string / []byte (formatted time-string),
otherwise Scan fails.
Value implements the driver Valuer interface.
*NullTime : database/sql.Scanner
NullTime : database/sql/driver.Valuer
Package-Level Functions (total 14)
DeregisterLocalFile removes the given filepath from the allowlist.
DeregisterReaderHandler removes the ReaderHandler function with
the given name from the registry.
DeregisterServerPubKey removes the public key registered with the given name.
DeregisterTLSConfig removes the tls.Config associated with key.
NewConfig creates a new Config and sets default values.
NewConnector returns new driver.Connector.
ParseDSN parses the DSN string to a Config
RegisterDial registers a custom dial function. It can then be used by the
network address mynet(addr), where mynet is the registered new network.
addr is passed as a parameter to the dial function.
Deprecated: users should call RegisterDialContext instead
RegisterDialContext registers a custom dial function. It can then be used by the
network address mynet(addr), where mynet is the registered new network.
The current context for the connection and its address is passed to the dial function.
RegisterLocalFile adds the given file to the file allowlist,
so that it can be used by "LOAD DATA LOCAL INFILE <filepath>".
Alternatively you can allow the use of all local files with
the DSN parameter 'allowAllFiles=true'
filePath := "/home/gopher/data.csv"
mysql.RegisterLocalFile(filePath)
err := db.Exec("LOAD DATA LOCAL INFILE '" + filePath + "' INTO TABLE foo")
if err != nil {
...
RegisterReaderHandler registers a handler function which is used
to receive a io.Reader.
The Reader can be used by "LOAD DATA LOCAL INFILE Reader::<name>".
If the handler returns a io.ReadCloser Close() is called when the
request is finished.
mysql.RegisterReaderHandler("data", func() io.Reader {
var csvReader io.Reader // Some Reader that returns CSV data
... // Open Reader here
return csvReader
})
err := db.Exec("LOAD DATA LOCAL INFILE 'Reader::data' INTO TABLE foo")
if err != nil {
...
RegisterServerPubKey registers a server RSA public key which can be used to
send data in a secure manner to the server without receiving the public key
in a potentially insecure way from the server first.
Registered keys can afterwards be used adding serverPubKey=<name> to the DSN.
Note: The provided rsa.PublicKey instance is exclusively owned by the driver
after registering it and may not be modified.
data, err := ioutil.ReadFile("mykey.pem")
if err != nil {
log.Fatal(err)
}
block, _ := pem.Decode(data)
if block == nil || block.Type != "PUBLIC KEY" {
log.Fatal("failed to decode PEM block containing public key")
}
pub, err := x509.ParsePKIXPublicKey(block.Bytes)
if err != nil {
log.Fatal(err)
}
if rsaPubKey, ok := pub.(*rsa.PublicKey); ok {
mysql.RegisterServerPubKey("mykey", rsaPubKey)
} else {
log.Fatal("not a RSA public key")
}
RegisterTLSConfig registers a custom tls.Config to be used with sql.Open.
Use the key as a value in the DSN where tls=value.
Note: The provided tls.Config is exclusively owned by the driver after
registering it.
rootCertPool := x509.NewCertPool()
pem, err := ioutil.ReadFile("/path/ca-cert.pem")
if err != nil {
log.Fatal(err)
}
if ok := rootCertPool.AppendCertsFromPEM(pem); !ok {
log.Fatal("Failed to append PEM.")
}
clientCert := make([]tls.Certificate, 0, 1)
certs, err := tls.LoadX509KeyPair("/path/client-cert.pem", "/path/client-key.pem")
if err != nil {
log.Fatal(err)
}
clientCert = append(clientCert, certs)
mysql.RegisterTLSConfig("custom", &tls.Config{
RootCAs: rootCertPool,
Certificates: clientCert,
})
db, err := sql.Open("mysql", "user@tcp(localhost:3306)/test?tls=custom")
SetLogger is used to set the logger for critical errors.
The initial logger is os.Stderr.
Package-Level Variables (total 12)
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
Various errors the driver might return. Can change between driver versions.
![]() |
The pages are generated with Golds v0.6.7. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |