package m6;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import java.util.Iterator;
import java.util.concurrent.ConcurrentHashMap;
import nb.g;

/* JADX INFO: loaded from: classes.dex */
public final class a extends SQLiteOpenHelper {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Context f30390a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final ConcurrentHashMap f30391b;

    /* JADX WARN: Illegal instructions before constructor call */
    public a(Context context, d dVar, l6.d dVar2) {
        StringBuilder sbD = u.a.d("events_" + dVar2.lb(), "_");
        sbD.append(g.w());
        super(context, sbD.toString(), (SQLiteDatabase.CursorFactory) null, 1);
        this.f30390a = context;
        this.f30391b = dVar.f30399c;
        setWriteAheadLoggingEnabled(dVar2.ajl());
    }

    public final void e(SQLiteDatabase sQLiteDatabase) {
        for (f fVar : this.f30391b.values()) {
            try {
                sQLiteDatabase.execSQL(fVar.f30409c.lb());
                String strYz = fVar.f30409c.yz();
                String str = "CREATE INDEX IF NOT EXISTS idx_" + strYz + "_data_id ON " + strYz + " (data_id);";
                String str2 = "CREATE INDEX IF NOT EXISTS idx_" + strYz + "_create_time ON " + strYz + " (create_time);";
                sQLiteDatabase.execSQL(str);
                sQLiteDatabase.execSQL(str2);
                sQLiteDatabase.execSQL("CREATE INDEX IF NOT EXISTS idx_" + strYz + "_priority ON " + strYz + " (priority);");
            } catch (Exception unused) {
            }
        }
    }

    public final void g(SQLiteDatabase sQLiteDatabase) {
        Iterator it = this.f30391b.values().iterator();
        while (it.hasNext()) {
            try {
                sQLiteDatabase.execSQL("DROP TABLE IF EXISTS ".concat(String.valueOf(((f) it.next()).f30409c.yz())));
            } catch (Exception unused) {
            }
        }
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onConfigure(SQLiteDatabase sQLiteDatabase) {
        super.onConfigure(sQLiteDatabase);
        try {
            if (sQLiteDatabase.isWriteAheadLoggingEnabled()) {
                sQLiteDatabase.execSQL("PRAGMA synchronous = NORMAL;");
            }
        } catch (Exception unused) {
        }
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onCreate(SQLiteDatabase sQLiteDatabase) {
        e(sQLiteDatabase);
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onDowngrade(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
        if (i10 > i11) {
            g(sQLiteDatabase);
            e(sQLiteDatabase);
        }
    }

    @Override // android.database.sqlite.SQLiteOpenHelper
    public final void onUpgrade(SQLiteDatabase sQLiteDatabase, int i10, int i11) {
        if (i10 > i11) {
            g(sQLiteDatabase);
        }
        e(sQLiteDatabase);
    }
}