@@ -39,11 +39,17 @@ func (s *MysqlTestSuite) TestExample() {
3939
4040 rdr , err := reader .Connect (reader.ConnOpts {DSN : readDSN , Timeout : s .timeout })
4141 s .Require ().NoError (err , "Unable to create reader" )
42- defer rdr .Close ()
42+ defer func () {
43+ err := rdr .Close ()
44+ s .Assert ().NoError (err )
45+ }()
4346
4447 dmp , err := dumper .NewDumper (dumper.ConnOpts {DSN : dumpDSN }, rdr )
4548 s .Require ().NoError (err , "Unable to create dumper" )
46- defer dmp .Close ()
49+ defer func () {
50+ err := dmp .Close ()
51+ s .Assert ().NoError (err )
52+ }()
4753
4854 done := make (chan struct {})
4955 defer close (done )
@@ -75,7 +81,8 @@ func (s *MysqlTestSuite) TearDownSuite() {
7581 s .dropDatabase (db )
7682 }
7783
78- s .rootConnection .Close ()
84+ err := s .rootConnection .Close ()
85+ s .Assert ().NoError (err )
7986}
8087
8188func (s * MysqlTestSuite ) createDatabase (name string ) string {
@@ -102,7 +109,10 @@ func (s *MysqlTestSuite) loadFixture(dsn string, file string) {
102109 s .Require ().NoError (err , "Unable to load fixture file" )
103110
104111 conn , err := sql .Open ("mysql" , dsn )
105- defer conn .Close ()
112+ defer func () {
113+ err := conn .Close ()
114+ s .Assert ().NoError (err )
115+ }()
106116 s .Require ().NoError (err , "Unable to open db connection to load fixture" )
107117
108118 _ , err = conn .Exec (string (data ))
@@ -112,11 +122,17 @@ func (s *MysqlTestSuite) loadFixture(dsn string, file string) {
112122func (s * MysqlTestSuite ) assertDatabaseAreTheSame (expectedDSN string , dumpDSN string ) {
113123 sourceConn , err := sql .Open ("mysql" , expectedDSN )
114124 s .Require ().NoError (err , "Unable to connect to source db" )
115- defer sourceConn .Close ()
125+ defer func () {
126+ err := sourceConn .Close ()
127+ s .Assert ().NoError (err )
128+ }()
116129
117130 targetConn , err := sql .Open ("mysql" , dumpDSN )
118131 s .Require ().NoError (err , "Unable to connect to target db" )
119- defer targetConn .Close ()
132+ defer func () {
133+ err := targetConn .Close ()
134+ s .Assert ().NoError (err )
135+ }()
120136
121137 tables := s .fetchTableRowCount (sourceConn )
122138 s .Require ().Equal (tables , s .fetchTableRowCount (targetConn ))
@@ -142,7 +158,7 @@ func (s *MysqlTestSuite) fetchTableRowCount(db *sql.DB) []tableInfo {
142158 s .Require ().NoError (err , "Unable to fetch table info" )
143159 defer tableRows .Close ()
144160
145- tables := []tableInfo {}
161+ var tables []tableInfo
146162 for tableRows .Next () {
147163 table := tableInfo {}
148164
@@ -163,11 +179,17 @@ func (s *MysqlTestSuite) compareTable(source *sql.DB, target *sql.DB, table stri
163179
164180 expectedRows , err := source .Query (query )
165181 assert .NoError (err , "Unable to query source table" )
166- defer expectedRows .Close ()
182+ defer func () {
183+ err := expectedRows .Close ()
184+ s .Assert ().NoError (err )
185+ }()
167186
168187 rows , err := target .Query (query )
169188 assert .NoError (err , "Unable to query target table" )
170- defer rows .Close ()
189+ defer func () {
190+ err := rows .Close ()
191+ s .Assert ().NoError (err )
192+ }()
171193
172194 for expectedRows .Next () {
173195 assert .True (rows .Next (), "target row mismatch" )
0 commit comments