diff --git a/src/Storages/StorageMongoDB.cpp b/src/Storages/StorageMongoDB.cpp
index a33f17191eb..67cb7722414 100644
--- a/src/Storages/StorageMongoDB.cpp
+++ b/src/Storages/StorageMongoDB.cpp
@@ -94,8 +94,7 @@ public:
         const std::string & collection_name_,
         const std::string & db_name_,
         const StorageMetadataPtr & metadata_snapshot_,
-        std::shared_ptr<Poco::MongoDB::Connection> connection_
-        )
+        std::shared_ptr<Poco::MongoDB::Connection> connection_)
         : SinkToStorage(metadata_snapshot_->getSampleBlock())
         , collection_name(collection_name_)
         , db_name(db_name_)
@@ -108,14 +107,18 @@ public:
 
     void consume(Chunk chunk) override
     {
-        auto block = getHeader().cloneWithColumns(chunk.detachColumns());
         Poco::MongoDB::Database db(db_name);
         Poco::MongoDB::Document::Ptr index = new Poco::MongoDB::Document();
 
+        auto block = getHeader().cloneWithColumns(chunk.detachColumns());
+
+        size_t num_rows = block.rows();
+        size_t num_cols = block.columns();
+
         const auto columns = block.getColumns();
-        const size_t num_rows = block.rows(), num_cols = block.columns();
         const auto data_types = block.getDataTypes();
         const auto data_names = block.getNames();
+
         std::vector<std::string> row(num_cols);
         for (const auto i : collections::range(0, num_rows))
         {
diff --git a/tests/integration/test_storage_mongodb/test.py b/tests/integration/test_storage_mongodb/test.py
index d8ca207d0a6..1fc3e255a5b 100644
--- a/tests/integration/test_storage_mongodb/test.py
+++ b/tests/integration/test_storage_mongodb/test.py
@@ -253,3 +253,29 @@ def test_missing_columns(started_cluster):
     result = node.query("SELECT count() FROM simple_mongo_table WHERE isNull(data)")
     assert result == "10\n"
     simple_mongo_table.drop()
+
+
+@pytest.mark.parametrize("started_cluster", [False], indirect=["started_cluster"])
+def test_simple_insert_select(started_cluster):
+    mongo_connection = get_mongo_connection(started_cluster)
+    db = mongo_connection["test"]
+    db.add_user("root", "clickhouse")
+    simple_mongo_table = db["simple_table"]
+
+    node = started_cluster.instances["node"]
+    node.query(
+        "CREATE TABLE simple_mongo_table(key UInt64, data String) ENGINE = MongoDB('mongo1:27017', 'test', 'simple_table', 'root', 'clickhouse')"
+    )
+    node.query("INSERT INTO simple_mongo_table SELECT 1, 'kek'")
+
+    assert (
+        node.query("SELECT data from simple_mongo_table where key = 1").strip() == "kek"
+    )
+    node.query("INSERT INTO simple_mongo_table(key) SELECT 12")
+    assert int(node.query("SELECT count() from simple_mongo_table")) == 2
+    assert (
+        node.query("SELECT data from simple_mongo_table where key = 12").strip() == ""
+    )
+
+    node.query("DROP TABLE simple_mongo_table")
+    simple_mongo_table.drop()