如何判断Firebase实时数据库中所有子节点均未匹配指定手机号？

一、优先用Firebase查询API（推荐） #

遍历所有子节点的方式在数据量增大后会严重影响性能，Firebase Realtime Database提供了直接的查询能力，能精准定位匹配MobileNo的节点，不用遍历全部数据。

具体实现逻辑：

• 构建查询，按MobileNo字段筛选目标手机号
• 根据查询结果判断是否存在匹配用户：
  • 存在：执行你原有的更新逻辑
  • 不存在：执行创建新用户的操作

代码示例（Kotlin）：

val targetPhone = binding.phoneNumberInput.text.toString()
// 构建查询：筛选MobileNo等于目标手机号的节点
val query = databaseReferenceUser.orderByChild("MobileNo").equalTo(targetPhone)

query.addListenerForSingleValueEvent(object : ValueEventListener {
    override fun onDataChange(snapshot: DataSnapshot) {
        if (snapshot.exists()) {
            // 找到匹配用户，执行更新逻辑
            for (ds in snapshot.children) {
                ds.child("school").child(uid!!).apply {
                    child("schoolUid").setValue(uid)
                    child("timestamp").setValue(timestamp)
                    child("userIdForSchool").setValue(idDealerFactory)
                    child("schoolName").setValue(namaPerusahaan)
                    child("schoolCode").setValue(codeFactory)
                }
            }
        } else {
            // 无匹配手机号，创建新用户
            val newUserRef = databaseReferenceUser.push() // 生成唯一用户ID
            val newUser = hashMapOf(
                "MobileNo" to targetPhone,
                "SchoolUid" to uid,
                "timestamp" to timestamp,
                "userIdForSchool" to idDealerFactory,
                "schoolName" to namaPerusahaan,
                "schoolCode" to codeFactory
                // 按需添加其他用户字段
            )
            newUserRef.setValue(newUser)
        }
    }

    override fun onCancelled(error: DatabaseError) {
        // 处理查询失败，比如打印错误日志
        error.toException().printStackTrace()
    }
})

二、如果坚持用遍历方式（不推荐） #

若一定要遍历所有子节点，确实需要手动声明布尔变量标记是否找到匹配项，遍历结束后根据变量值判断是否创建新用户：

代码示例：

val targetPhone = binding.phoneNumberInput.text.toString()
var isPhoneExists = false

databaseReferenceUser.addListenerForSingleValueEvent(object : ValueEventListener {
    override fun onDataChange(snapshot: DataSnapshot) {
        if (snapshot.exists()) {
            for (ds in snapshot.children) {
                if (ds.child("MobileNo").getValue<String>() == targetPhone) {
                    isPhoneExists = true
                    // 执行更新逻辑
                    ds.child("school").child(uid!!).apply {
                        child("schoolUid").setValue(uid)
                        child("timestamp").setValue(timestamp)
                        child("userIdForSchool").setValue(idDealerFactory)
                        child("schoolName").setValue(namaPerusahaan)
                        child("schoolCode").setValue(codeFactory)
                    }
                    // 找到匹配项后提前跳出循环，提升效率
                    break
                }
            }
        }

        // 遍历结束后判断是否创建新用户
        if (!isPhoneExists) {
            val newUserRef = databaseReferenceUser.push()
            val newUser = hashMapOf(
                "MobileNo" to targetPhone,
                "SchoolUid" to uid,
                "timestamp" to timestamp,
                "userIdForSchool" to idDealerFactory,
                "schoolName" to namaPerusahaan,
                "schoolCode" to codeFactory
            )
            newUserRef.setValue(newUser)
        }
    }

    override fun onCancelled(error: DatabaseError) {
        error.toException().printStackTrace()
    }
})

关键提醒 #

• 用查询API的方式不仅更高效，还能避免数据量过大导致的性能问题，强烈推荐使用第一种方案
• 确保已在Firebase控制台为MobileNo字段创建索引，否则查询会被拒绝（控制台会自动提示创建索引的链接，直接点击即可完成配置）

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