diff --git a/main_test.go b/main_test.go index bdcdd4aee85f5badb481483d13f10223475965b0..df587e6d90747f03a41ff4206d17201a7869db00 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 e131e265693b499dfb554685bb92da35386bee0c..291a5a7d57117fb9e976763c4132082b1187405a 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 9b7ec79071cdaf8a1df4c56ad96b2951b43f886e..1a87da25a0e244e80874f1c6790ab224a2f13b8f 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 97b0af5beb2590113fc3924d20157a8012c6328b..473eda73646bf04ae36cd5d8b7b88002df7d6966 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" ) @@ -112,7 +113,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -122,7 +123,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -130,7 +131,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. @@ -141,7 +142,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -158,7 +159,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -170,7 +171,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) } } @@ -246,7 +247,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -260,7 +261,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -279,7 +280,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -288,7 +289,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -319,7 +320,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -349,7 +350,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -379,7 +380,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -392,7 +393,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 { @@ -411,7 +412,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 { @@ -430,7 +431,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 { @@ -448,7 +449,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -458,7 +459,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -473,7 +474,7 @@ func TestUpdate(t *testing.T) { err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating with a map @@ -484,13 +485,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"] { @@ -505,13 +506,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 { @@ -526,13 +527,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 { @@ -550,7 +551,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -560,7 +561,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -592,7 +593,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -602,7 +603,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. @@ -615,7 +616,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}) @@ -624,7 +625,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -638,7 +639,7 @@ func TestDataTypes(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -652,7 +653,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. @@ -661,7 +662,7 @@ func TestDataTypes(t *testing.T) { exists, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -688,7 +689,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -705,7 +706,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) } } } @@ -714,7 +715,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -726,7 +727,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) } } } @@ -735,7 +736,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -747,7 +748,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 ce2493d9886d185769b9d3a47ba963cf0efd8f62..19e372f68583980676a84f09b019c0ebb85dac75 100644 --- a/mongo/result.go +++ b/mongo/result.go @@ -25,6 +25,7 @@ package mongo import ( "errors" + "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 0d5df5f318600515b8fb56a65fd9cbbc2cea891b..d42efd8d1e75cd2b98c1afc06a9c51a110234b1a 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 cf4baea27285e57d77638d367dce17daf8e52e3f..c55a08f6ab3bcf020588937cdd5e9b722378a146 100644 --- a/mysql/collection.go +++ b/mysql/collection.go @@ -25,11 +25,12 @@ package mysql import ( "fmt" - _ "github.com/go-sql-driver/mysql" - "menteslibres.net/gosexy/to" "reflect" "strings" "time" + + _ "github.com/go-sql-driver/mysql" + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util/sqlutil" ) diff --git a/mysql/database.go b/mysql/database.go index 77eeef41d832c55dae0b5de048c2798815edbf1b..451d0a22ca68d41c2a7da4d0d7780f21e8157ce9 100644 --- a/mysql/database.go +++ b/mysql/database.go @@ -26,12 +26,13 @@ package mysql import ( "database/sql" "fmt" - _ "github.com/go-sql-driver/mysql" "log" "os" "reflect" "regexp" "strings" + + _ "github.com/go-sql-driver/mysql" "upper.io/db" ) diff --git a/mysql/database_test.go b/mysql/database_test.go index f50e1ca7ef5d404ae64fafbb904d49b70a0266ed..33c352b5759165bd9ca3c6fe31660b44ef6d7117 100644 --- a/mysql/database_test.go +++ b/mysql/database_test.go @@ -35,12 +35,13 @@ package mysql import ( "database/sql" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -122,7 +123,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -132,7 +133,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -140,7 +141,7 @@ func TestTruncate(t *testing.T) { // Pointing the collection. col, err := sess.Collection(name) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Since this is a SQL collection (table), the structure must exists before @@ -152,7 +153,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -169,7 +170,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -179,7 +180,7 @@ func TestAppend(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending a map. @@ -226,7 +227,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -240,7 +241,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -259,7 +260,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -268,7 +269,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -292,7 +293,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -322,7 +323,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) } } @@ -365,7 +366,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 { @@ -384,7 +385,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 { @@ -403,7 +404,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 { @@ -421,7 +422,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -431,7 +432,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -446,7 +447,7 @@ func TestUpdate(t *testing.T) { err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating with a map @@ -457,13 +458,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"] { @@ -478,13 +479,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 { @@ -499,13 +500,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 { @@ -523,7 +524,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -533,7 +534,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -565,7 +566,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -575,7 +576,7 @@ func TestRemove(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -585,7 +586,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -599,7 +600,7 @@ func TestDataTypes(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -613,7 +614,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. @@ -622,7 +623,7 @@ func TestDataTypes(t *testing.T) { exists, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -649,7 +650,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -663,7 +664,7 @@ func BenchmarkAppendRaw(b *testing.B) { for i := 0; i < b.N; i++ { _, err := driver.Exec(`INSERT INTO artist (name) VALUES('Hayao Miyazaki')`) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -676,7 +677,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -688,7 +689,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) } } } @@ -702,7 +703,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -712,19 +713,19 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { err = sess.Begin() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } for i := 0; i < b.N; i++ { _, err = artist.Append(map[string]string{"name": "Isaac Asimov"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } err = sess.End() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -733,7 +734,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -745,7 +746,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/mysql/result.go b/mysql/result.go index b12fbbfff038af0dc4dcf6c715a13ebc3aca217e..bed76f7b831baae7bec40f3cfc7362543babbace 100644 --- a/mysql/result.go +++ b/mysql/result.go @@ -27,6 +27,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlutil" ) diff --git a/postgresql/_example/main.go b/postgresql/_example/main.go index 32571bcf69ac0cd3e4140258f6397d934c034589..32b986fc801a6c3cf4260bd489dc024eaed917a0 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 6bca36f3cbf20d7967eb4d815848f6062aafc7d8..27181a8bea11c11006d51b318325a8dfa29f17dc 100644 --- a/postgresql/collection.go +++ b/postgresql/collection.go @@ -26,10 +26,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/sqlutil" ) diff --git a/postgresql/database.go b/postgresql/database.go index 025774876884ef3f1a36b45a1cf8724f2e940cfe..fd20a29408bd3cc223948da96bce42fe27fbbe19 100644 --- a/postgresql/database.go +++ b/postgresql/database.go @@ -26,12 +26,13 @@ package postgresql import ( "database/sql" "fmt" - _ "github.com/xiam/gopostgresql" "log" "os" "reflect" "regexp" "strings" + + _ "github.com/xiam/gopostgresql" "upper.io/db" ) diff --git a/postgresql/database_test.go b/postgresql/database_test.go index 19624f94dfe179ed47d9ef1f32c9d6f8cc943ff2..fc38327f25999699af3e96165599c05b9d619e49 100644 --- a/postgresql/database_test.go +++ b/postgresql/database_test.go @@ -35,12 +35,13 @@ package postgresql import ( "database/sql" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -122,7 +123,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -132,7 +133,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -140,7 +141,7 @@ func TestTruncate(t *testing.T) { // Pointing the collection. col, err := sess.Collection(name) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Since this is a SQL collection (table), the structure must exists before @@ -152,7 +153,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -191,7 +192,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -201,7 +202,7 @@ func TestAppend(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending a map. @@ -248,7 +249,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -262,7 +263,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -281,7 +282,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -290,7 +291,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -314,7 +315,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -344,7 +345,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -374,7 +375,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -387,7 +388,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 { @@ -406,7 +407,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 { @@ -425,7 +426,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 { @@ -443,7 +444,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -453,7 +454,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -473,13 +474,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"] { @@ -494,13 +495,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 { @@ -515,13 +516,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 { @@ -539,7 +540,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -549,7 +550,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -581,7 +582,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -591,7 +592,7 @@ func TestRemove(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -601,7 +602,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -615,7 +616,7 @@ func TestDataTypes(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -629,7 +630,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. @@ -638,7 +639,7 @@ func TestDataTypes(t *testing.T) { exists, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -665,7 +666,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -679,7 +680,7 @@ func BenchmarkAppendRaw(b *testing.B) { for i := 0; i < b.N; i++ { _, err := driver.Exec(`INSERT INTO artist (name) VALUES('Hayao Miyazaki')`) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -692,7 +693,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -704,7 +705,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) } } } @@ -718,7 +719,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -728,19 +729,19 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { err = sess.Begin() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } for i := 0; i < b.N; i++ { _, err = artist.Append(map[string]string{"name": "Isaac Asimov"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } err = sess.End() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -749,7 +750,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -761,7 +762,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/postgresql/result.go b/postgresql/result.go index 5b3a49b8a5ae2f922a11207ac221c68802ed64ef..07bb42a2e6b383a1ab9142fa59ef59d9eee0319e 100644 --- a/postgresql/result.go +++ b/postgresql/result.go @@ -27,6 +27,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlutil" ) 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 4adcc8a5776a78b71f567b7aa8bb419a60f50e1d..84c6171e986b97648e820860d2655b3847df23c0 100644 --- a/ql/collection.go +++ b/ql/collection.go @@ -27,6 +27,7 @@ import ( "fmt" "reflect" "strings" + "upper.io/db" "upper.io/db/util/sqlutil" ) diff --git a/ql/database.go b/ql/database.go index 9d4db014538bd67c174e4bc21667e5c82aade866..8f2c9508c3ba7284fe34379a0b28be6b019d5295 100644 --- a/ql/database.go +++ b/ql/database.go @@ -26,12 +26,13 @@ package ql import ( "database/sql" "fmt" - _ "github.com/cznic/ql/driver" "log" "os" "reflect" "strings" "time" + + _ "github.com/cznic/ql/driver" "upper.io/db" ) diff --git a/ql/database_test.go b/ql/database_test.go index 668a059a6a3ec0e7388a79e863f5cb67631b04b8..9771fb8339157666a0911d8af44b31174dd35b2c 100644 --- a/ql/database_test.go +++ b/ql/database_test.go @@ -35,11 +35,12 @@ package ql import ( "database/sql" - "menteslibres.net/gosexy/to" "os" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -113,7 +114,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -123,7 +124,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -131,7 +132,7 @@ func TestTruncate(t *testing.T) { // Pointing the collection. col, err := sess.Collection(name) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Since this is a SQL collection (table), the structure must exists before @@ -143,7 +144,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -160,7 +161,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -170,7 +171,7 @@ func TestAppend(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending a map. @@ -217,7 +218,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -231,7 +232,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -250,7 +251,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -259,7 +260,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -283,7 +284,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -313,7 +314,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -343,7 +344,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -356,7 +357,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 { @@ -375,7 +376,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 { @@ -394,7 +395,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 { @@ -412,7 +413,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -422,7 +423,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -437,7 +438,7 @@ func TestUpdate(t *testing.T) { err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating with a map @@ -448,13 +449,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"] { @@ -469,13 +470,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 { @@ -490,13 +491,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 { @@ -514,7 +515,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -524,7 +525,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -556,7 +557,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -566,7 +567,7 @@ func TestRemove(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -576,7 +577,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -642,7 +643,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -656,7 +657,7 @@ func BenchmarkAppendRaw(b *testing.B) { for i := 0; i < b.N; i++ { _, err := driver.Exec(`INSERT INTO artist (name) VALUES('Hayao Miyazaki')`) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -669,7 +670,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -681,7 +682,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) } } } @@ -695,7 +696,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -705,19 +706,19 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { err = sess.Begin() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } for i := 0; i < b.N; i++ { _, err = artist.Append(map[string]string{"name": "Isaac Asimov"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } err = sess.End() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -726,7 +727,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -738,7 +739,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/ql/result.go b/ql/result.go index 5ee594c26fb2190459c315cb56a90123fe756fdd..965d39ddb2eb51239835007ed8f97fda0e3653d2 100644 --- a/ql/result.go +++ b/ql/result.go @@ -27,6 +27,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlutil" ) 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 4a633e9f0b2d3742e088587c4155d7e6d4e93741..713677b839db1550694d095e64164a583d76a3e6 100644 --- a/sqlite/collection.go +++ b/sqlite/collection.go @@ -25,10 +25,11 @@ package sqlite import ( "fmt" - "menteslibres.net/gosexy/to" "reflect" "strings" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util/sqlutil" ) diff --git a/sqlite/database_test.go b/sqlite/database_test.go index b640f832b7fb2056e864933f1d282a0d102cfb67..364817b2ffa38c4e8a355fb4abe19f0a6c4bc61c 100644 --- a/sqlite/database_test.go +++ b/sqlite/database_test.go @@ -35,12 +35,13 @@ package sqlite import ( "database/sql" - "menteslibres.net/gosexy/to" "os" "reflect" "strings" "testing" "time" + + "menteslibres.net/gosexy/to" "upper.io/db" ) @@ -114,7 +115,7 @@ func TestTruncate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -124,7 +125,7 @@ func TestTruncate(t *testing.T) { collections, err := sess.Collections() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } for _, name := range collections { @@ -132,7 +133,7 @@ func TestTruncate(t *testing.T) { // Pointing the collection. col, err := sess.Collection(name) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Since this is a SQL collection (table), the structure must exists before @@ -144,7 +145,7 @@ func TestTruncate(t *testing.T) { err = col.Truncate() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -161,7 +162,7 @@ func TestAppend(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -171,7 +172,7 @@ func TestAppend(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Appending a map. @@ -218,7 +219,7 @@ func TestResultCount(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } defer sess.Close() @@ -232,7 +233,7 @@ func TestResultCount(t *testing.T) { total, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if total == 0 { @@ -251,7 +252,7 @@ func TestResultFetch(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -260,7 +261,7 @@ func TestResultFetch(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Testing map @@ -284,7 +285,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -314,7 +315,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -344,7 +345,7 @@ func TestResultFetch(t *testing.T) { t.Fatalf("Expecting a name.") } } else { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -357,7 +358,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 { @@ -376,7 +377,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 { @@ -395,7 +396,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 { @@ -413,7 +414,7 @@ func TestUpdate(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -423,7 +424,7 @@ func TestUpdate(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Value @@ -438,7 +439,7 @@ func TestUpdate(t *testing.T) { err = res.One(&value) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Updating with a map @@ -449,13 +450,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"] { @@ -470,13 +471,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 { @@ -491,13 +492,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 { @@ -515,7 +516,7 @@ func TestFunction(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -525,7 +526,7 @@ func TestFunction(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } row_s := struct { @@ -557,7 +558,7 @@ func TestRemove(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -567,7 +568,7 @@ func TestRemove(t *testing.T) { artist, err := sess.Collection("artist") if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // Getting the artist with id = 1 @@ -577,7 +578,7 @@ func TestRemove(t *testing.T) { err = res.Remove() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } } @@ -591,7 +592,7 @@ func TestDataTypes(t *testing.T) { sess, err := db.Open(wrapperName, settings) if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } // We should close the database when it's no longer in use. @@ -605,7 +606,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. @@ -614,7 +615,7 @@ func TestDataTypes(t *testing.T) { exists, err := res.Count() if err != nil { - t.Fatalf(err.Error()) + t.Fatal(err) } if exists == 0 { @@ -641,7 +642,7 @@ func BenchmarkAppendRaw(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -655,7 +656,7 @@ func BenchmarkAppendRaw(b *testing.B) { for i := 0; i < b.N; i++ { _, err := driver.Exec(`INSERT INTO artist (name) VALUES("Hayao Miyazaki")`) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } } @@ -668,7 +669,7 @@ func BenchmarkAppendDbItem(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -680,7 +681,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) } } } @@ -694,7 +695,7 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -704,19 +705,19 @@ func BenchmarkAppendDbItem_Transaction(b *testing.B) { err = sess.Begin() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } for i := 0; i < b.N; i++ { _, err = artist.Append(map[string]string{"name": "Isaac Asimov"}) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } err = sess.End() if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } } @@ -725,7 +726,7 @@ func BenchmarkAppendStruct(b *testing.B) { sess, err := db.Open(wrapperName, settings) if err != nil { - b.Fatalf(err.Error()) + b.Fatal(err) } defer sess.Close() @@ -737,7 +738,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/sqlite/result.go b/sqlite/result.go index 5354308b3a9ce0739dd3f48c3e20631297ece640..c62e61e8727c1b65aa50b3609c2f5bebd15b2deb 100644 --- a/sqlite/result.go +++ b/sqlite/result.go @@ -27,6 +27,7 @@ import ( "database/sql" "fmt" "strings" + "upper.io/db" "upper.io/db/util/sqlutil" ) diff --git a/util/main.go b/util/main.go index ca757a1aa75be846ebff844a2fb0ae7b91acc342..288ed97b5324abfe383cdd94459e081d73cf46b1 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 261c0d0990b316b10d3602b412f07b2eb61f143e..4a2a628f016f4032a23c9046cfe4a806fd775d21 100644 --- a/util/sqlutil/main.go +++ b/util/sqlutil/main.go @@ -25,9 +25,10 @@ package sqlutil import ( "database/sql" - "menteslibres.net/gosexy/to" "reflect" "strings" + + "menteslibres.net/gosexy/to" "upper.io/db" "upper.io/db/util" )