Skip to content

Commit 0da307f

Browse files
mattnmattn
committed
gofmt
1 parent ca20da3 commit 0da307f

File tree

4 files changed

+285
-276
lines changed

4 files changed

+285
-276
lines changed

‎samples/tutorials/go/columnstore.go‎

Lines changed: 49 additions & 46 deletions
Original file line numberDiff line numberDiff line change
@@ -1,46 +1,49 @@
1-
package main
2-
3-
import _ "github.com/denisenkom/go-mssqldb"
4-
import "database/sql"
5-
import "log"
6-
import "fmt"
7-
import "time"
8-
9-
var server = "localhost"
10-
var port = 1433
11-
var user = "sa"
12-
var password = "your_password"
13-
var database = "SampleDB"
14-
15-
// Delete an employee from database
16-
func ExecuteAggregateStatement(db *sql.DB) {
17-
result, err := db.Prepare("SELECT SUM(Price) as sum FROM Table_with_5M_rows")
18-
if err != nil {
19-
fmt.Println("Error preparing query: " + err.Error())
20-
}
21-
22-
row := result.QueryRow()
23-
var sum string
24-
err = row.Scan(&sum)
25-
fmt.Printf("Sum: %s\n", sum)
26-
}
27-
28-
func main() {
29-
// Connect to database
30-
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
31-
server, user, password, port, database)
32-
conn, err := sql.Open("mssql", connString)
33-
if err != nil {
34-
log.Fatal("Open connection failed:", err.Error())
35-
}
36-
fmt.Printf("Connected!\n")
37-
defer conn.Close()
38-
39-
t1 := time.Now()
40-
fmt.Printf("Start time: %s\n", t1)
41-
42-
ExecuteAggregateStatement(conn)
43-
44-
t2 := time.Since(t1)
45-
fmt.Printf("The query took: %s\n", t2)
46-
}
1+
package main
2+
3+
import (
4+
"database/sql"
5+
"fmt"
6+
"log"
7+
"time"
8+
9+
_ "github.com/denisenkom/go-mssqldb"
10+
)
11+
12+
var server = "localhost"
13+
var port = 1433
14+
var user = "sa"
15+
var password = "your_password"
16+
var database = "SampleDB"
17+
18+
// Delete an employee from database
19+
func ExecuteAggregateStatement(db *sql.DB) {
20+
result, err := db.Prepare("SELECT SUM(Price) as sum FROM Table_with_5M_rows")
21+
if err != nil {
22+
fmt.Println("Error preparing query: " + err.Error())
23+
}
24+
25+
row := result.QueryRow()
26+
var sum string
27+
err = row.Scan(&sum)
28+
fmt.Printf("Sum: %s\n", sum)
29+
}
30+
31+
func main() {
32+
// Connect to database
33+
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
34+
server, user, password, port, database)
35+
conn, err := sql.Open("mssql", connString)
36+
if err != nil {
37+
log.Fatal("Open connection failed:", err.Error())
38+
}
39+
fmt.Printf("Connected!\n")
40+
defer conn.Close()
41+
42+
t1 := time.Now()
43+
fmt.Printf("Start time: %s\n", t1)
44+
45+
ExecuteAggregateStatement(conn)
46+
47+
t2 := time.Since(t1)
48+
fmt.Printf("The query took: %s\n", t2)
49+
}

‎samples/tutorials/go/connect.go‎

