Use performance_schema.session_connect_attrs in test

Vasfed · Vasfed · commit 05f15c193d3d · 2018-06-16T05:00:21.000+03:00
diff --git a/driver_test.go b/driver_test.go
@@ -2093,10 +2093,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() {
@@ -2109,7 +2109,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)

Original file line number	Diff line number	Diff line change
`@@ -2093,10 +2093,10 @@ func TestConnectAttrs(t *testing.T) {`
`2093`	`2093`	`dbt.Error("no data in processlist")`
`2094`	`2094`	`}`
`2095`	`2095`
`2096`		`- 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'")`
	`2096`	`+ rows, err = dbt.db.Query("select attr_value from performance_schema.session_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='program_name'")`
`2097`	`2097`	`if err != nil {`
`2098`	`2098`	`fmt.Println(err)`
`2099`		`- dbt.Skip("server probably does not support performance_schema.session_account_connect_attrs")`
	`2099`	`+ dbt.Skip("server probably does not support performance_schema.session_connect_attrs")`
`2100`	`2100`	`}`
`2101`	`2101`
`2102`	`2102`	`if rows.Next() {`
`@@ -2109,7 +2109,7 @@ func TestConnectAttrs(t *testing.T) {`
`2109`	`2109`	`dbt.Error("no data for program_name")`
`2110`	`2110`	`}`
`2111`	`2111`
`2112`		`- rows = dbt.mustQuery("select attr_value from performance_schema.session_account_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='foo'")`
	`2112`	`+ rows = dbt.mustQuery("select attr_value from performance_schema.session_connect_attrs where processlist_id=CONNECTION_ID() and attr_name='foo'")`
`2113`	`2113`	`if rows.Next() {`
`2114`	`2114`	`var str string`
`2115`	`2115`	`rows.Scan(&str)`