Database di Azure per PostgreSQL: usare il linguaggio Go per connettersi ai dati ed eseguire queryAzure Database for PostgreSQL: Use Go language to connect and query data

Questa guida introduttiva illustra come connettersi a un database di Azure per PostgreSQL usando il codice scritto nel linguaggio Go (golang).This quickstart demonstrates how to connect to an Azure Database for PostgreSQL using code written in the Go language (golang). Spiega come usare le istruzioni SQL per eseguire query, inserire, aggiornare ed eliminare dati nel database.It shows how to use SQL statements to query, insert, update, and delete data in the database. Questo articolo presuppone che si abbia familiarità con lo sviluppo con Go, ma non con Database di Azure per PostgreSQL.This article assumes you are familiar with development using Go, but that you are new to working with Azure Database for PostgreSQL.

PrerequisitiPrerequisites

Questa guida introduttiva usa le risorse create in una delle guide seguenti come punto di partenza:This quickstart uses the resources created in either of these guides as a starting point:

Installare Go e il connettore pqInstall Go and pq connector

Installare Go e il driver Pure Go per Postgres (pq) nel computer.Install Go and the Pure Go Postgres driver (pq) on your own machine. A seconda della piattaforma, seguire le istruzioni appropriate:Depending on your platform, follow the appropriate steps:

WindowsWindows

  1. Scaricare e installare Go per Microsoft Windows seguendo le istruzioni di installazione.Download and install Go for Microsoft Windows according to the installation instructions.
  2. Avviare il prompt dei comandi dal menu Start.Launch the command prompt from the start menu.
  3. Creare una cartella per il progetto, ad esempio mkdir %USERPROFILE%\go\src\postgresqlgo.Make a folder for your project, such as mkdir %USERPROFILE%\go\src\postgresqlgo.
  4. Passare alla cartella del progetto, ad esempio cd %USERPROFILE%\go\src\postgresqlgo.Change directory into the project folder, such as cd %USERPROFILE%\go\src\postgresqlgo.
  5. Impostare la variabile di ambiente per GOPATH in modo che punti alla directory del codice sorgente.Set the environment variable for GOPATH to point to the source code directory. set GOPATH=%USERPROFILE%\go.set GOPATH=%USERPROFILE%\go.
  6. Installare il driver Pure Go per Postgres (pq) eseguendo il comando go get github.com/lib/pq.Install the Pure Go Postgres driver (pq) by running the go get github.com/lib/pq command.

    In sintesi, installare Go e quindi eseguire questi comandi nel prompt dei comandi:In summary, install Go, then run these commands in the command prompt:

    mkdir  %USERPROFILE%\go\src\postgresqlgo
    cd %USERPROFILE%\go\src\postgresqlgo
    set GOPATH=%USERPROFILE%\go
    go get github.com/lib/pq
    

Linux (Ubuntu)Linux (Ubuntu)

  1. Avviare la shell Bash.Launch the Bash shell.
  2. Installare Go eseguendo sudo apt-get install golang-go.Install Go by running sudo apt-get install golang-go.
  3. Creare una cartella per il progetto nella home directory, ad esempio mkdir -p ~/go/src/postgresqlgo/.Make a folder for your project in your home directory, such as mkdir -p ~/go/src/postgresqlgo/.
  4. Passare alla cartella, ad esempio cd ~/go/src/postgresqlgo/.Change directory into the folder, such as cd ~/go/src/postgresqlgo/.
  5. Impostare la variabile di ambiente GOPATH in modo che punti a una directory di origine valida, ad esempio la cartella go della home directory corrente.Set the GOPATH environment variable to point to a valid source directory, such as your current home directory's go folder. Nella shell Bash eseguire export GOPATH=~/go per aggiungere la directory go come GOPATH per la sessione shell corrente.At the bash shell, run export GOPATH=~/go to add the go directory as the GOPATH for the current shell session.
  6. Installare il driver Pure Go per Postgres (pq) eseguendo il comando go get github.com/lib/pq.Install the Pure Go Postgres driver (pq) by running the go get github.com/lib/pq command.

    In sintesi, eseguire questi comandi Bash:In summary, run these bash commands:

    sudo apt-get install golang-go
    mkdir -p ~/go/src/postgresqlgo/
    cd ~/go/src/postgresqlgo/
    export GOPATH=~/go/
    go get github.com/lib/pq
    

