Support SQL Server INSERT BULK declarations

src/main/java/net/sf/jsqlparser/parser/feature/Feature.java

@@ -457,7 +457,7 @@ public enum Feature {
      */
     oracleBlock,
 
-    execute, executeExec, executeCall, executeExecute, doStatement,
+    execute, executeExec, executeCall, executeExecute, doStatement, insertBulk,
 
     /**
      * SQL "EXECUTE" statement is allowed

src/main/java/net/sf/jsqlparser/statement/StatementFeatureVisitor.java

@@ -61,6 +61,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.lock.LockStatement;
 import net.sf.jsqlparser.statement.merge.Merge;
 import net.sf.jsqlparser.statement.refresh.RefreshMaterializedViewStatement;
@@ -392,6 +393,13 @@ public <S> Void visit(Insert insert, S context) {
         return super.visit(insert, context);
     }
 
+    @Override
+    public <S> Void visit(InsertBulk statement, S context) {
+        analysis.claimTopLevel();
+        analysis.certain(StmtFeature.MODIFIES_DATA);
+        return super.visit(statement, context);
+    }
+
     @Override
     public <S> Void visit(Update update, S context) {
         boolean topLevel = analysis.claimTopLevel();

src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java

@@ -56,6 +56,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
 import net.sf.jsqlparser.statement.lock.LockStatement;
 import net.sf.jsqlparser.statement.merge.Merge;
@@ -70,6 +71,14 @@
 
 public interface StatementVisitor<T> {
 
+    default <S> T visit(InsertBulk statement, S context) {
+        return null;
+    }
+
+    default void visit(InsertBulk statement) {
+        this.visit(statement, null);
+    }
+
     <S> T visit(Analyze analyze, S context);
 
     default void visit(Analyze analyze) {

src/main/java/net/sf/jsqlparser/statement/StatementVisitorAdapter.java

@@ -62,6 +62,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.insert.InsertConflictAction;
 import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
 import net.sf.jsqlparser.statement.lock.LockStatement;
@@ -314,6 +315,13 @@ private <S> T visitReturningClause(ReturningClause returningClause, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(InsertBulk statement, S context) {
+        fromItemVisitor.visitFromItem(statement.getTable(), context);
+        statement.visitExpressions(expression -> expression.accept(expressionVisitor, context));
+        return null;
+    }
+
     @Override
     public <S> T visit(ParenthesedInsert insert, S context) {
         insert.getInsert().accept(this, context);

src/main/java/net/sf/jsqlparser/statement/insert/InsertBulk.java

@@ -0,0 +1,162 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement.insert;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.function.Consumer;
+import net.sf.jsqlparser.expression.Expression;
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.StatementVisitor;
+import net.sf.jsqlparser.statement.create.table.ColumnDefinition;
+import net.sf.jsqlparser.statement.select.OrderByElement;
+
+/** SQL Server's SQL declaration preceding a separate bulk-load data stream. */
+public class InsertBulk implements Statement {
+    private Table table;
+    private List<ColumnDefinition> columns = new ArrayList<>();
+    private List<Option> options = new ArrayList<>();
+
+    public Table getTable() {
+        return table;
+    }
+
+    public void setTable(Table table) {
+        this.table = table;
+    }
+
+    public List<ColumnDefinition> getColumns() {
+        return columns;
+    }
+
+    public void setColumns(List<ColumnDefinition> columns) {
+        this.columns = columns;
+    }
+
+    public List<Option> getOptions() {
+        return options;
+    }
+
+    public void setOptions(List<Option> options) {
+        this.options = options;
+    }
+
+    public void visitExpressions(Consumer<Expression> visitor) {
+        for (Option option : options) {
+            if (option.getValue() != null) {
+                visitor.accept(option.getValue());
+            }
+            for (OrderByElement order : option.getOrderByElements()) {
+                visitor.accept(order.getExpression());
+            }
+        }
+    }
+
+    public StringBuilder appendTo(StringBuilder builder, Consumer<Expression> expressions,
+            Consumer<OrderByElement> ordering) {
+        builder.append("INSERT BULK ").append(table).append(" (");
+        for (int i = 0; i < columns.size(); i++) {
+            if (i > 0) {
+                builder.append(", ");
+            }
+            builder.append(columns.get(i));
+        }
+        builder.append(')');
+        if (!options.isEmpty()) {
+            builder.append(" WITH (");
+            for (int i = 0; i < options.size(); i++) {
+                if (i > 0) {
+                    builder.append(", ");
+                }
+                options.get(i).appendTo(builder, expressions, ordering);
+            }
+            builder.append(')');
+        }
+        return builder;
+    }
+
+    @Override
+    public <T, S> T accept(StatementVisitor<T> visitor, S context) {
+        return visitor.visit(this, context);
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder builder = new StringBuilder();
+        return appendTo(builder, value -> builder.append(value), order -> builder.append(order))
+                .toString();
+    }
+
+    public static class Option {
+        public enum Kind {
+            CHECK_CONSTRAINTS, FIRE_TRIGGERS, KEEP_NULLS, TABLOCK, ALLOW_ENCRYPTED_VALUE_MODIFICATIONS, ROWS_PER_BATCH, ORDER
+        }
+
+        private Kind kind;
+        private Expression value;
+        private List<OrderByElement> orderByElements = new ArrayList<>();
+
+        public Option(Kind kind) {
+            this.kind = kind;
+        }
+
+        public Kind getKind() {
+            return kind;
+        }
+
+        public void setKind(Kind kind) {
+            this.kind = kind;
+        }
+
+        public Expression getValue() {
+            return value;
+        }
+
+        public void setValue(Expression value) {
+            this.value = value;
+        }
+
+        public List<OrderByElement> getOrderByElements() {
+            return orderByElements;
+        }
+
+        public void setOrderByElements(List<OrderByElement> orderByElements) {
+            this.orderByElements = orderByElements;
+        }
+
+        public StringBuilder appendTo(StringBuilder builder, Consumer<Expression> expressions,
+                Consumer<OrderByElement> ordering) {
+            builder.append(kind);
+            if (value != null) {
+                builder.append(" = ");
+                expressions.accept(value);
+            }
+            if (!orderByElements.isEmpty()) {
+                builder.append(" (");
+                for (int i = 0; i < orderByElements.size(); i++) {
+                    if (i > 0) {
+                        builder.append(", ");
+                    }
+                    ordering.accept(orderByElements.get(i));
+                }
+                builder.append(')');
+            }
+            return builder;
+        }
+
+        @Override
+        public String toString() {
+            StringBuilder builder = new StringBuilder();
+            return appendTo(builder, value -> builder.append(value), order -> builder.append(order))
+                    .toString();
+        }
+    }
+}

src/main/java/net/sf/jsqlparser/util/TablesNamesFinder.java

@@ -139,6 +139,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.insert.InsertConflictAction;
 import net.sf.jsqlparser.statement.insert.InsertDuplicateAction;
 import net.sf.jsqlparser.statement.insert.OracleMultiInsertBranch;
@@ -1571,6 +1572,13 @@ public <S> Void visit(DoStatement statement, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(InsertBulk statement, S context) {
+        visit(statement.getTable(), context);
+        statement.visitExpressions(value -> value.accept(this, context));
+        return null;
+    }
+
     @Override
     public void visit(CreateIndex createIndex) {
         StatementVisitor.super.visit(createIndex);

src/main/java/net/sf/jsqlparser/util/deparser/StatementDeParser.java

@@ -82,6 +82,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
 import net.sf.jsqlparser.statement.lock.LockStatement;
 import net.sf.jsqlparser.statement.merge.Merge;
@@ -157,6 +158,13 @@ public <S> StringBuilder visit(DoStatement statement, S context) {
         return statement.appendTo(builder, code -> code.accept(expressionDeParser, context));
     }
 
+    @Override
+    public <S> StringBuilder visit(InsertBulk statement, S context) {
+        OrderByDeParser order = new OrderByDeParser(expressionDeParser, builder);
+        return statement.appendTo(builder, value -> value.accept(expressionDeParser, context),
+                element -> order.deParseElement(element, context));
+    }
+
     @Override
     public <S> StringBuilder visit(CreateTable createTable, S context) {
         CreateTableDeParser createTableDeParser = new CreateTableDeParser(this, builder);

src/main/java/net/sf/jsqlparser/util/validation/feature/SqlServerVersion.java

@@ -60,6 +60,7 @@ public enum SqlServerVersion implements Version {
 
                     // https://docs.microsoft.com/en-us/sql/t-sql/statements/insert-transact-sql?view=sql-server-ver15
                     Feature.insert,
+                    Feature.insertBulk,
                     Feature.insertValues,
                     Feature.insertFromSelect, // https://docs.microsoft.com/en-us/sql/t-sql/queries/update-transact-sql?view=sql-server-ver15
                     Feature.update,

src/main/java/net/sf/jsqlparser/util/validation/validator/InsertBulkValidator.java

@@ -0,0 +1,31 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.util.validation.validator;
+
+import java.util.stream.Collectors;
+import net.sf.jsqlparser.parser.feature.Feature;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
+import net.sf.jsqlparser.statement.create.table.ColumnDefinition;
+import net.sf.jsqlparser.util.validation.ValidationCapability;
+import net.sf.jsqlparser.util.validation.metadata.NamedObject;
+
+public class InsertBulkValidator extends AbstractValidator<InsertBulk> {
+    @Override
+    public void validate(InsertBulk statement) {
+        validateFeature(Feature.insertBulk);
+        validateOptionalFromItem(statement.getTable());
+        for (ValidationCapability capability : getCapabilities()) {
+            validateOptionalColumnNames(capability, statement.getColumns().stream()
+                    .map(ColumnDefinition::getColumnName).collect(Collectors.toList()),
+                    NamedObject.table);
+        }
+        statement.visitExpressions(this::validateOptionalExpression);
+    }
+}

src/main/java/net/sf/jsqlparser/util/validation/validator/StatementValidator.java

@@ -83,6 +83,7 @@
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
+import net.sf.jsqlparser.statement.insert.InsertBulk;
 import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
 import net.sf.jsqlparser.statement.lock.LockStatement;
 import net.sf.jsqlparser.statement.merge.Merge;
@@ -239,6 +240,12 @@ public <S> Void visit(DoStatement statement, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(InsertBulk statement, S context) {
+        getValidator(InsertBulkValidator.class).validate(statement);
+        return null;
+    }
+
     @Override
     public <S> Void visit(SetStatement set, S context) {
         getValidator(SetStatementValidator.class).validate(set);