CODEWITHSUNDEEP
mysqldatabasego
Mark
Mark

Reputation: 932

Golang MySQL Database Not Selected

I'm using github.com/go-sql-driver/mysql package to connect to MySQL. It works well except when I select a database (USE), I can't run queries against it.

package main

import (
    "database/sql"
    "fmt"
    "log"
)

import _ "github.com/go-sql-driver/mysql"

func main() {
    dsn := "root:@/"
    db, err := sql.Open("mysql", dsn)
    if err != nil {
        fmt.Println("Failed to prepare connection to database. DSN:", dsn)
        log.Fatal("Error:", err.Error())
    }

    err = db.Ping()
    if err != nil {
        fmt.Println("Failed to establish connection to database. DSN:", dsn)
        log.Fatal("Error:", err.Error())
    }

    _, err = db.Query("USE test")
    if err != nil {
        fmt.Println("Failed to change database.")
        log.Fatal("Error:", err.Error())
    }

    _, err = db.Query("SHOW TABLES")
    if err != nil {
        fmt.Println("Failed to execute query.")
        log.Fatal("Error:", err.Error())
    }
}

The program produces this output:

Error 1046: No database selected

Upvotes: 3

Views: 14490

Answers (4)

seven
seven

Reputation: 2597

As other answers mentioned, sql.DB is not a single connection but a connection pool. When you execute use database, imagine you executed your query on just one connection in the pool. Next query will get another connection from the pool which has no databases selected.

I would strongly advise against using transactions for this (as several places suggest).

I would suggest to use context:

    ctx := context.Background()
    conn, err := db.Conn(ctx)
    conn.ExecContext(ctx, "use mydb")
    defer conn.Close()

    var found int
    err = conn.QueryRowContext(ctx, "SELECT count(*) as found FROM mytable").Scan(&found)
    if err != nil {
        panic(err)
    }

Upvotes: 1

kangsouth
kangsouth

Reputation: 73

That's because db maintains a connection pool that has several connections to mysql database."USE test" just let one connection use schema test. When you do database query later,the driver will select one idle connection,if the connection that use test schema is selected,it will be normal,but if another connection is chosen, it does not use test,so it will report an error:no database selected.

If you add a clause: 

db.SetMaxOpenConns(1)

the db will maintain only one connection,it will not have an error.And of course it's impossible in high concurrency scene.

If you specify the database name in sql.open() function,all the connection will use this data base which can avoid this problem.

Upvotes: 3

Zender Fufikoff
Zender Fufikoff

Reputation: 107

In your case you need to use transactions:

tx, _ := db.Begin()
tx.Query("USE test")
tx.Query("SHOW TABLES")
tx.Commit()

For SELECT/UPDATE/INSERT/etc need to specify DB name in the query.

Upvotes: 1

Jan Laussmann
Jan Laussmann

Reputation: 1520

Specify the database directly in the DSN (Data Source Name) part of the sql.Open function:

dsn := "user:password@/dbname"
db, err := sql.Open("mysql", dsn)

Upvotes: 10

Related Questions