如何通过Content Provider检查SQLite数据库中是否存在指定记录

嘿，这个需求太常见了——做数据同步时避免重复插入绝对是核心环节。咱们就围绕你提到的那个以w开头的唯一id来做文章，把检查逻辑整合到Content Provider里就行，要么在插入时自动校验，要么提供单独方法供外部主动调用。下面给你具体的实现方案：

首先在创建SQLite表的时候，给那个唯一id字段加上UNIQUE约束，就算后续代码有疏漏，数据库层面也会拦截重复插入，相当于多一层保险：

CREATE TABLE IF NOT EXISTS projects (
    _id INTEGER PRIMARY KEY AUTOINCREMENT,
    project_id TEXT UNIQUE NOT NULL, -- 就是你说的w开头的唯一标识
    title TEXT,
    -- 其他业务字段...
);

最省心的方式是重写Content Provider的insert方法，执行插入前先查一遍数据库，存在就返回已有的记录URI，不存在再执行插入：

@Override
public Uri insert(Uri uri, ContentValues values) {
    final SQLiteDatabase db = mOpenHelper.getWritableDatabase();
    Uri returnUri;

    switch (sUriMatcher.match(uri)) {
        case PROJECTS:
            // 提取要插入的项目唯一ID
            String targetProjectId = values.getAsString(ProjectContract.ProjectEntry.COLUMN_PROJECT_ID);
            
            // 轻量查询：只判断是否存在，不需要返回全量数据
            Cursor existCursor = db.query(
                ProjectContract.ProjectEntry.TABLE_NAME,
                new String[]{ProjectContract.ProjectEntry._ID}, // 只查主键就行
                ProjectContract.ProjectEntry.COLUMN_PROJECT_ID + " = ?",
                new String[]{targetProjectId},
                null,
                null,
                null,
                "1" // 限制只返回1条，提升查询效率
            );

            try {
                if (existCursor.moveToFirst()) {
                    // 记录已存在，返回已有记录的URI
                    long existingId = existCursor.getLong(existCursor.getColumnIndex(ProjectContract.ProjectEntry._ID));
                    returnUri = ContentUris.withAppendedId(ProjectContract.ProjectEntry.CONTENT_URI, existingId);
                } else {
                    // 记录不存在，执行插入
                    long newId = db.insert(ProjectContract.ProjectEntry.TABLE_NAME, null, values);
                    if (newId > 0) {
                        returnUri = ContentUris.withAppendedId(ProjectContract.ProjectEntry.CONTENT_URI, newId);
                    } else {
                        throw new SQLException("Failed to insert row into " + uri);
                    }
                }
            } finally {
                existCursor.close(); // 务必关闭Cursor，避免内存泄漏
            }
            break;
        default:
            throw new IllegalArgumentException("Unknown URI: " + uri);
    }

    // 通知数据变化，触发UI更新
    getContext().getContentResolver().notifyChange(uri, null);
    return returnUri;
}

如果有时候你需要在插入前主动判断记录是否存在，可以在Content Provider里加个静态方法，或者通过自定义URI触发检查：

方式一：静态工具方法（直接用ContentResolver调用） #

public static boolean isProjectExists(ContentResolver resolver, String projectId) {
    Cursor checkCursor = resolver.query(
        ProjectContract.ProjectEntry.CONTENT_URI,
        new String[]{"1"}, // 只需要判断存在性，随便查个字段就行
        ProjectContract.ProjectEntry.COLUMN_PROJECT_ID + " = ?",
        new String[]{projectId},
        null,
        null,
        "1"
    );

    boolean exists = false;
    if (checkCursor != null) {
        exists = checkCursor.moveToFirst();
        checkCursor.close();
    }
    return exists;
}

方式二：自定义URI通过query方法返回结果 #

先给UriMatcher加个匹配规则：

private static final int PROJECT_EXISTS = 101;

static {
    sUriMatcher.addURI(ProjectContract.CONTENT_AUTHORITY, ProjectContract.PATH_PROJECTS + "/exists", PROJECT_EXISTS);
}

然后在query方法里处理这个URI：

@Override
public Cursor query(Uri uri, String[] projection, String selection, String[] selectionArgs, String sortOrder) {
    SQLiteDatabase db = mOpenHelper.getReadableDatabase();
    Cursor cursor;

    switch (sUriMatcher.match(uri)) {
        case PROJECT_EXISTS:
            String targetId = selectionArgs[0];
            cursor = db.query(
                ProjectContract.ProjectEntry.TABLE_NAME,
                new String[]{"1"},
                ProjectContract.ProjectEntry.COLUMN_PROJECT_ID + " = ?",
                new String[]{targetId},
                null,
                null,
                null,
                "1"
            );
            break;
        // 其他case逻辑...
        default:
            throw new IllegalArgumentException("Unknown URI: " + uri);
    }

    cursor.setNotificationUri(getContext().getContentResolver(), uri);
    return cursor;
}

外部调用时：

Cursor checkCursor = getContentResolver().query(
    Uri.parse("content://com.your.app.provider/projects/exists"),
    null,
    null,
    new String[]{targetProjectId},
    null
);
boolean isExists = checkCursor != null && checkCursor.moveToFirst();
checkCursor.close();

• 性能优化：查询时只判断存在性，不要返回全量字段，并且限制返回1条记录，减少IO开销。
• 线程安全：如果是多线程环境下操作，建议用SQLite事务或者加同步锁，避免并发插入导致的重复。
• 通知更新：不管是插入新记录还是返回已有记录，都要调用notifyChange，确保UI能及时感知数据变化。

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