databaseutils.go 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. package databaseutils
  2. import (
  3. "database/sql"
  4. _ "github.com/go-sql-driver/mysql"
  5. "fmt"
  6. )
  7. var (
  8. DBUtil *DBUtils
  9. )
  10. type DBUtils struct {
  11. User string
  12. Password string
  13. Host string
  14. Database string
  15. Handle *sql.DB
  16. }
  17. // db := dbUtils{"root", "root", "127.0.0.1", "gotest"}
  18. func (dbUtil *DBUtils) Connect() {
  19. var err error
  20. dbUtil.Handle, err = sql.Open("mysql", dbUtil.User + ":" + dbUtil.Password + "@tcp(" + dbUtil.Host + ")/" + dbUtil.Database) // open handle
  21. if err != nil {
  22. panic(err.Error()) // TODO
  23. }
  24. err = dbUtil.Handle.Ping() // try to connect
  25. if err != nil {
  26. panic(err.Error()) // TODO
  27. }
  28. }
  29. func (dbUtil DBUtils) Close() {
  30. dbUtil.Handle.Close()
  31. }
  32. func (dbUtil DBUtils) GetString(what string, from string, where string, wherevalue string) string {
  33. var username string
  34. rows, err := dbUtil.Handle.Query("SELECT " + what + " FROM " + from + " WHERE " + where + " = " + wherevalue) // TODO Parse?
  35. if err != nil {
  36. fmt.Println(err)
  37. }
  38. defer rows.Close()
  39. for rows.Next() {
  40. err := rows.Scan(&username)
  41. if err != nil {
  42. fmt.Println(err)
  43. }
  44. fmt.Println(username)
  45. }
  46. err = rows.Err()
  47. if err != nil {
  48. fmt.Println(err)
  49. }
  50. return username
  51. }
  52. // GetRow(what, from, where, wherevalue)
  53. func (dbUtil DBUtils) GetRow(options ...string) ([]string, error) {
  54. var err error
  55. var rows *sql.Rows // TODO fix this weird bug
  56. if len(options) > 3 { // with or without where
  57. rows, err = dbUtil.Handle.Query("SELECT " + options[0] + " FROM " + options[1] + " WHERE " + options[2] + " = \"" + options[3] + "\"") // TODO Parse?
  58. } else {
  59. rows, err = dbUtil.Handle.Query("SELECT " + options[0] + " FROM " + options[1]) // TODO Parse?
  60. }
  61. if err != nil {
  62. fmt.Println(err)
  63. }
  64. cols, err := rows.Columns()
  65. if err != nil {
  66. fmt.Println("Failed to get columns", err)
  67. var x []string;
  68. x[0] = "";
  69. return x, err
  70. }
  71. // Result is your slice string.
  72. rawResult := make([][]byte, len(cols))
  73. result := make([]string, len(cols))
  74. dest := make([]interface{}, len(cols)) // A temporary interface{} slice
  75. for i, _ := range rawResult {
  76. dest[i] = &rawResult[i] // Put pointers to each string in the interface slice
  77. }
  78. for rows.Next() {
  79. err = rows.Scan(dest...)
  80. if err != nil {
  81. fmt.Println("Failed to scan row", err)
  82. var x []string;
  83. x[0] = "";
  84. return x
  85. }
  86. for i, raw := range rawResult {
  87. if raw == nil {
  88. result[i] = "\\N"
  89. } else {
  90. result[i] = string(raw)
  91. }
  92. }
  93. }
  94. return result
  95. }