[bug](prepared statement) fix prepared statement throw exception when…

… inserting null value (#36426)

## Proposed changes

Issue Number: close #xxx

When inserting a null value using jdbc prepared statement, Fe reports
the following error:

```
2024-06-18 00:01:41,381 WARN (mysql-nio-pool-0|287) [StmtExecutor.analyze():1336] Analyze failed. stmt[38, 857b9a4c512f48b5-89ee68afc32f1828]
java.lang.IllegalStateException: null
        at com.google.common.base.Preconditions.checkState(Preconditions.java:496) ~[guava-32.1.2-jre.jar:?]
        at org.apache.doris.analysis.Analyzer.materializeSlots(Analyzer.java:2624) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.planner.SingleNodePlanner.createSingleNodePlan(SingleNodePlanner.java:178) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.planner.OriginalPlanner.createPlanFragments(OriginalPlanner.java:171) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.planner.OriginalPlanner.plan(OriginalPlanner.java:102) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.StmtExecutor.analyzeAndGenerateQueryPlan(StmtExecutor.java:1512) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.StmtExecutor.analyze(StmtExecutor.java:1298) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.StmtExecutor.executeByLegacy(StmtExecutor.java:930) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:618) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.StmtExecutor.execute(StmtExecutor.java:536) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.MysqlConnectProcessor.handleExecute(MysqlConnectProcessor.java:137) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.MysqlConnectProcessor.handleExecute(MysqlConnectProcessor.java:231) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.MysqlConnectProcessor.dispatch(MysqlConnectProcessor.java:288) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.qe.MysqlConnectProcessor.processOnce(MysqlConnectProcessor.java:339) ~[doris-fe.jar:1.2-SNAPSHOT]
        at org.apache.doris.mysql.ReadListener.lambda$handleEvent$0(ReadListener.java:52) ~[doris-fe.jar:1.2-SNAPSHOT]
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
        at java.lang.Thread.run(Thread.java:840) ~[?:?]
```

<!--Describe your changes.-->

fe/fe-core/src/main/java/org/apache/doris/analysis/PlaceHolderExpr.java

@@ -58,6 +58,20 @@ public void setLiteral(LiteralExpr literal) {
         this.type = literal.getType();
     }
 
+    public LiteralExpr getLiteral() {
+        return lExpr;
+    }
+
+    @Override
+    protected void analysisDone() {
+        if (lExpr != null && !lExpr.isAnalyzed) {
+            lExpr.analysisDone();
+        }
+        if (!isAnalyzed) {
+            super.analysisDone();
+        }
+    }
+
     public LiteralExpr createLiteralFromType() throws AnalysisException {
         Preconditions.checkState(mysqlTypeCode > 0);
         return LiteralExpr.getLiteralByMysqlType(mysqlTypeCode, isUnsigned());
@@ -134,11 +148,6 @@ public String toDigestImpl() {
         return "?";
     }
 
-    @Override
-    protected Expr uncheckedCastTo(Type targetType) throws AnalysisException {
-        return this.lExpr.uncheckedCastTo(targetType);
-    }
-
     // Swaps the sign of numeric literals.
     // Throws for non-numeric literals.
     public void swapSign() throws NotImplementedException {

fe/fe-core/src/main/java/org/apache/doris/analysis/PrepareStmt.java

@@ -268,6 +268,7 @@ public void asignValues(List<LiteralExpr> values) throws UserException {
         }
         for (int i = 0; i < values.size(); ++i) {
             inner.getPlaceHolders().get(i).setLiteral(values.get(i));
+            inner.getPlaceHolders().get(i).analysisDone();
         }
         if (!values.isEmpty()) {
             if (LOG.isDebugEnabled()) {

fe/fe-core/src/main/java/org/apache/doris/planner/ScanNode.java

@@ -29,6 +29,7 @@
 import org.apache.doris.analysis.IsNullPredicate;
 import org.apache.doris.analysis.LiteralExpr;
 import org.apache.doris.analysis.NullLiteral;
+import org.apache.doris.analysis.PlaceHolderExpr;
 import org.apache.doris.analysis.PredicateUtils;
 import org.apache.doris.analysis.SlotDescriptor;
 import org.apache.doris.analysis.SlotId;
@@ -407,7 +408,8 @@ private PartitionColumnFilter createPartitionFilter(SlotDescriptor desc, List<Ex
                 if (null == partitionColumnFilter) {
                     partitionColumnFilter = new PartitionColumnFilter();
                 }
-                LiteralExpr literal = (LiteralExpr) slotBinding;
+                LiteralExpr literal = slotBinding instanceof PlaceHolderExpr
+                        ? ((PlaceHolderExpr) slotBinding).getLiteral() : (LiteralExpr) slotBinding;
                 BinaryPredicate.Operator op = binPredicate.getOp();
                 if (!binPredicate.slotIsLeft()) {
                     op = op.commutative();

fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteInPredicateRule.java

@@ -23,6 +23,7 @@
 import org.apache.doris.analysis.Expr;
 import org.apache.doris.analysis.InPredicate;
 import org.apache.doris.analysis.LiteralExpr;
+import org.apache.doris.analysis.PlaceHolderExpr;
 import org.apache.doris.analysis.SlotRef;
 import org.apache.doris.analysis.Subquery;
 import org.apache.doris.catalog.Type;
@@ -114,7 +115,11 @@ public Expr apply(Expr expr, Analyzer analyzer, ClauseType clauseType) throws An
                 //   For example, 2.1 is converted to 2;
                 // 3. childExpr is precisely converted to column type. For example, 2.0 is converted to 2.
                 // In cases 1 and 2 above, childExpr should be discarded.
-                LiteralExpr newExpr = (LiteralExpr) childExpr.castTo(columnType);
+                Expr tmpExpr = childExpr.castTo(columnType);
+                if (tmpExpr instanceof CastExpr && tmpExpr.getChild(0) instanceof PlaceHolderExpr) {
+                    tmpExpr = ((PlaceHolderExpr) tmpExpr.getChild(0)).getLiteral().castTo(columnType);
+                }
+                LiteralExpr newExpr = (LiteralExpr) tmpExpr;
                 if (childExpr.compareLiteral(newExpr) == 0) {
                     isCast = true;
                     newInList.add(newExpr);

regression-test/data/insert_p0/prepare_insert.out

@@ -1,5 +1,6 @@
 -- This file is automatically generated. You should know what you did if you want to edit this
 -- !sql --
+\N	\N	\N
 1	a	90
 2	ab	91
 3	abc	92

regression-test/suites/insert_p0/prepare_insert.groovy

@@ -34,7 +34,7 @@ suite("prepare_insert") {
     sql """ DROP TABLE IF EXISTS ${tableName} """
     sql """
         CREATE TABLE ${tableName} (
-            `id` int(11) NOT NULL,
+            `id` int(11) NULL,
             `name` varchar(50) NULL,
             `score` int(11) NULL DEFAULT "-1"
         ) ENGINE=OLAP
@@ -141,6 +141,20 @@ suite("prepare_insert") {
         stmt.close()
     }
 
+    // insert with null
+    result1 = connect(user = user, password = password, url = url) {
+        def stmt = prepareStatement "insert into ${tableName} values(?, ?, ?)"
+        assertEquals(com.mysql.cj.jdbc.ServerPreparedStatement, stmt.class)
+        stmt.setNull(1, java.sql.Types.INTEGER)
+        stmt.setNull(2, java.sql.Types.VARCHAR)
+        stmt.setNull(3, java.sql.Types.INTEGER)
+        def result = stmt.execute()
+        logger.info("result: ${result}")
+        getServerInfo(stmt)
+
+        stmt.close()
+    }
+
     // insert with label
     def label = "insert_" + System.currentTimeMillis()
     result1 = connect(user = user, password = password, url = url) {
@@ -238,4 +252,4 @@ suite("prepare_insert") {
     }
 
     qt_sql """ select * from ${tableName} order by id, name, score """
-}
+}