package androidx.room.util;

import android.database.Cursor;
import android.os.CancellationSignal;
import androidx.room.RoomDatabase;
import androidx.room.coroutines.m;
import androidx.room.s0;
import java.util.Iterator;
import kotlin.collections.builders.ListBuilder;
import sd.l;

/* JADX INFO: loaded from: classes.dex */
public abstract class b {
    public static final void a(k3.a aVar) throws Exception {
        nb.g.i(aVar, "connection");
        ListBuilder listBuilder = new ListBuilder();
        k3.c cVarJ = aVar.J("SELECT name FROM sqlite_master WHERE type = 'trigger'");
        while (cVarJ.G()) {
            try {
                listBuilder.add(cVarJ.A(0));
            } finally {
            }
        }
        ua.b.h(cVarJ, null);
        listBuilder.m();
        Iterator it = listBuilder.iterator();
        while (true) {
            ld.a aVar2 = (ld.a) it;
            if (!aVar2.hasNext()) {
                return;
            }
            String str = (String) aVar2.next();
            if (kotlin.text.h.j0(str, "room_fts_content_sync_", false)) {
                ua.b.t("DROP TRIGGER IF EXISTS ".concat(str), aVar);
            }
        }
    }

    public static final Object b(RoomDatabase roomDatabase, boolean z10, boolean z11, l lVar) {
        nb.g.i(roomDatabase, "db");
        roomDatabase.assertNotMainThread();
        roomDatabase.assertNotSuspendingTransaction();
        return m.a(new DBUtil__DBUtil_androidKt$performBlocking$1(roomDatabase, null, lVar, z11, z10));
    }

    public static final Cursor c(RoomDatabase roomDatabase, s0 s0Var) {
        nb.g.i(roomDatabase, "db");
        return roomDatabase.query(s0Var, (CancellationSignal) null);
    }
}