diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/PlaceHolderExpr.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/PlaceHolderExpr.java
index ca0596258f6f9f..50bea1c2d5647e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/PlaceHolderExpr.java
+++ b/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 {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/PrepareStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/PrepareStmt.java
index 90da98c14f4e76..1c7b5459979be9 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/PrepareStmt.java
+++ b/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()) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/planner/ScanNode.java b/fe/fe-core/src/main/java/org/apache/doris/planner/ScanNode.java
index 9c896bd75042b3..342ec3c91490a1 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/ScanNode.java
+++ b/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();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteInPredicateRule.java b/fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteInPredicateRule.java
index c04ff432961574..3541690d002a98 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/rewrite/RewriteInPredicateRule.java
+++ b/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);
diff --git a/regression-test/data/insert_p0/prepare_insert.out b/regression-test/data/insert_p0/prepare_insert.out
index a84bd02040e236..f535890c5b88b8 100644
--- a/regression-test/data/insert_p0/prepare_insert.out
+++ b/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
diff --git a/regression-test/suites/insert_p0/prepare_insert.groovy b/regression-test/suites/insert_p0/prepare_insert.groovy
index 305758170d7a30..235adf03c1dcd7 100644
--- a/regression-test/suites/insert_p0/prepare_insert.groovy
+++ b/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 """
-}
\ No newline at end of file
+}