add syntax err

Author: elianddb

sql/rowexec/binlog.go

@@ -98,6 +98,10 @@ func binlogSessClearTableMaps() {
 // not in ha_write_row().
 // See https://github.com/MariaDB/server/blob/mariadb-11.4.8/sql/sql_binlog.cc#L267-L428
 func (b *BaseBuilder) buildBinlog(ctx *sql.Context, n *plan.Binlog, row sql.Row) (sql.RowIter, error) {
+	if n.Base64Str == "" {
+		return nil, sql.ErrSyntaxError.New("BINLOG")
+	}
+
 	var decoded []byte
 
 	lines := strings.Split(n.Base64Str, "\n")

sql/rowexec/binlog_test.go

@@ -17,7 +17,6 @@ package rowexec
 import (
 	"encoding/base64"
 	"encoding/binary"
-	"io"
 	"testing"
 
 	"github.com/dolthub/go-mysql-server/memory"
@@ -53,13 +52,9 @@ func TestBuildBinlog_EmptyString(t *testing.T) {
 
 	binlogNode := plan.NewBinlog("", catalog)
 
-	iter, err := builder.buildBinlog(ctx, binlogNode, nil)
-	require.NoError(t, err)
-	require.NotNil(t, iter)
-
-	row, err := iter.Next(ctx)
-	require.Equal(t, io.EOF, err)
-	require.Nil(t, row)
+	_, err := builder.buildBinlog(ctx, binlogNode, nil)
+	require.Error(t, err)
+	require.True(t, sql.ErrSyntaxError.Is(err))
 }
 
 func TestBuildBinlog_IncompleteEventHeader(t *testing.T) {