Apple macOSApple macOS

  1. Scaricare e installare Go seguendo le istruzioni di installazione per la piattaforma in uso.Download and install Go according to the installation instructions matching your platform.
  2. Avviare la shell Bash.Launch the Bash shell.
  3. Creare una cartella per il progetto nella home directory, ad esempio mkdir -p ~/go/src/postgresqlgo/.Make a folder for your project in your home directory, such as mkdir -p ~/go/src/postgresqlgo/.
  4. Passare alla cartella, ad esempio cd ~/go/src/postgresqlgo/.Change directory into the folder, such as cd ~/go/src/postgresqlgo/.
  5. Impostare la variabile di ambiente GOPATH in modo che punti a una directory di origine valida, ad esempio la cartella go della home directory corrente.Set the GOPATH environment variable to point to a valid source directory, such as your current home directory's go folder. Nella shell Bash eseguire export GOPATH=~/go per aggiungere la directory go come GOPATH per la sessione shell corrente.At the bash shell, run export GOPATH=~/go to add the go directory as the GOPATH for the current shell session.
  6. Installare il driver Pure Go per Postgres (pq) eseguendo il comando go get github.com/lib/pq.Install the Pure Go Postgres driver (pq) by running the go get github.com/lib/pq command.

    In sintesi, installare Go e quindi eseguire questi comandi Bash:In summary, install Go, then run these bash commands:

    mkdir -p ~/go/src/postgresqlgo/
    cd ~/go/src/postgresqlgo/
    export GOPATH=~/go/
    go get github.com/lib/pq
    

Ottenere informazioni di connessioneGet connection information

Ottenere le informazioni di connessione necessarie per connettersi al database di Azure per PostgreSQL.Get the connection information needed to connect to the Azure Database for PostgreSQL. Sono necessari il nome del server completo e le credenziali di accesso.You need the fully qualified server name and login credentials.

  1. Accedere al Portale di Azure.Log in to the Azure portal.
  2. Nel menu a sinistra nel portale di Azure fare clic su Tutte le risorse e cercare il server creato, ad esempio mypgserver-20170401.From the left-hand menu in Azure portal, click All resources and search for the server you have created, such as mypgserver-20170401.
  3. Fare clic sul nome del server mypgserver-20170401.Click the server name mypgserver-20170401.
  4. Selezionare la pagina Panoramica del server.Select the server's Overview page. Annotare il Nome server e il nome di accesso dell'amministratore del server.Make a note of the Server name and Server admin login name. Database di Azure per PostgreSQL - Accesso dell'amministratore del serverAzure Database for PostgreSQL - Server Admin Login
  5. Se si dimenticano le informazioni di accesso per il server, passare alla pagina Panoramica e visualizzare il nome di accesso dell'amministratore del server.If you forget your server login information, navigate to the Overview page, and view the Server admin login name. Se necessario, reimpostare la password.If necessary, reset the password.

