From 1de16d3cae8fa13a39cee9fe7197b5a472cb4d72 Mon Sep 17 00:00:00 2001 From: Dennis Hermsmeier Date: Fri, 14 Feb 2025 13:20:43 +0100 Subject: [PATCH] may fix things --- test/pkg/source/mysqltest/mysql_test.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/test/pkg/source/mysqltest/mysql_test.go b/test/pkg/source/mysqltest/mysql_test.go index eefdc20..d320fd7 100644 --- a/test/pkg/source/mysqltest/mysql_test.go +++ b/test/pkg/source/mysqltest/mysql_test.go @@ -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) @@ -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")