Skip to content

Commit

Permalink
may fix things
Browse files Browse the repository at this point in the history
  • Loading branch information
Hermsi1337 committed Feb 14, 2025
1 parent a0a5933 commit 1de16d3
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions test/pkg/source/mysqltest/mysql_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -317,7 +317,7 @@ func mySQLDoRestore(

// establish connection for retrieving restored data
restoreConnectionString := fmt.Sprintf(
"%s:%s@tcp(%s:%s)/%s?tls=skip-verify",
"%s:%s@tcp(%s:%s)/%s?tls=false",
mySQLRoot, mySQLRootPW, mySQLRestoreTarget.Address, mySQLRestoreTarget.Port, mySQLDatabase,
)
dbRestore, dbRestoreConnection := sql.Open(dbDriver, restoreConnectionString)
Expand All @@ -332,10 +332,9 @@ func mySQLDoRestore(
}()

// attempt to retrieve test data from database
var result *sql.Rows
result, err = dbRestore.Query(fmt.Sprintf("SELECT * FROM %s", tableName))
if err != nil {
return []TestStruct{}, err
result, queryErr := dbRestore.Query(fmt.Sprintf("SELECT * FROM %s", tableName))
if queryErr != nil {
return []TestStruct{}, errors.Wrap(queryErr, "failed to query mysql restore container")
}
if result.Err() != nil {
return []TestStruct{}, errors.Wrap(result.Err(), "failed to query mysql restore container")
Expand Down

0 comments on commit 1de16d3

Please sign in to comment.