Compilare ed eseguire il codice GoBuild and run Go code

  1. Per scrivere codice Golang, è possibile usare un editor di testo normale, ad esempio Blocco note di Microsoft Windows, vi o Nano in Ubuntu oppure TextEdit in macOS.To write Golang code, you can use a plain text editor, such as Notepad in Microsoft Windows, vi or Nano in Ubuntu, or TextEdit in macOS. Se si preferisce un ambiente IDE (Interactive Development Environment) avanzato, provare Gogland di Jetbrains, Visual Studio Code di Microsoft o Atom.If you prefer a richer Interactive Development Environment (IDE) try Gogland by Jetbrains, Visual Studio Code by Microsoft, or Atom.
  2. Incollare nel file di testo il codice Golang riportato nelle sezioni seguenti e quindi salvare il file nella cartella del progetto con l'estensione *.go, ad esempio il percorso di Windows %USERPROFILE%\go\src\postgresqlgo\createtable.go o il percorso di Linux ~/go/src/postgresqlgo/createtable.go.Paste the Golang code from the following sections into text files, and save into your project folder with file extension *.go, such as Windows path %USERPROFILE%\go\src\postgresqlgo\createtable.go or Linux path ~/go/src/postgresqlgo/createtable.go.
  3. Trovare le costanti HOST, DATABASE, USER e PASSWORD nel codice e sostituire i valori di esempio con i propri valori.Locate the HOST, DATABASE, USER, and PASSWORD constants in the code, and replace the example values with your own values.
  4. Avviare il prompt dei comandi o la shell Bash.Launch the command prompt or bash shell. Passare alla cartella del progetto,Change directory into your project folder. ad esempio cd %USERPROFILE%\go\src\postgresqlgo\ in Windows.For example, on Windows cd %USERPROFILE%\go\src\postgresqlgo\. In Linux cd ~/go/src/postgresqlgo/.On Linux cd ~/go/src/postgresqlgo/. Alcuni degli ambienti IDE indicati offrono funzionalità di debug e di runtime che non richiedono comandi della shell.Some of the IDE environments mentioned offer debug and runtime capabilities without requiring shell commands.
  5. Eseguire il codice digitando il comando go run createtable.go per compilare l'applicazione ed eseguirla.Run the code by typing the command go run createtable.go to compile the application and run it.
  6. In alternativa, per compilare il codice in un'applicazione nativa, digitare go build createtable.go e quindi avviare createtable.exe per eseguire l'applicazione.Alternatively, to build the code into a native application, go build createtable.go, then launch createtable.exe to run the application.

Connettersi e creare una tabellaConnect and create a table

Usare il codice seguente per connettersi e creare una tabella usando l'istruzione SQL CREATE TABLE, seguita dalle istruzioni SQL INSERT INTO per aggiungere righe nella tabella.Use the following code to connect and create a table using CREATE TABLE SQL statement, followed by INSERT INTO SQL statements to add rows into the table.

Il codice importa tre pacchetti: il pacchetto sql, il pacchetto pq come driver per comunicare con il server PostgreSQL e il pacchetto fmt per l'input e l'output stampati nella riga di comando.The code imports three packages: the sql package, the pq package as a driver to communicate with the PostgreSQL server, and the fmt package for printed input and output on the command line.

Il codice chiama il metodo sql.Open() per la connessione a Database di Azure per il database PostgreSQL e controlla la connessione usando il metodo db.Ping().The code calls method sql.Open() to connect to Azure Database for PostgreSQL database, and checks the connection using method db.Ping(). Viene usato un handle di database, contenente il pool di connessioni per il server di database.A database handle is used throughout, holding the connection pool for the database server. Il codice chiama il metodo Exec() più volte per eseguire diversi comandi SQL.The code calls the Exec() method several times to run several SQL commands. Ogni volta un metodo checkError() personalizzato controlla se si è verificato un errore e un metodo panic esce se si verifica un errore.Each time a custom checkError() method checks if an error occurred and panic to exit if an error does occur.

Sostituire i parametri HOST, DATABASE, USER e PASSWORD con valori personalizzati.Replace the HOST, DATABASE, USER, and PASSWORD parameters with your own values.

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/lib/pq"
)

const (
    // Initialize connection constants.
    HOST     = "mypgserver-20170401.postgres.database.azure.com"
    DATABASE = "mypgsqldb"
    USER     = "mylogin@mypgserver-20170401"
    PASSWORD = "<server_admin_password>"
)

func checkError(err error) {
    if err != nil {
        panic(err)
    }
}

func main() {
    // Initialize connection string.
    var connectionString string = fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

    // Initialize connection object.
    db, err := sql.Open("postgres", connectionString)
    checkError(err)

    err = db.Ping()
    checkError(err)
    fmt.Println("Successfully created connection to database")

    // Drop previous table of same name if one exists.
    _, err = db.Exec("DROP TABLE IF EXISTS inventory;")
    checkError(err)
    fmt.Println("Finished dropping table (if existed)")

    // Create table.
    _, err = db.Exec("CREATE TABLE inventory (id serial PRIMARY KEY, name VARCHAR(50), quantity INTEGER);")
    checkError(err)
    fmt.Println("Finished creating table")

    // Insert some data into table.
    sql_statement := "INSERT INTO inventory (name, quantity) VALUES ($1, $2);"
    _, err = db.Exec(sql_statement, "banana", 150)
    checkError(err)
    _, err = db.Exec(sql_statement, "orange", 154)
    checkError(err)
    _, err = db.Exec(sql_statement, "apple", 100)
    checkError(err)
    fmt.Println("Inserted 3 rows of data")
}

