diff --git a/pkg/datasource/sql/driver.go b/pkg/datasource/sql/driver.go index 6ce0b703b..04b79b33b 100644 --- a/pkg/datasource/sql/driver.go +++ b/pkg/datasource/sql/driver.go @@ -111,7 +111,7 @@ func (d *seataDriver) Open(name string) (driver.Conn, error) { } func (d *seataDriver) OpenConnector(name string) (c driver.Connector, err error) { - c = &dsnConnector{dsn: name, driver: d} + c = &dsnConnector{dsn: name, driver: d.target} if driverCtx, ok := d.target.(driver.DriverContext); ok { c, err = driverCtx.OpenConnector(name) if err != nil {