Method Open

backend/plugin/db/mysql/mysql.go:79–113

Open opens a MySQL driver.

(ctx context.Context, dbType storepb.Engine, connCfg db.ConnectionConfig)

// Open opens a MySQL driver.
func (d *Driver) Open(ctx context.Context, dbType storepb.Engine, connCfg db.ConnectionConfig) (db.Driver, error) {
	defer func() {
		for _, f := range d.openCleanUp {
			f()
		}
	}()

	var dsn string
	var err error
	switch connCfg.DataSource.GetAuthenticationType() {
	case storepb.DataSource_GOOGLE_CLOUD_SQL_IAM:
		dsn, err = getCloudSQLConnection(ctx, connCfg)
	case storepb.DataSource_AWS_RDS_IAM:
		dsn, err = d.getRDSConnection(ctx, connCfg)
	default:
		dsn, err = d.getMySQLConnection(connCfg)
	}
	if err != nil {
		return nil, err
	}

	db, err := sql.Open("mysql", dsn)
	if err != nil {
		return nil, err
	}
	d.dbType = dbType
	d.db = db
	// TODO(d): remove the work-around once we have clean-up the migration connection hack.
	db.SetConnMaxLifetime(2 * time.Hour)
	db.SetMaxOpenConns(50)
	db.SetMaxIdleConns(15)
	d.databaseName = connCfg.ConnectionContext.DatabaseName

	return d, nil
}

func (d *Driver) getMySQLConnection(connCfg db.ConnectionConfig) (string, error) {
	protocol := "tcp"