Lines changed: 35 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1,33 +1,35 @@
1-
package main
2-
3-
import _ "github.com/denisenkom/go-mssqldb"
4-
import "database/sql"
5-
import "log"
6-
import "fmt"
7-
8-
9-
var server = "localhost"
10-
var port = 1433
11-
var user = "sa"
12-
var password = "your_password"
13-
14-
func main() {
15-
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d",
16-
server, user, password, port)
17-
18-
conn, err := sql.Open("mssql", connString)
19-
if err != nil {
20-
log.Fatal("Open connection failed:", err.Error())
21-
}
22-
fmt.Printf("Connected!\n")
23-
defer conn.Close()
24-
stmt, err := conn.Prepare("select @@version")
25-
row := stmt.QueryRow()
26-
var result string
27-
28-
err = row.Scan(&result)
29-
if err != nil {
30-
log.Fatal("Scan failed:", err.Error())
31-
}
32-
fmt.Printf("%s\n", result)
33-
}
1+
package main
2+
3+
import (
4+
"database/sql"
5+
"fmt"
6+
"log"
7+
8+
_ "github.com/denisenkom/go-mssqldb"
9+
)
10+
11+
var server = "localhost"
12+
var port = 1433
13+
var user = "sa"
14+
var password = "your_password"
15+
16+
func main() {
17+
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d",
18+
server, user, password, port)
19+
20+
conn, err := sql.Open("mssql", connString)
21+
if err != nil {
22+
log.Fatal("Open connection failed:", err.Error())
23+
}
24+
fmt.Printf("Connected!\n")
25+
defer conn.Close()
26+
stmt, err := conn.Prepare("select @@version")
27+
row := stmt.QueryRow()
28+
var result string
29+
30+
err = row.Scan(&result)
31+
if err != nil {
32+
log.Fatal("Scan failed:", err.Error())
33+
}
34+
fmt.Printf("%s\n", result)
35+
}

‎samples/tutorials/go/crud.go‎