Leggere i datiRead data

Usare il codice seguente per connettersi e leggere i dati usando un'istruzione SQL SELECT.Use the following code to connect and read the data using a SELECT SQL statement.

Il codice importa tre pacchetti: il pacchetto sql, il pacchetto pq come driver per comunicare con il server PostgreSQL e il pacchetto fmt per l'input e l'output stampati nella riga di comando.The code imports three packages: the sql package, the pq package as a driver to communicate with the PostgreSQL server, and the fmt package for printed input and output on the command line.

Il codice chiama il metodo sql.Open() per la connessione a Database di Azure per il database PostgreSQL e controlla la connessione usando il metodo db.Ping().The code calls method sql.Open() to connect to Azure Database for PostgreSQL database, and checks the connection using method db.Ping(). Viene usato un handle di database, contenente il pool di connessioni per il server di database.A database handle is used throughout, holding the connection pool for the database server. La query di selezione viene eseguita chiamando il metodo db.Query() e le righe risultanti vengono mantenute in una variabile di tipo rows.The select query is run by calling method db.Query(), and the resulting rows are kept in a variable of type rows. Il codice legge i valori dei dati delle colonne nella riga corrente usando il metodo rows.Scan() ed esegue il ciclo sulle righe usando l'iteratore rows.Next() fino ad esaurimento delle righe.The code reads the column data values in the current row using method rows.Scan() and loops over the rows using the iterator rows.Next() until no more rows exist. I valori delle colonne di ogni riga vengono trasmessi alla console. Ogni volta viene usato un metodo checkError() personalizzato per controllare se si è verificato un errore e il metodo panic per uscire se si verifica un errore.Each row's column values are printed to the console out. Each time a custom checkError() method is used to check if an error occurred and panic to exit if an error does occur.

Sostituire i parametri HOST, DATABASE, USER e PASSWORD con valori personalizzati.Replace the HOST, DATABASE, USER, and PASSWORD parameters with your own values.

package main

import (
    "database/sql"
    "fmt"
    _ "github.com/lib/pq"
)

const (
    // Initialize connection constants.
    HOST     = "mypgserver-20170401.postgres.database.azure.com"
    DATABASE = "mypgsqldb"
    USER     = "mylogin@mypgserver-20170401"
    PASSWORD = "<server_admin_password>"
)

func checkError(err error) {
    if err != nil {
        panic(err)
    }
}

func main() {

    // Initialize connection string.
    var connectionString string = fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

    // Initialize connection object.
    db, err := sql.Open("postgres", connectionString)
    checkError(err)

    err = db.Ping()
    checkError(err)
    fmt.Println("Successfully created connection to database")

    // Read rows from table.
    var id int
    var name string
    var quantity int

    sql_statement := "SELECT * from inventory;"
    rows, err := db.Query(sql_statement)
    checkError(err)

    for rows.Next() {
        switch err := rows.Scan(&id, &name, &quantity); err {
        case sql.ErrNoRows:
            fmt.Println("No rows were returned")
        case nil:
            fmt.Printf("Data row = (%d, %s, %d)\n", id, name, quantity)
        default:
            checkError(err)
        }
    }
}

Aggiornare i datiUpdate data

Usare il codice seguente per connettersi e aggiornare i dati usando un'istruzione SQL UPDATE.Use the following code to connect and update the data using an UPDATE SQL statement.

Il codice importa tre pacchetti: il pacchetto sql, il pacchetto pq, come driver per comunicare con il server Postgres, e il pacchetto fmt per l'input e l'output stampati nella riga di comando.The code imports three packages: the sql package, the pq package as a driver to communicate with the Postgres server, and the fmt package for printed input and output on the command line.

