removed unused database config
This commit is contained in:
parent
07e6748060
commit
17e34352f9
40
database.go
40
database.go
@ -1,40 +0,0 @@
|
||||
package request
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"log"
|
||||
)
|
||||
|
||||
func dbConnect() *sql.DB {
|
||||
resp := Option().Database
|
||||
db, err := sql.Open("mysql", resp.User+":"+resp.Passwd+"@tcp("+resp.Server+")/"+resp.Db)
|
||||
if err != nil {
|
||||
fmt.Println(err)
|
||||
} else {
|
||||
fmt.Println("Connection Established")
|
||||
}
|
||||
return db
|
||||
}
|
||||
|
||||
func GetUser(id int) {
|
||||
var email string
|
||||
db := dbConnect()
|
||||
rows, err := db.Query("select request_id, email from gdpr_requests where request_id = ?", 1)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
defer db.Close()
|
||||
for rows.Next() {
|
||||
err := rows.Scan(&id, &email)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
fmt.Println(id, email)
|
||||
}
|
||||
err = rows.Err()
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
defer db.Close()
|
||||
}
|
Loading…
Reference in New Issue
Block a user