Lines changed: 102 additions & 99 deletions
Original file line numberDiff line numberDiff line change
@@ -1,99 +1,102 @@
1-
package main
2-
3-
import _ "github.com/denisenkom/go-mssqldb"
4-
import "database/sql"
5-
import "log"
6-
import "fmt"
7-
8-
var server = "localhost"
9-
var port = 1433
10-
var user = "sa"
11-
var password = "your_password"
12-
var database = "SampleDB"
13-
14-
// Create an employee
15-
func CreateEmployee(db *sql.DB, name string, location string) (int64, error) {
16-
tsql := fmt.Sprintf("INSERT INTO TestSchema.Employees (Name, Location) VALUES ('%s','%s');",
17-
name, location)
18-
result, err := db.Exec(tsql)
19-
if err != nil {
20-
fmt.Println("Error inserting new row: " + err.Error())
21-
return -1, err
22-
}
23-
return result.LastInsertId()
24-
}
25-
26-
// Read all employees
27-
func ReadEmployees(db *sql.DB) (int, error) {
28-
tsql := fmt.Sprintf("SELECT Id, Name, Location FROM TestSchema.Employees;")
29-
rows, err := db.Query(tsql)
30-
if err != nil {
31-
fmt.Println("Error reading rows: " + err.Error())
32-
return -1, err
33-
}
34-
defer rows.Close()
35-
var count int = 0
36-
for rows.Next(){
37-
var name, location string
38-
var id int
39-
err := rows.Scan(&id, &name, &location)
40-
if err != nil {
41-
fmt.Println("Error reading rows: " + err.Error())
42-
return -1, err
43-
}
44-
fmt.Printf("ID: %d, Name: %s, Location: %s\n", id, name, location)
45-
count++
46-
}
47-
return count, nil
48-
}
49-
50-
// Update an employee's information
51-
func UpdateEmployee(db *sql.DB, name string, location string) (int64, error) {
52-
tsql := fmt.Sprintf("UPDATE TestSchema.Employees SET Location = '%s' WHERE Name= '%s'",
53-
location, name)
54-
result, err := db.Exec(tsql)
55-
if err != nil {
56-
fmt.Println("Error updating row: " + err.Error())
57-
return -1, err
58-
}
59-
return result.LastInsertId()
60-
}
61-
62-
// Delete an employee from database
63-
func DeleteEmployee(db *sql.DB, name string) (int64, error) {
64-
tsql := fmt.Sprintf("DELETE FROM TestSchema.Employees WHERE Name='%s';", name)
65-
result, err := db.Exec(tsql)
66-
if err != nil {
67-
fmt.Println("Error deleting row: " + err.Error())
68-
return -1, err
69-
}
70-
return result.RowsAffected()
71-
}
72-
73-
func main() {
74-
// Connect to database
75-
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
76-
server, user, password, port, database)
77-
conn, err := sql.Open("mssql", connString)
78-
if err != nil {
79-
log.Fatal("Open connection failed:", err.Error())
80-
}
81-
fmt.Printf("Connected!\n")
82-
defer conn.Close()
83-
84-
// Create employee
85-
createId, err := CreateEmployee(conn, "Jake", "United States")
86-
fmt.Printf("Inserted ID: %d successfully.\n", createId)
87-
88-
// Read employees
89-
count, err := ReadEmployees(conn)
90-
fmt.Printf("Read %d rows successfully.\n", count)
91-
92-
// Update from database
93-
updateId, err := UpdateEmployee(conn, "Jake", "Poland")
94-
fmt.Printf("Updated row with ID: %d successfully.\n", updateId)
95-
96-
// Delete from database
97-
rows, err := DeleteEmployee(conn, "Jake")
98-
fmt.Printf("Deleted %d rows successfully.\n", rows)
99-
}
1+
package main
2+
3+
import (
4+
"database/sql"
5+
"fmt"
6+
"log"
7+
8+
_ "github.com/denisenkom/go-mssqldb"
9+
)
10+
11+
var server = "localhost"
12+
var port = 1433
13+
var user = "sa"
14+
var password = "your_password"
15+
var database = "SampleDB"
16+
17+
// Create an employee
18+
func CreateEmployee(db *sql.DB, name string, location string) (int64, error) {
19+
tsql := fmt.Sprintf("INSERT INTO TestSchema.Employees (Name, Location) VALUES ('%s','%s');",
20+
name, location)
21+
result, err := db.Exec(tsql)
22+
if err != nil {
23+
fmt.Println("Error inserting new row: " + err.Error())
24+
return -1, err
25+
}
26+
return result.LastInsertId()
27+
}
28+
29+
// Read all employees
30+
func ReadEmployees(db *sql.DB) (int, error) {
31+
tsql := fmt.Sprintf("SELECT Id, Name, Location FROM TestSchema.Employees;")
32+
rows, err := db.Query(tsql)
33+
if err != nil {
34+
fmt.Println("Error reading rows: " + err.Error())
35+
return -1, err
36+
}
37+
defer rows.Close()
38+
var count int = 0
39+
for rows.Next() {
40+
var name, location string
41+
var id int
42+
err := rows.Scan(&id, &name, &location)
43+
if err != nil {
44+
fmt.Println("Error reading rows: " + err.Error())
45+
return -1, err
46+
}
47+
fmt.Printf("ID: %d, Name: %s, Location: %s\n", id, name, location)
48+
count++
49+
}
50+
return count, nil
51+
}
52+
53+
// Update an employee's information
54+
func UpdateEmployee(db *sql.DB, name string, location string) (int64, error) {
55+
tsql := fmt.Sprintf("UPDATE TestSchema.Employees SET Location = '%s' WHERE Name= '%s'",
56+
location, name)
57+
result, err := db.Exec(tsql)
58+
if err != nil {
59+
fmt.Println("Error updating row: " + err.Error())
60+
return -1, err
61+
}
62+
return result.LastInsertId()
63+
}
64+
65+
// Delete an employee from database
66+
func DeleteEmployee(db *sql.DB, name string) (int64, error) {
67+
tsql := fmt.Sprintf("DELETE FROM TestSchema.Employees WHERE Name='%s';", name)
68+
result, err := db.Exec(tsql)
69+
if err != nil {
70+
fmt.Println("Error deleting row: " + err.Error())
71+
return -1, err
72+
}
73+
return result.RowsAffected()
74+
}
75+
76+
func main() {
77+
// Connect to database
78+
connString := fmt.Sprintf("server=%s;user id=%s;password=%s;port=%d;database=%s;",
79+
server, user, password, port, database)
80+
conn, err := sql.Open("mssql", connString)
81+
if err != nil {
82+
log.Fatal("Open connection failed:", err.Error())
83+
}
84+
fmt.Printf("Connected!\n")
85+
defer conn.Close()
86+
87+
// Create employee
88+
createId, err := CreateEmployee(conn, "Jake", "United States")
89+
fmt.Printf("Inserted ID: %d successfully.\n", createId)
90+
91+
// Read employees
92+
count, err := ReadEmployees(conn)
93+
fmt.Printf("Read %d rows successfully.\n", count)
94+
95+
// Update from database
96+
updateId, err := UpdateEmployee(conn, "Jake", "Poland")
97+
fmt.Printf("Updated row with ID: %d successfully.\n", updateId)
98+
99+
// Delete from database
100+
rows, err := DeleteEmployee(conn, "Jake")
101+
fmt.Printf("Deleted %d rows successfully.\n", rows)
102+
}

0 commit comments

Comments
 (0)