diff --git a/sea.go b/sea.go index 4150ec3..3c7b8e9 100644 --- a/sea.go +++ b/sea.go @@ -1,30 +1,45 @@ package sea import ( - "fmt" + // "fmt" _ "github.com/go-sql-driver/mysql" // для связи с mysql "github.com/jmoiron/sqlx" ) +// ============= SEA ============ + +type Sea struct { + db *sqlx.DB +} + +func Connect() (*Sea, error) { + db, err := openDB() + if err != nil { + return nil, err + } + sea := Sea{db: db} + return &sea, nil +} + +// ============= ALBUM ============ type Album struct { Seria string Cnt int Hash string } -func getAlbums(db *sqlx.DB) []Album { - cmd := "call getAlbums()" - var albums []Album - err := db.Select(&albums, cmd) - checkError("get albums", err) - - return albums -} +// func getAlbums(db *sqlx.DB) []Album { +// cmd := "call getAlbums()" +// var albums []Album +// err := db.Select(&albums, cmd) +// return albums +// } -func openDB() *sqlx.DB { - fmt.Printf("открываю БД sea\n") +func openDB() (*sqlx.DB, error) { db, err := sqlx.Open("mysql", "itman:X753951x@(xigmanas:3306)/sea") - checkError("open db", err) - return db + if err != nil { + return nil, err + } + return db, nil }