mysql - dodawanie i pobieranie uzytkownikow dziala
This commit is contained in:
parent
63c0fc8d54
commit
d0849206c1
Binary file not shown.
@ -16,29 +16,36 @@ func connectMysql() (*sql.DB, error) {
|
|||||||
return db, nil
|
return db, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// func addUser(login string, password string, userDescription string, points int) {
|
func addUser(_login string, _password string, _userDescription string, _points int) {
|
||||||
// //do rejestracji uzytkownika
|
//do rejestracji uzytkownika
|
||||||
// // Insert do bazy Mysql Nowego użytkownika
|
// Insert do bazy Mysql Nowego użytkownika
|
||||||
|
|
||||||
// db, err = connectMysql()
|
db, err := connectMysql()
|
||||||
// if err != nil {
|
|
||||||
// panic(err.Error())
|
|
||||||
// }
|
|
||||||
// queryInsert := fmt.Sprintf(`INSERT INTO golang_user (
|
|
||||||
// login,
|
|
||||||
// password,
|
|
||||||
// userDescription,
|
|
||||||
// points
|
|
||||||
// )VALUES (
|
|
||||||
// %s,
|
|
||||||
// %s,
|
|
||||||
// %s,
|
|
||||||
// %d
|
|
||||||
// )`, login, password, userDescription, 0)
|
|
||||||
|
|
||||||
// insert, err := db.Query(queryInsert)
|
if err != nil {
|
||||||
|
panic(err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
// }
|
queryInsert := fmt.Sprintf(`INSERT INTO users (
|
||||||
|
login,
|
||||||
|
password,
|
||||||
|
userDescription,
|
||||||
|
points
|
||||||
|
)VALUES (
|
||||||
|
"%s",
|
||||||
|
"%s",
|
||||||
|
"%s",
|
||||||
|
"%d"
|
||||||
|
)`, _login, _password, _userDescription, _points)
|
||||||
|
|
||||||
|
fmt.Printf(queryInsert)
|
||||||
|
insert, err := db.Query(queryInsert)
|
||||||
|
if err != nil {
|
||||||
|
panic(err.Error())
|
||||||
|
}
|
||||||
|
fmt.Println(insert)
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
func getAllUsers() []User {
|
func getAllUsers() []User {
|
||||||
//pobiera wszystkich uzytkownikow - do wysiwetlenie na front
|
//pobiera wszystkich uzytkownikow - do wysiwetlenie na front
|
||||||
@ -60,16 +67,14 @@ func getAllUsers() []User {
|
|||||||
for result.Next() {
|
for result.Next() {
|
||||||
var user User
|
var user User
|
||||||
|
|
||||||
err = result.Scan(&user.userId, user.login, user.userDescription, user.points)
|
err = result.Scan(&user.userId, &user.login, &user.password, &user.userDescription, &user.points)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err.Error())
|
panic(err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println(user.userId, user.login)
|
|
||||||
allUsers = append(allUsers, user)
|
allUsers = append(allUsers, user)
|
||||||
}
|
}
|
||||||
|
|
||||||
fmt.Println(allUsers)
|
|
||||||
return allUsers
|
return allUsers
|
||||||
|
|
||||||
}
|
}
|
||||||
@ -81,6 +86,9 @@ func main() {
|
|||||||
// // db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/golang_user")
|
// // db, err := sql.Open("mysql", "root:password@tcp(127.0.0.1:3306)/golang_user")
|
||||||
// fmt.Println(reflect.TypeOf(db))
|
// fmt.Println(reflect.TypeOf(db))
|
||||||
// fmt.Println(reflect.TypeOf(err))
|
// fmt.Println(reflect.TypeOf(err))
|
||||||
|
|
||||||
|
addUser("login10", "password", "userDescription", 123)
|
||||||
allUsers := getAllUsers()
|
allUsers := getAllUsers()
|
||||||
fmt.Println(allUsers)
|
fmt.Println(allUsers)
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user