Load Data From S3

go/vt/sqlparser/analyzer.go

@@ -78,7 +78,7 @@ func ASTToStatementType(stmt Statement) StatementType {
  return StmtDDL
  case *Use:
  return StmtUse
- case *OtherRead, *OtherAdmin:
+ case *OtherRead, *OtherAdmin, *Load:
  return StmtOther
  case *Explain:
  return StmtExplain

go/vt/sqlparser/ast.go

@@ -242,6 +242,10 @@ type (
  // DDLAction is an enum for DDL.Action
  DDLAction int8
 
+ Load struct {
+ InfileS3 string
+ }
+
  // ParenSelect is a parenthesized SELECT statement.
  ParenSelect struct {
  Select SelectStatement
@@ -333,6 +337,7 @@ func (*OtherAdmin) iStatement() {}
 func (*Select) iSelectStatement() {}
 func (*Union) iSelectStatement() {}
 func (*ParenSelect) iSelectStatement() {}
+func (*Load) iStatement() {}
 
 // ParenSelect can actually not be a top level statement,
 // but we have to allow it because it's a requirement
@@ -2056,3 +2061,7 @@ func (node AccessMode) Format(buf *TrackedBuffer) {
  buf.WriteString(TxReadWrite)
  }
 }
+
+func (load *Load) Format(buf *TrackedBuffer) {
+ buf.WriteString("AST node missing for Load type")
+}

go/vt/sqlparser/parse_test.go

@@ -1051,6 +1051,12 @@ var (
  output: "alter database d",
  }, {
  input: "create table a",
+ }, {
+ input: "load data from s3 'x.txt'",
+ output: "AST node missing for Load type",
+ }, {
+ input: "load data from s3 'x.txt' into table x",
+ output: "AST node missing for Load type",
  }, {
  input: "create table a (\n\t`a` int\n)",
  output: "create table a (\n\ta int\n)",