Il codice chiama il metodo sql.Open() per la connessione a Database di Azure per il database PostgreSQL e controlla la connessione usando il metodo db.Ping().The code calls method sql.Open() to connect to Azure Database for PostgreSQL database, and checks the connection using method db.Ping(). Viene usato un handle di database, contenente il pool di connessioni per il server di database.A database handle is used throughout, holding the connection pool for the database server. Il codice chiama il metodo Exec() per eseguire l'istruzione SQL che aggiorna la tabella.The code calls the Exec() method to run the SQL statement that updates the table. Viene usato un metodo checkError() personalizzato per controllare se si è verificato un errore e un metodo panic per uscire se si verifica un errore.A custom checkError() method is used to check if an error occurred and panic to exit if an error does occur.

Sostituire i parametri HOST, DATABASE, USER e PASSWORD con valori personalizzati.Replace the HOST, DATABASE, USER, and PASSWORD parameters with your own values.

package main

import (
  "database/sql"
  _ "github.com/lib/pq"
  "fmt"
)

const (
    // Initialize connection constants.
    HOST     = "mypgserver-20170401.postgres.database.azure.com"
    DATABASE = "mypgsqldb"
    USER     = "mylogin@mypgserver-20170401"
    PASSWORD = "<server_admin_password>"
)

func checkError(err error) {
    if err != nil {
        panic(err)
    }
}

func main() {

    // Initialize connection string.
    var connectionString string = 
        fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

    // Initialize connection object.
    db, err := sql.Open("postgres", connectionString)
    checkError(err)

    err = db.Ping()
    checkError(err)
    fmt.Println("Successfully created connection to database")

    // Modify some data in table.
    sql_statement := "UPDATE inventory SET quantity = $2 WHERE name = $1;"
    _, err = db.Exec(sql_statement, "banana", 200)
    checkError(err)
    fmt.Println("Updated 1 row of data")
}

Eliminare i datiDelete data

Usare il codice seguente per connettersi ed eliminare i dati usando un'istruzione SQL DELETE.Use the following code to connect and delete the data using a DELETE SQL statement.

Il codice importa tre pacchetti: il pacchetto sql, il pacchetto pq, come driver per comunicare con il server Postgres, e il pacchetto fmt per l'input e l'output stampati nella riga di comando.The code imports three packages: the sql package, the pq package as a driver to communicate with the Postgres server, and the fmt package for printed input and output on the command line.

Il codice chiama il metodo sql.Open() per la connessione a Database di Azure per il database PostgreSQL e controlla la connessione usando il metodo db.Ping().The code calls method sql.Open() to connect to Azure Database for PostgreSQL database, and checks the connection using method db.Ping(). Viene usato un handle di database, contenente il pool di connessioni per il server di database.A database handle is used throughout, holding the connection pool for the database server. Il codice chiama il metodo Exec() per eseguire l'istruzione SQL che elimina una riga dalla tabella.The code calls the Exec() method to run the SQL statement that deletes a row from the table. Viene usato un metodo checkError() personalizzato per controllare se si è verificato un errore e un metodo panic per uscire se si verifica un errore.A custom checkError() method is used to check if an error occurred and panic to exit if an error does occur.

Sostituire i parametri HOST, DATABASE, USER e PASSWORD con valori personalizzati.Replace the HOST, DATABASE, USER, and PASSWORD parameters with your own values.

package main

import (
  "database/sql"
  _ "github.com/lib/pq"
  "fmt"
)

const (
    // Initialize connection constants.
    HOST     = "mypgserver-20170401.postgres.database.azure.com"
    DATABASE = "mypgsqldb"
    USER     = "mylogin@mypgserver-20170401"
    PASSWORD = "<server_admin_password>"
)

func checkError(err error) {
    if err != nil {
        panic(err)
    }
}

func main() {

    // Initialize connection string.
    var connectionString string = 
        fmt.Sprintf("host=%s user=%s password=%s dbname=%s sslmode=require", HOST, USER, PASSWORD, DATABASE)

    // Initialize connection object.
    db, err := sql.Open("postgres", connectionString)
    checkError(err)

    err = db.Ping()
    checkError(err)
    fmt.Println("Successfully created connection to database")

    // Delete some data from table.
    sql_statement := "DELETE FROM inventory WHERE name = $1;"
    _, err = db.Exec(sql_statement, "orange")
    checkError(err)
    fmt.Println("Deleted 1 row of data")
}

Passaggi successiviNext steps