add connection reset and fix test log msgs

Author: asmyasnikov

internal/xsql/conn.go

@@ -80,6 +80,7 @@ var (
 	_ driver.QueryerContext     = &conn{}
 	_ driver.Pinger             = &conn{}
 	_ driver.NamedValueChecker  = &conn{}
+	_ driver.SessionResetter    = &conn{}
 )
 
 func newConn(c *Connector, s table.ClosableSession, opts ...connOption) *conn {
@@ -343,3 +344,13 @@ func (c *conn) BeginTx(ctx context.Context, txOptions driver.TxOptions) (_ drive
 	}
 	return c.currentTx, nil
 }
+
+func (c *conn) ResetSession(ctx context.Context) error {
+	if c.currentTx != nil {
+		_ = c.currentTx.Rollback()
+	}
+	if c.isClosed() {
+		return errClosedConn
+	}
+	return nil
+}

sql_e2e_test.go

@@ -163,7 +163,7 @@ func TestDatabaseSql(t *testing.T) {
 			return nil
 		}, retry.WithDoTxRetryOptions(retry.WithIdempotent(true)))
 		if err != nil {
-			t.Fatalf("begin tx failed: %v\n", err)
+			t.Fatalf("do tx failed: %v\n", err)
 		}
 		err = retry.DoTx(ctx, db,
 			func(ctx context.Context, tx *sql.Tx) error {
@@ -198,7 +198,7 @@ func TestDatabaseSql(t *testing.T) {
 			}),
 		)
 		if err != nil {
-			t.Fatalf("begin tx failed: %v\n", err)
+			t.Fatalf("do tx failed: %v\n", err)
 		}
 	})
 }