Use performance_schema.session_connect_attrs in test

Vasfed · Vasfed · commit 151e4dc10539 · 2018-06-18T17:52:03.000+03:00
diff --git a/driver_test.go b/driver_test.go
@@ -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() {
@@ -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)

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