package main import ( "github.com/jmoiron/sqlx" _ "github.com/lib/pq" ) func connect() (*sqlx.DB, error) { db := config.Database return sqlx.Connect( db.Adapter, "user="+db.Username+ " password="+db.Password+ " dbname="+db.Database+ " sslmode="+db.SSLMode) } func getCaches() (DBCaches, error) { var caches DBCaches db, err := connect() if err != nil { return caches, err } err = db.Select(&caches, "SELECT * FROM caches ORDER BY id ASC") if err != nil { return caches, err } err = db.Close() return caches, err } func getCache(id uint64) (DBCache, error) { var cache DBCache db, err := connect() if err != nil { return cache, err } err = db.Get(&cache, "SELECT * FROM caches WHERE id=$1", id) if err != nil { return cache, err } err = db.Close() return cache, err } func postCache(incache DBCache) (DBCache, error) { var outcache DBCache db, err := connect() if err != nil { return outcache, err } rows, err := db.NamedQuery("INSERT INTO caches (latitude, longitude, created, path) VALUES (:latitude, :longitude, :created, :path) RETURNING *", incache) if err != nil { return outcache, err } rows.Next() err = rows.StructScan(&outcache) if err != nil { return outcache, err } err = db.Close() return outcache, err }