Skip to content

Commit

Permalink
Use performance_schema.session_connect_attrs in test
Browse files Browse the repository at this point in the history
  • Loading branch information
Vasfed committed Jun 18, 2018
1 parent 7038d92 commit 151e4dc
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions driver_test.go
Expand Up @@ -2096,10 +2096,10 @@ func TestConnectAttrs(t *testing.T) {
dbt.Error("no data in processlist")
}

rows, err = dbt.db.Query("select attr_value from performance_schema.session_account_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='program_name'")
rows, err = dbt.db.Query("select attr_value from performance_schema.session_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='program_name'")
if err != nil {
fmt.Println(err)
dbt.Skip("server probably does not support performance_schema.session_account_connect_attrs")
dbt.Skip("server probably does not support performance_schema.session_connect_attrs")
}

if rows.Next() {
Expand All @@ -2112,7 +2112,7 @@ func TestConnectAttrs(t *testing.T) {
dbt.Error("no data for program_name")
}

rows = dbt.mustQuery("select attr_value from performance_schema.session_account_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='foo'")
rows = dbt.mustQuery("select attr_value from performance_schema.session_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='foo'")
if rows.Next() {
var str string
rows.Scan(&str)
Expand Down

0 comments on commit 151e4dc

Please sign in to comment.