mirror of
https://github.com/Microsoft/sql-server-samples.git
synced 2025-12-08 14:58:54 +00:00
50 lines
1.0 KiB
Go
50 lines
1.0 KiB
Go
package main
|
|
|
|
import (
|
|
"database/sql"
|
|
"fmt"
|
|
"log"
|
|
"time"
|
|
|
|
_ "github.com/denisenkom/go-mssqldb"
|
|
)
|
|
|
|
var server = "localhost"
|
|
var port = 1433
|
|
var user = "sa"
|
|
var password = "your_password"
|
|
var database = "SampleDB"
|
|
|
|
// Delete an employee from database
|
|
func ExecuteAggregateStatement(db *sql.DB) {
|
|
result, err := db.Prepare("SELECT SUM(Price) as sum FROM Table_with_5M_rows")
|
|
if err != nil {
|
|
fmt.Println("Error preparing query: " + err.Error())
|
|
}
|
|
|
|
row := result.QueryRow()
|
|
var sum string
|
|
err = row.Scan(&sum)
|
|
fmt.Printf("Sum: %s\n", sum)
|
|
}
|
|
|
|
func main() {
|
|
// Connect to database
|
|
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
|
|
server, user, password, port, database)
|
|
conn, err := sql.Open("mssql", connString)
|
|
if err != nil {
|
|
log.Fatal("Open connection failed:", err.Error())
|
|
}
|
|
fmt.Printf("Connected!\n")
|
|
defer conn.Close()
|
|
|
|
t1 := time.Now()
|
|
fmt.Printf("Start time: %s\n", t1)
|
|
|
|
ExecuteAggregateStatement(conn)
|
|
|
|
t2 := time.Since(t1)
|
|
fmt.Printf("The query took: %s\n", t2)
|
|
}
|