Scala-Spark-Neo4j应用执行全量节点删除操作失败求助

针对你遇到的执行MATCH (n) DETACH DELETE n;无报错但节点未删除的问题，以下是具体排查和解决步骤：

1. 确认Cypher语句执行的API使用正确 #

Neo4j Spark连接器执行非写入类（如删除、查询）的Cypher语句，需要使用queryAPI而非write操作。如果误用了write模式，语句可能不会被正确执行。

正确的Scala代码示例：

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("Neo4jDeleteAllNodes")
  .config("spark.neo4j.bolt.url", "bolt://localhost:7687")
  .config("spark.neo4j.authentication.basic.username", "neo4j")
  .config("spark.neo4j.authentication.basic.password", "your-password")
  .getOrCreate()

// 执行删除所有节点的Cypher语句
import org.neo4j.spark._
val neo4j = Neo4j(spark.sparkContext)
neo4j.query("MATCH (n) DETACH DELETE n;")

spark.stop()

或者手动管理会话确保事务提交：

spark.sparkContext.parallelize(Seq(1)).foreach { _ =>
  val query = "MATCH (n) DETACH DELETE n;"
  val neo4jConfig = org.neo4j.spark.config.Neo4jConfig.fromSparkSession(spark)
  val session = org.neo4j.spark.Neo4j(neo4jConfig).session()
  try {
    session.run(query)
    session.commit()
  } finally {
    session.close()
  }
}

2. 检查数据库连接配置是否正确 #

• 确认spark.neo4j.bolt.url指向的是目标Neo4j实例，避免连接到测试环境或其他无关数据库
• 验证用户名和密码拥有删除节点/关系的权限
• 如果使用Neo4j多数据库功能，需显式指定目标数据库：

  .config("spark.neo4j.database", "your-target-db")
  

3. 验证语句执行结果 #

可以在Cypher语句中返回删除计数，确认操作是否生效：

val result = neo4j.query("MATCH (n) DETACH DELETE n RETURN count(n) as deletedCount;")
result.show()

如果返回的deletedCount为0，说明当前数据库原本无节点；如果计数大于0但数据库中仍有节点，需检查是否连接到错误的数据库实例。

4. 检查版本兼容性 #

你使用的5.0.3_for_spark_3版本需要对应：

• Spark 3.x（3.0~3.3版本均可）
• Neo4j 5.x服务器版本
  如果Neo4j服务器是4.x版本，建议降级连接器到4.4.x_for_spark_3版本，避免版本不兼容导致的隐性问题。

内容的提问来源于stack exchange，提问作者user2095071