diff --git a/main_test.go b/main_test.go index b20497c8a4455707fdbee6dcd8d1b5c66fc98066..a09c61361bd6a2bd424cbee9e6c00d52b01de6b5 100644 --- a/main_test.go +++ b/main_test.go @@ -4,12 +4,13 @@ import ( "database/sql" "errors" "flag" - "labix.org/v2/mgo" - "labix.org/v2/mgo/bson" "log" "reflect" "testing" "time" + + "labix.org/v2/mgo" + "labix.org/v2/mgo/bson" "upper.io/db" _ "upper.io/db/mongo" _ "upper.io/db/mysql" diff --git a/mongo/_example/main.go b/mongo/_example/main.go index 4b86f107176711105aa841cf2601cace6724e5ae..0f72b97354b59e5ede666bdd35035aefc9214ffb 100644 --- a/mongo/_example/main.go +++ b/mongo/_example/main.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "time" + "upper.io/db" // Imports the main db package. _ "upper.io/db/mongo" // Imports the mongo adapter. ) diff --git a/mongo/collection.go b/mongo/collection.go index 02b6ef588d8d9a57cd03432ad95fb7a3412d0d4c..4b1a855f409ed828f6d47f69d415fbc0fcbb8ace 100644 --- a/mongo/collection.go +++ b/mongo/collection.go @@ -25,9 +25,10 @@ package mongo import ( "fmt" + "strings" + "labix.org/v2/mgo" "labix.org/v2/mgo/bson" - "strings" "upper.io/db" "upper.io/db/util" ) diff --git a/mongo/database.go b/mongo/database.go index b2472c2056b5a70315de2731b8bd9ca89c9d3c50..66c683bf89254659c255e0ac3cebdb180c18b213 100644 --- a/mongo/database.go +++ b/mongo/database.go @@ -25,12 +25,13 @@ package mongo import ( "fmt" - "labix.org/v2/mgo" "log" "net/url" "os" "strings" "time" + + "labix.org/v2/mgo" "upper.io/db" ) diff --git a/mongo/database_test.go b/mongo/database_test.go index fbd7328cb93c1f08fce287a1c13699e463d1aee2..47dc528b0dfa1cf3a71f17adc61a1863b48507b0 100644 --- a/mongo/database_test.go +++ b/mongo/database_test.go @@ -24,14 +24,15 @@ package mongo import ( - "labix.org/v2/mgo" - "labix.org/v2/mgo/bson" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "labix.org/v2/mgo" + "labix.org/v2/mgo/bson" + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -109,7 +110,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -119,7 +120,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -127,7 +128,7 @@ func TestTruncate(t *testing.T) { // Pointing the collection. col, err := sess.Collection(name) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // The collection may ot may not exists. @@ -138,7 +139,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -155,7 +156,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -167,7 +168,7 @@ func TestAppend(t *testing.T) { if err != nil { // We can use the collection even if it does not exists. if err != db.ErrCollectionDoesNotExists { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -243,7 +244,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -257,7 +258,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -276,7 +277,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -285,7 +286,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -316,7 +317,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -346,7 +347,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -376,7 +377,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -389,7 +390,7 @@ func TestResultFetch(t *testing.T) { err = res.All(&all_rows_m) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, single_row_m := range all_rows_m { @@ -408,7 +409,7 @@ func TestResultFetch(t *testing.T) { err = res.All(&all_rows_s) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, single_row_s := range all_rows_s { @@ -427,7 +428,7 @@ func TestResultFetch(t *testing.T) { err = res.All(&all_rows_t) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, single_row_t := range all_rows_t { @@ -445,7 +446,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -455,7 +456,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -470,7 +471,7 @@ func TestUpdate(t *testing.T) { err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating with a map @@ -481,13 +482,13 @@ func TestUpdate(t *testing.T) { err = res.Update(row_m) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if value.Name != row_m["name"] { @@ -502,13 +503,13 @@ func TestUpdate(t *testing.T) { err = res.Update(row_s) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if value.Name != row_s.Name { @@ -523,13 +524,13 @@ func TestUpdate(t *testing.T) { err = res.Update(row_t) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if value.Name != row_t.Value1 { @@ -547,7 +548,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -557,7 +558,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -589,7 +590,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -599,7 +600,7 @@ func TestRemove(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the first artist. @@ -612,7 +613,7 @@ func TestRemove(t *testing.T) { err = res.One(&first) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } res = artist.Find(db.Cond{"_id": first.Id}) @@ -621,7 +622,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -635,7 +636,7 @@ func TestDataTypes(t *testing.T) { sess, err := db.Open(Adapter, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -649,7 +650,7 @@ func TestDataTypes(t *testing.T) { id, err := dataTypes.Append(testValues) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Trying to get the same subject we added. @@ -658,7 +659,7 @@ func TestDataTypes(t *testing.T) { exists, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -685,7 +686,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -702,7 +703,7 @@ func BenchmarkAppendRaw(b *testing.B) { for i := 0; i < b.N; i++ { err := col.Insert(map[string]string{"name": "Hayao Miyazaki"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -711,7 +712,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -723,7 +724,7 @@ func BenchmarkAppendDbItem(b *testing.B) { for i := 0; i < b.N; i++ { _, err = artist.Append(map[string]string{"name": "Leonardo DaVinci"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -732,7 +733,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -744,7 +745,7 @@ func BenchmarkAppendStruct(b *testing.B) { for i := 0; i < b.N; i++ { _, err = artist.Append(struct{ Name string }{"John Lennon"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } diff --git a/mongo/result.go b/mongo/result.go index 5d810a9cdd4f3a3668421c0640d5cc377c19ea77..a18034d41cc338b4c5e40a7993af6bb1811b98c4 100644 --- a/mongo/result.go +++ b/mongo/result.go @@ -26,6 +26,7 @@ package mongo import ( "errors" "fmt" + "labix.org/v2/mgo" "labix.org/v2/mgo/bson" "upper.io/db" diff --git a/mysql/_example/main.go b/mysql/_example/main.go index f7d963f6554fd8f8aa6174d10fd40e308f1850f6..87029d2d3eb17603a8f447bc4ad6e54c44e16809 100644 --- a/mysql/_example/main.go +++ b/mysql/_example/main.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "time" + "upper.io/db" // Imports the main db package. _ "upper.io/db/mysql" // Improts the mysql adapter. ) diff --git a/mysql/collection.go b/mysql/collection.go index a358e0aeb84e4fd1026db0401b3c82564a4ce49e..0091d2bce2a93cdf338a171ca61087ca3715e7ff 100644 --- a/mysql/collection.go +++ b/mysql/collection.go @@ -23,10 +23,11 @@ package mysql import ( "fmt" - "menteslibres.net/gosexy/to" "reflect" "strings" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/mysql/database.go b/mysql/database.go index 8c2f480e3959d97f951a37f7866a0d9e16ad6b6d..acd8dca2b8a419f71bd9e1f95f9ba18ba1b32526 100644 --- a/mysql/database.go +++ b/mysql/database.go @@ -24,11 +24,12 @@ package mysql import ( "database/sql" "fmt" - _ "github.com/go-sql-driver/mysql" "os" "reflect" "regexp" "strings" + + _ "github.com/go-sql-driver/mysql" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/mysql/database_test.go b/mysql/database_test.go index c08bc47c70bfe64ac676ca1862dff0f5dc8c416b..e9cccd2a8c604197f04c5c48582f84c1dcff39b0 100644 --- a/mysql/database_test.go +++ b/mysql/database_test.go @@ -31,12 +31,13 @@ package mysql import ( "database/sql" "flag" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -120,7 +121,7 @@ func TestTruncate(t *testing.T) { // Opening database. if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -128,7 +129,7 @@ func TestTruncate(t *testing.T) { // Getting a list of all collections in this database. if collections, err = sess.Collections(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(collections) == 0 { @@ -140,14 +141,14 @@ func TestTruncate(t *testing.T) { // Getting a collection. if col, err = sess.Collection(name); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Table must exists before we can use it. if col.Exists() == true { // Truncating the table. if err = col.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } } @@ -162,13 +163,13 @@ func TestAppend(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Attempt to append a map. @@ -177,7 +178,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -192,7 +193,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -207,7 +208,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -216,7 +217,7 @@ func TestAppend(t *testing.T) { // Counting elements, must be exactly 3 elements. if total, err = artist.Find().Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -234,14 +235,14 @@ func TestResultCount(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // We should close the database when it's no longer in use. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining a set with no conditions. @@ -249,7 +250,7 @@ func TestResultCount(t *testing.T) { // Counting all the matching rows. if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -265,13 +266,13 @@ func TestResultFetch(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Dumping into a map. @@ -294,7 +295,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -323,7 +324,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -352,7 +353,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -363,7 +364,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_m) != 3 { @@ -385,7 +386,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_s) != 3 { @@ -407,7 +408,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_t) != 3 { @@ -428,13 +429,13 @@ func TestUpdate(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining destination struct @@ -447,7 +448,7 @@ func TestUpdate(t *testing.T) { res := artist.Find(db.Cond{"id !=": 0}).Limit(1) if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating set with a map @@ -456,12 +457,12 @@ func TestUpdate(t *testing.T) { } if err = res.Update(row_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying. @@ -475,12 +476,12 @@ func TestUpdate(t *testing.T) { }{strings.ToLower(value.Name)} if err = res.Update(row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -494,12 +495,12 @@ func TestUpdate(t *testing.T) { }{strings.Replace(value.Name, "z", "Z", -1)} if err = res.Update(row_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -517,13 +518,13 @@ func TestFunction(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -534,11 +535,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id NOT IN": []int{0, -1}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -548,11 +549,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id": db.Func{"NOT IN", []int{0, -1}}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -570,13 +571,13 @@ func TestRemove(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -584,7 +585,7 @@ func TestRemove(t *testing.T) { // Trying to remove the row. if err = res.Remove(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -617,56 +618,56 @@ func TestRawRelations(t *testing.T) { } if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Artist collection. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = artist.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Publication collection. if publication, err = sess.Collection("publication"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = publication.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Review collection. if review, err = sess.Collection("review"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = review.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some artists. var miyazakiId interface{} miyazaki := artist_t{Name: `Hayao Miyazaki`} if miyazakiId, err = artist.Append(miyazaki); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } miyazaki.Id = miyazakiId.(int64) var asimovId interface{} asimov := artist_t{Name: `Isaac Asimov`} if asimovId, err = artist.Append(asimov); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } var marquezId interface{} marquez := artist_t{Name: `Gabriel GarcÃa Márquez`} if marquezId, err = artist.Append(marquez); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some publications. @@ -711,7 +712,7 @@ func TestRawRelations(t *testing.T) { AuthorId: asimovId.(int64), }) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } publication.Append(publication_t{ @@ -737,7 +738,7 @@ func TestRawRelations(t *testing.T) { // Exec'ing a raw query. var artistPublication db.Collection if artistPublication, err = sess.Collection(`artist AS a, publication AS p`); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } res := artistPublication.Find( @@ -757,7 +758,7 @@ func TestRawRelations(t *testing.T) { all := []artistPublication_t{} if err = res.All(&all); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all) != 9 { @@ -778,31 +779,31 @@ func TestDataTypes(t *testing.T) { var exists uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Getting a pointer to the "data_types" collection. if dataTypes, err = sess.Collection("data_types"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Removing all data. if err = dataTypes.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending our test subject. if id, err = dataTypes.Append(testValues); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining our set. res = dataTypes.Find(db.Cond{"id": id}) if exists, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -831,7 +832,7 @@ func BenchmarkAppendRawSQL(b *testing.B) { var sess db.Database if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -839,13 +840,13 @@ func BenchmarkAppendRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if _, err = driver.Exec("TRUNCATE TABLE `artist`"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = driver.Exec("INSERT INTO `artist` (`name`) VALUES('Hayao Miyazaki')"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -858,7 +859,7 @@ func BenchmarkAppendUpper(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -873,7 +874,7 @@ func BenchmarkAppendUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -885,7 +886,7 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { var tx *sql.Tx if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -893,22 +894,22 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if tx, err = driver.Begin(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if _, err = tx.Exec("TRUNCATE TABLE `artist`"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = tx.Exec("INSERT INTO `artist` (`name`) VALUES('Hayao Miyazaki')"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -918,23 +919,23 @@ func BenchmarkAppendTxUpper(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := struct { @@ -944,12 +945,12 @@ func BenchmarkAppendTxUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -959,23 +960,23 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := map[string]string{"name": "Hayao Miyazaki"} @@ -983,11 +984,11 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } diff --git a/mysql/result.go b/mysql/result.go index ca810196ebf524805581f98da41ea88b13e409de..3ebb2a6369d983c8ea702f0669152730092fcf51 100644 --- a/mysql/result.go +++ b/mysql/result.go @@ -25,6 +25,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlgen" ) diff --git a/postgresql/_example/main.go b/postgresql/_example/main.go index 6b0f76c653d410c8aac4e4940274c2fffa20d43d..6ebbfd2931d97178d44c5cac51106d1d3f6e3640 100644 --- a/postgresql/_example/main.go +++ b/postgresql/_example/main.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "time" + "upper.io/db" // Imports the main db package. _ "upper.io/db/postgresql" // Imports the postgresql adapter. ) diff --git a/postgresql/collection.go b/postgresql/collection.go index 445bf6730bb8fefb54fd6b039023001acf0c0a14..04beea90d68aea6a2f3f2bfcbc0d27c252d071a0 100644 --- a/postgresql/collection.go +++ b/postgresql/collection.go @@ -24,10 +24,11 @@ package postgresql import ( "database/sql" "fmt" - "menteslibres.net/gosexy/to" "reflect" "strings" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/postgresql/database.go b/postgresql/database.go index 7af36a7214e4b215c33d0be62f26340b0e1b29a3..a0e9475090341c041d78c9058f16a2a04143f91e 100644 --- a/postgresql/database.go +++ b/postgresql/database.go @@ -24,11 +24,12 @@ package postgresql import ( "database/sql" "fmt" - _ "github.com/xiam/gopostgresql" "os" "reflect" "regexp" "strings" + + _ "github.com/xiam/gopostgresql" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/postgresql/database_test.go b/postgresql/database_test.go index a6d4510da6ac03baef7def2ee8c9686deef0ce59..57db2b0777b221714b5bd952a4c9889d409d25c8 100644 --- a/postgresql/database_test.go +++ b/postgresql/database_test.go @@ -31,12 +31,13 @@ package postgresql import ( "database/sql" "flag" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -120,7 +121,7 @@ func TestTruncate(t *testing.T) { // Opening database. if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -128,7 +129,7 @@ func TestTruncate(t *testing.T) { // Getting a list of all collections in this database. if collections, err = sess.Collections(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(collections) == 0 { @@ -140,14 +141,14 @@ func TestTruncate(t *testing.T) { // Getting a collection. if col, err = sess.Collection(name); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Table must exists before we can use it. if col.Exists() == true { // Truncating the table. if err = col.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } } @@ -162,13 +163,13 @@ func TestAppend(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Attempt to append a map. @@ -177,7 +178,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -192,7 +193,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -207,7 +208,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -216,7 +217,7 @@ func TestAppend(t *testing.T) { // Counting elements, must be exactly 3 elements. if total, err = artist.Find().Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -234,14 +235,14 @@ func TestResultCount(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // We should close the database when it's no longer in use. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining a set with no conditions. @@ -249,7 +250,7 @@ func TestResultCount(t *testing.T) { // Counting all the matching rows. if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -265,13 +266,13 @@ func TestResultFetch(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Dumping into a map. @@ -294,7 +295,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -323,7 +324,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -352,7 +353,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -363,7 +364,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_m) != 3 { @@ -385,7 +386,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_s) != 3 { @@ -407,7 +408,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_t) != 3 { @@ -428,13 +429,13 @@ func TestUpdate(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining destination struct @@ -447,7 +448,7 @@ func TestUpdate(t *testing.T) { res := artist.Find(db.Cond{"id !=": 0}).Limit(1) if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating set with a map @@ -456,12 +457,12 @@ func TestUpdate(t *testing.T) { } if err = res.Update(row_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying. @@ -475,12 +476,12 @@ func TestUpdate(t *testing.T) { }{strings.ToLower(value.Name)} if err = res.Update(row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -494,12 +495,12 @@ func TestUpdate(t *testing.T) { }{strings.Replace(value.Name, "z", "Z", -1)} if err = res.Update(row_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -517,13 +518,13 @@ func TestFunction(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -534,11 +535,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id NOT IN": []int{0, -1}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -548,11 +549,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id": db.Func{"NOT IN", []int{0, -1}}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -570,13 +571,13 @@ func TestRemove(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -584,7 +585,7 @@ func TestRemove(t *testing.T) { // Trying to remove the row. if err = res.Remove(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -617,56 +618,56 @@ func TestRawRelations(t *testing.T) { } if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Artist collection. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = artist.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Publication collection. if publication, err = sess.Collection("publication"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = publication.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Review collection. if review, err = sess.Collection("review"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = review.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some artists. var miyazakiId interface{} miyazaki := artist_t{Name: `Hayao Miyazaki`} if miyazakiId, err = artist.Append(miyazaki); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } miyazaki.Id = miyazakiId.(int64) var asimovId interface{} asimov := artist_t{Name: `Isaac Asimov`} if asimovId, err = artist.Append(asimov); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } var marquezId interface{} marquez := artist_t{Name: `Gabriel GarcÃa Márquez`} if marquezId, err = artist.Append(marquez); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some publications. @@ -711,7 +712,7 @@ func TestRawRelations(t *testing.T) { AuthorId: asimovId.(int64), }) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } publication.Append(publication_t{ @@ -737,7 +738,7 @@ func TestRawRelations(t *testing.T) { // Exec'ing a raw query. var artistPublication db.Collection if artistPublication, err = sess.Collection(`artist AS a, publication AS p`); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } res := artistPublication.Find( @@ -757,7 +758,7 @@ func TestRawRelations(t *testing.T) { all := []artistPublication_t{} if err = res.All(&all); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all) != 9 { @@ -778,31 +779,31 @@ func TestDataTypes(t *testing.T) { var exists uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Getting a pointer to the "data_types" collection. if dataTypes, err = sess.Collection("data_types"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Removing all data. if err = dataTypes.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending our test subject. if id, err = dataTypes.Append(testValues); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining our set. res = dataTypes.Find(db.Cond{"id": id}) if exists, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -831,7 +832,7 @@ func BenchmarkAppendRawSQL(b *testing.B) { var sess db.Database if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -839,13 +840,13 @@ func BenchmarkAppendRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if _, err = driver.Exec(`TRUNCATE TABLE "artist"`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = driver.Exec(`INSERT INTO "artist" ("name") VALUES('Hayao Miyazaki')`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -858,7 +859,7 @@ func BenchmarkAppendUpper(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -873,7 +874,7 @@ func BenchmarkAppendUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -885,7 +886,7 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { var tx *sql.Tx if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -893,22 +894,22 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if tx, err = driver.Begin(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if _, err = tx.Exec(`TRUNCATE TABLE "artist"`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = tx.Exec(`INSERT INTO "artist" ("name") VALUES('Hayao Miyazaki')`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -918,23 +919,23 @@ func BenchmarkAppendTxUpper(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := struct { @@ -944,12 +945,12 @@ func BenchmarkAppendTxUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -959,23 +960,23 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := map[string]string{"name": "Hayao Miyazaki"} @@ -983,11 +984,11 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } diff --git a/postgresql/result.go b/postgresql/result.go index bb5d4c4de806f762a573161f455b8748a76476c9..bf269858fc1948f88143cf35abb64c660adef48c 100644 --- a/postgresql/result.go +++ b/postgresql/result.go @@ -25,6 +25,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlgen" ) diff --git a/ql/_example/main.go b/ql/_example/main.go index 013517e8b868fe022c087ff9a7df544108494425..43c939b0c7b983911c8ceed9da852171630b49df 100644 --- a/ql/_example/main.go +++ b/ql/_example/main.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "time" + "upper.io/db" // Imports the main db package. _ "upper.io/db/ql" // Imports the ql adapter. ) diff --git a/ql/collection.go b/ql/collection.go index aa8c776804f8079b4dd82065388e057d0e310610..238d4395b9ba9b69a5638977961133ee8bbf9527 100644 --- a/ql/collection.go +++ b/ql/collection.go @@ -25,6 +25,7 @@ import ( "fmt" "reflect" "strings" + "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/ql/database.go b/ql/database.go index bf909d8f468721ad7327463b4e0b6df8197a85b8..ff7aaaeaa0e3c215c673e0f1ea7953c58e836d56 100644 --- a/ql/database.go +++ b/ql/database.go @@ -24,11 +24,12 @@ package ql import ( "database/sql" "fmt" - _ "github.com/cznic/ql/driver" "os" "reflect" "strings" "time" + + _ "github.com/cznic/ql/driver" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/ql/database_test.go b/ql/database_test.go index 2a5dc7445c6a9dedcc609788658530f4fa9ca55f..2f74cfc5a86dede81af1cadc85bcc2cc013a2989 100644 --- a/ql/database_test.go +++ b/ql/database_test.go @@ -30,12 +30,14 @@ package ql import ( //"database/sql" - "menteslibres.net/gosexy/to" "os" + + "menteslibres.net/gosexy/to" //"reflect" "strings" "testing" "time" + "upper.io/db" ) @@ -108,7 +110,7 @@ func TestTruncate(t *testing.T) { // Opening database. if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -116,7 +118,7 @@ func TestTruncate(t *testing.T) { // Getting a list of all collections in this database. if collections, err = sess.Collections(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(collections) == 0 { @@ -128,14 +130,14 @@ func TestTruncate(t *testing.T) { // Getting a collection. if col, err = sess.Collection(name); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Table must exists before we can use it. if col.Exists() == true { // Truncating the table. if err = col.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } } @@ -150,13 +152,13 @@ func TestAppend(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Attempt to append a map. @@ -165,7 +167,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -180,7 +182,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -195,7 +197,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -204,7 +206,7 @@ func TestAppend(t *testing.T) { // Counting elements, must be exactly 3 elements. if total, err = artist.Find().Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -222,14 +224,14 @@ func TestResultCount(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // We should close the database when it's no longer in use. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining a set with no conditions. @@ -237,7 +239,7 @@ func TestResultCount(t *testing.T) { // Counting all the matching rows. if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -253,13 +255,13 @@ func TestResultFetch(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Dumping into a map. @@ -282,7 +284,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -311,7 +313,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -340,7 +342,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -351,7 +353,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find().Select("id() as id", "name") if err = res.All(&all_rows_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_m) != 3 { @@ -373,7 +375,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find().Select("id() as id", "name") if err = res.All(&all_rows_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_s) != 3 { @@ -395,7 +397,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find().Select("id() as id", "name") if err = res.All(&all_rows_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_t) != 3 { @@ -416,13 +418,13 @@ func TestUpdate(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining destination struct @@ -435,7 +437,7 @@ func TestUpdate(t *testing.T) { res := artist.Find(db.Cond{"id() !=": 0}).Limit(1) if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating set with a map @@ -444,12 +446,12 @@ func TestUpdate(t *testing.T) { } if err = res.Update(row_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying. @@ -463,12 +465,12 @@ func TestUpdate(t *testing.T) { }{strings.ToLower(value.Name)} if err = res.Update(row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -482,12 +484,12 @@ func TestUpdate(t *testing.T) { }{strings.Replace(value.Name, "z", "Z", -1)} if err = res.Update(row_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -505,13 +507,13 @@ func TestFunction(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -522,11 +524,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id() NOT IN": []int{0, -1}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -536,11 +538,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id()": db.Func{"NOT IN", []int{0, -1}}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -558,13 +560,13 @@ func TestRemove(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -572,7 +574,7 @@ func TestRemove(t *testing.T) { // Trying to remove the row. if err = res.Remove(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -605,56 +607,56 @@ func TestRawRelations(t *testing.T) { } if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Artist collection. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = artist.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Publication collection. if publication, err = sess.Collection("publication"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = publication.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Review collection. if review, err = sess.Collection("review"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = review.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some artists. var miyazakiId interface{} miyazaki := artist_t{Name: `Hayao Miyazaki`} if miyazakiId, err = artist.Append(miyazaki); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } miyazaki.Id = miyazakiId.(int64) var asimovId interface{} asimov := artist_t{Name: `Isaac Asimov`} if asimovId, err = artist.Append(asimov); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } var marquezId interface{} marquez := artist_t{Name: `Gabriel GarcÃa Márquez`} if marquezId, err = artist.Append(marquez); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some publications. @@ -699,7 +701,7 @@ func TestRawRelations(t *testing.T) { AuthorId: asimovId.(int64), }) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } publication.Append(publication_t{ @@ -728,7 +730,7 @@ func TestRawRelations(t *testing.T) { // Exec'ing a raw query. var artistPublication db.Collection if artistPublication, err = sess.Collection(`artist AS a, publication AS p`); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } res := artistPublication.Find( @@ -748,7 +750,7 @@ func TestRawRelations(t *testing.T) { all := []artistPublication_t{} if err = res.All(&all); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all) != 9 { @@ -773,31 +775,31 @@ func TestDataTypes(t *testing.T) { var exists uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Getting a pointer to the "data_types" collection. if dataTypes, err = sess.Collection("data_types"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Removing all data. if err = dataTypes.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending our test subject. if id, err = dataTypes.Append(testValues); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining our set. res = dataTypes.Find(db.Cond{"id": id}) if exists, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -829,7 +831,7 @@ func BenchmarkAppendRawSQL(b *testing.B) { var sess db.Database if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -837,13 +839,13 @@ func BenchmarkAppendRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if _, err = driver.Exec("TRUNCATE TABLE artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = driver.Exec("INSERT INTO artist (name) VALUES('Hayao Miyazaki')"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -857,7 +859,7 @@ func BenchmarkAppendUpper(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -872,7 +874,7 @@ func BenchmarkAppendUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -887,7 +889,7 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { var tx *sql.Tx if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -895,22 +897,22 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if tx, err = driver.Begin(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if _, err = tx.Exec("TRUNCATE TABLE artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = tx.Exec("INSERT INTO artist (name) VALUES('Hayao Miyazaki')"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -920,23 +922,23 @@ func BenchmarkAppendTxUpper(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := struct { @@ -946,12 +948,12 @@ func BenchmarkAppendTxUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -961,23 +963,23 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := map[string]string{"name": "Hayao Miyazaki"} @@ -985,12 +987,12 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } */ diff --git a/ql/result.go b/ql/result.go index 97fe1a2491456c59908d7b3c747be7716096a083..a9548f5a721e4236c44d2492e6cb499a46fa9581 100644 --- a/ql/result.go +++ b/ql/result.go @@ -25,6 +25,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlgen" ) diff --git a/ql/util.go b/ql/util.go index 4e30684ba67d66b1ef7bfaea5e8202f307342be4..199127613ca5bf787ae0998f832486e33f05ab53 100644 --- a/ql/util.go +++ b/ql/util.go @@ -25,8 +25,9 @@ package ql import ( "database/sql" - "menteslibres.net/gosexy/to" "reflect" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util" "upper.io/db/util/sqlutil" diff --git a/sqlite/_example/main.go b/sqlite/_example/main.go index 46ec6a5dbc1a6396ac06f8ede1aaf5be5a02aea3..b24d8925a5ca03e4f2f7b76b451a18c04bf4d5a9 100644 --- a/sqlite/_example/main.go +++ b/sqlite/_example/main.go @@ -4,6 +4,7 @@ import ( "fmt" "log" "time" + "upper.io/db" // Imports the main db package. _ "upper.io/db/sqlite" // Imports the sqlite adapter. ) diff --git a/sqlite/collection.go b/sqlite/collection.go index 21250066d7b44ce4106e7c5b365116c1f985ff71..ac770f6612f7c54a34499e3ed1151fd490a3c98e 100644 --- a/sqlite/collection.go +++ b/sqlite/collection.go @@ -23,10 +23,11 @@ package sqlite import ( "fmt" - "menteslibres.net/gosexy/to" "reflect" "strings" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/sqlite/database.go b/sqlite/database.go index d05bcb0da194c17ce4e48fd9f9303cefc507a016..2a31f2e1db915a43b854ff7430d69d70a003eaa0 100644 --- a/sqlite/database.go +++ b/sqlite/database.go @@ -24,11 +24,12 @@ package sqlite import ( "database/sql" "fmt" - _ "github.com/mattn/go-sqlite3" "os" "reflect" "regexp" "strings" + + _ "github.com/mattn/go-sqlite3" "upper.io/db" "upper.io/db/util/sqlgen" "upper.io/db/util/sqlutil" diff --git a/sqlite/database_test.go b/sqlite/database_test.go index 90ef19b194f130f94da9a2e6a6862f651e3ace2f..e337eb6b4b1ce2e51e583ad2fee4019e938f121e 100644 --- a/sqlite/database_test.go +++ b/sqlite/database_test.go @@ -30,12 +30,13 @@ package sqlite import ( "database/sql" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -108,7 +109,7 @@ func TestTruncate(t *testing.T) { // Opening database. if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -116,7 +117,7 @@ func TestTruncate(t *testing.T) { // Getting a list of all collections in this database. if collections, err = sess.Collections(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(collections) == 0 { @@ -128,14 +129,14 @@ func TestTruncate(t *testing.T) { // Getting a collection. if col, err = sess.Collection(name); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Table must exists before we can use it. if col.Exists() == true { // Truncating the table. if err = col.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } } @@ -150,13 +151,13 @@ func TestAppend(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Attempt to append a map. @@ -165,7 +166,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -180,7 +181,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -195,7 +196,7 @@ func TestAppend(t *testing.T) { } if id, err = artist.Append(item_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if to.Int64(id) == 0 { @@ -204,7 +205,7 @@ func TestAppend(t *testing.T) { // Counting elements, must be exactly 3 elements. if total, err = artist.Find().Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -222,14 +223,14 @@ func TestResultCount(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // We should close the database when it's no longer in use. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining a set with no conditions. @@ -237,7 +238,7 @@ func TestResultCount(t *testing.T) { // Counting all the matching rows. if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -253,13 +254,13 @@ func TestResultFetch(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Dumping into a map. @@ -282,7 +283,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -311,7 +312,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -340,7 +341,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -351,7 +352,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_m) != 3 { @@ -373,7 +374,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_s) != 3 { @@ -395,7 +396,7 @@ func TestResultFetch(t *testing.T) { res = artist.Find() if err = res.All(&all_rows_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all_rows_t) != 3 { @@ -416,13 +417,13 @@ func TestUpdate(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining destination struct @@ -435,7 +436,7 @@ func TestUpdate(t *testing.T) { res := artist.Find(db.Cond{"id !=": 0}).Limit(1) if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating set with a map @@ -444,12 +445,12 @@ func TestUpdate(t *testing.T) { } if err = res.Update(row_m); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying. @@ -463,12 +464,12 @@ func TestUpdate(t *testing.T) { }{strings.ToLower(value.Name)} if err = res.Update(row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -482,12 +483,12 @@ func TestUpdate(t *testing.T) { }{strings.Replace(value.Name, "z", "Z", -1)} if err = res.Update(row_t); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Pulling it again. if err = res.One(&value); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Verifying @@ -505,13 +506,13 @@ func TestFunction(t *testing.T) { var total uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -522,11 +523,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id NOT IN": []int{0, -1}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -536,11 +537,11 @@ func TestFunction(t *testing.T) { res = artist.Find(db.Cond{"id": db.Func{"NOT IN", []int{0, -1}}}) if err = res.One(&row_s); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total != 3 { @@ -558,13 +559,13 @@ func TestRemove(t *testing.T) { var artist db.Collection if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -572,7 +573,7 @@ func TestRemove(t *testing.T) { // Trying to remove the row. if err = res.Remove(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -605,56 +606,56 @@ func TestRawRelations(t *testing.T) { } if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Artist collection. if artist, err = sess.Collection("artist"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = artist.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Publication collection. if publication, err = sess.Collection("publication"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = publication.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Review collection. if review, err = sess.Collection("review"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if err = review.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some artists. var miyazakiId interface{} miyazaki := artist_t{Name: `Hayao Miyazaki`} if miyazakiId, err = artist.Append(miyazaki); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } miyazaki.Id = miyazakiId.(int64) var asimovId interface{} asimov := artist_t{Name: `Isaac Asimov`} if asimovId, err = artist.Append(asimov); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } var marquezId interface{} marquez := artist_t{Name: `Gabriel GarcÃa Márquez`} if marquezId, err = artist.Append(marquez); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Adding some publications. @@ -699,7 +700,7 @@ func TestRawRelations(t *testing.T) { AuthorId: asimovId.(int64), }) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } publication.Append(publication_t{ @@ -725,7 +726,7 @@ func TestRawRelations(t *testing.T) { // Exec'ing a raw query. var artistPublication db.Collection if artistPublication, err = sess.Collection(`artist AS a, publication AS p`); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } res := artistPublication.Find( @@ -745,7 +746,7 @@ func TestRawRelations(t *testing.T) { all := []artistPublication_t{} if err = res.All(&all); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if len(all) != 9 { @@ -766,31 +767,31 @@ func TestDataTypes(t *testing.T) { var exists uint64 if sess, err = db.Open(Adapter, settings); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() // Getting a pointer to the "data_types" collection. if dataTypes, err = sess.Collection("data_types"); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Removing all data. if err = dataTypes.Truncate(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending our test subject. if id, err = dataTypes.Append(testValues); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Defining our set. res = dataTypes.Find(db.Cond{"id": id}) if exists, err = res.Count(); err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -819,7 +820,7 @@ func BenchmarkAppendRawSQL(b *testing.B) { var sess db.Database if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -827,13 +828,13 @@ func BenchmarkAppendRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if _, err = driver.Exec(`DELETE FROM "artist"`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = driver.Exec(`INSERT INTO "artist" ("name") VALUES('Hayao Miyazaki')`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -846,7 +847,7 @@ func BenchmarkAppendUpper(b *testing.B) { sess, err := db.Open(Adapter, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -861,7 +862,7 @@ func BenchmarkAppendUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -873,7 +874,7 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { var tx *sql.Tx if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -881,22 +882,22 @@ func BenchmarkAppendTxRawSQL(b *testing.B) { driver := sess.Driver().(*sql.DB) if tx, err = driver.Begin(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if _, err = tx.Exec(`DELETE FROM "artist"`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = tx.Exec(`INSERT INTO "artist" ("name") VALUES('Hayao Miyazaki')`); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -906,23 +907,23 @@ func BenchmarkAppendTxUpper(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := struct { @@ -932,12 +933,12 @@ func BenchmarkAppendTxUpper(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -947,23 +948,23 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { var err error if sess, err = db.Open(Adapter, settings); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() var tx db.Tx if tx, err = sess.Transaction(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } var artist db.Collection if artist, err = tx.Collection("artist"); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } if err = artist.Truncate(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } item := map[string]string{"name": "Hayao Miyazaki"} @@ -971,11 +972,11 @@ func BenchmarkAppendTxUpperMap(b *testing.B) { b.ResetTimer() for i := 0; i < b.N; i++ { if _, err = artist.Append(item); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } if err = tx.Commit(); err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } diff --git a/sqlite/result.go b/sqlite/result.go index f314942c90929d06e8f35094c1808f21af3cbc95..0c2fc850bc95ced169c0d96ad6e101b84f1b09ae 100644 --- a/sqlite/result.go +++ b/sqlite/result.go @@ -25,6 +25,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlgen" ) diff --git a/util/main.go b/util/main.go index 652f7c8d660a7ac9a5d85bca5126a05854dd2d5a..8ba186be49d13f76b76696385577381b91031606 100644 --- a/util/main.go +++ b/util/main.go @@ -24,11 +24,12 @@ package util import ( - "menteslibres.net/gosexy/to" "reflect" "regexp" "strings" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) diff --git a/util/sqlutil/main.go b/util/sqlutil/main.go index d20eabd55aadc109feda78e8994ecef53efd0fe6..85505cf685c18f805745329a300e3e275f5d97e9 100644 --- a/util/sqlutil/main.go +++ b/util/sqlutil/main.go @@ -27,10 +27,11 @@ import ( "database/sql" "fmt" "log" - "menteslibres.net/gosexy/to" "reflect" "regexp" "strings" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util" )