import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * retrieve
 */

public ArrayList<StudentModel> getAllStudentRecord() {

    ArrayList<StudentModel> arrayListStudentRecord = new ArrayList<>();

    String selectQuery2 = "SELECT * FROM " + StudentDbCreation.STUDENT_TABLE_NAME;
    Cursor cursor2 = sqLiteDatabase.rawQuery(selectQuery2, null);

    if (cursor2.moveToFirst()) {

        do {
            StudentModel studentModel = new StudentModel();
            studentModel.setStudentRollNo(cursor2.getInt(0));
            studentModel.setStudentName(cursor2.getString(1));
            studentModel.setStudentClass(cursor2.getString(2));

            arrayListStudentRecord.add(studentModel);

        } while (cursor2.moveToNext());
    }
    return arrayListStudentRecord;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public int get_global_unseen_count() {
    Cursor cursor = dbw.query(table_accounts, new String[] { key_unseen }, null,
            null, null, null, null);

    int count = 0;
    if (cursor.moveToFirst()) {
        do {
            count += cursor.getInt(0);
        } while (cursor.moveToNext());
    }

    // Prevent memory issues
    cursor.close();

    return count;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public ArrayList<Integer> get_all_accounts_id() {
    Cursor cursor = dbw.query(table_accounts, new String[] { "*" }, null,
            null, null, null, null);

    ArrayList<Integer> accounts = new ArrayList<>();
    Integer current;
    if (cursor.moveToFirst()) {
        do {
            current = cursor.getInt(0);
            accounts.add(current);
        } while (cursor.moveToNext());
    }

    // Prevent memory issues
    cursor.close();

    return accounts;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * Changes all messages' status to seen.
 **/
public void mark_all_seen(int id) {
    Cursor cursor = dbw.query(table_messages, new String[] { "*" }, "account = " + id,
            null, null, null, null);

    if (cursor.moveToFirst()) {
        do {
            boolean b_set = cursor.getInt(23) == 1;
            if (!b_set) {
                seen_unseen_message(id, cursor.getString(12), true);
            }
        } while (cursor.moveToNext());
    }

    // Prevent memory issues
    cursor.close();
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * Computes the total message size on server for an account.
 * Used with IMAP.
 **/
public int refresh_total_size(int id) {
    Cursor cursor = dbw.query(table_messages, new String[] { key_size }, "account = " + id,
            null, null, null, null);

    int result = 0;
    if (cursor.moveToFirst()) {
        do {
            result += cursor.getInt(0);
        } while (cursor.moveToNext());
    }

    // Updating total size of (server) inbox
    dbw.execSQL("UPDATE " + table_accounts + " SET total_size=" + result + " WHERE id = " + id);

    // Prevent memory issues
    cursor.close();

    return result;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * Get the DB id and uid of a message. Every row is a message.
 **/
public HashMap<Integer, String> get_all_message_uids(int id) {
    Cursor cursor = dbw.query(table_messages, new String[] { "*" }, "account = " + id,
            null, null, null, null);

    HashMap<Integer, String> messages = new HashMap<>();

    if (cursor.moveToFirst()) {
        do {
            // DB ID and message-uid
            messages.put(cursor.getInt(0), cursor.getString(12));
        } while (cursor.moveToNext());
    }

    // Prevent memory issues
    cursor.close();

    return messages;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public ArrayList<Message> get_all_messages(int id) {
    Cursor cursor = dbw.query(table_messages, new String[] {"*"}, "account = " + id,
            null, null, null, null);

    ArrayList<Message> messages = new ArrayList<>();
    Message current;
    if (cursor.moveToFirst()) {
        do {
            current = new Message();
            current.set_id(cursor.getInt(0));
            current.set_account(cursor.getInt(1));
            current.set_from(cursor.getString(5));
            current.set_subject(cursor.getString(10));
            current.set_attachments(cursor.getInt(22));
            current.set_seen(cursor.getInt(23) == 1);
            messages.add(current);
        } while (cursor.moveToNext());
    }

    // Prevent memory issues
    cursor.close();

    return messages;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public static Response getAllTableName(SQLiteDatabase database) {
    Response response = new Response();
    Cursor c = database.rawQuery("SELECT name FROM sqlite_master WHERE type='table' OR type='view' ORDER BY name COLLATE NOCASE", null);
    if (c.moveToFirst()) {
        while (!c.isAfterLast()) {
            response.rows.add(c.getString(0));
            c.moveToNext();
        }
    }
    c.close();
    response.isSuccessful = true;
    try {
        response.dbVersion = database.getVersion();
    } catch (Exception ignore) {

    }
    return response;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
private static boolean doesTempFixtureTableExist(SQLiteDatabase db) {
    // "SELECT name FROM sqlite_master WHERE type='table' AND name='oldfixture';";
    String whereClause = "type =? AND name =?";
    String[] whereArgs = new String[]{
            "table",
            "oldfixture"
    };
    Cursor cursor = null;
    try {
        cursor = db.query("sqlite_master", new String[]{"name"},
                whereClause, whereArgs, null, null, null);
        return cursor.getCount() > 0;
    } finally {
        if (cursor != null) {
            cursor.close();
        }
    }
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * Get a list of Case Record id's for cases which index any of a set of provided values
 *
 * @param indexName      The name of the index
 * @param targetValueSet The set of cases targeted by the index
 * @return An integer array of indexed case record ids
 */
public LinkedHashSet<Integer> getCasesMatchingValueSet(String indexName, String[] targetValueSet) {
    String[] args = new String[1 + targetValueSet.length];
    args[0] = indexName;
    for (int i = 0; i < targetValueSet.length; ++i) {
        args[i + 1] = targetValueSet[i];
    }
    String inSet = getArgumentBasedVariableSet(targetValueSet.length);

    String whereExpr = String.format("%s = ? AND %s IN %s", COL_INDEX_NAME, COL_INDEX_TARGET, inSet);

    if (SqlStorage.STORAGE_OUTPUT_DEBUG) {
        String query = String.format("SELECT %s FROM %s WHERE %s", COL_CASE_RECORD_ID, TABLE_NAME, whereExpr);
        DbUtil.explainSql(db, query, args);
    }

    Cursor c = db.query(TABLE_NAME, new String[]{COL_CASE_RECORD_ID}, whereExpr, args, null, null, null);
    LinkedHashSet<Integer> ret = new LinkedHashSet<>();

    SqlStorage.fillIdWindow(c, COL_CASE_RECORD_ID, ret);
    return ret;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public static Pair<String, String> lookupIndexedFixturePaths(SQLiteDatabase db,
                                                             String fixtureName) {
    Cursor c = db.query(IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_TABLE,
            new String[]{IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_BASE, IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_CHILD},
            IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_NAME + "=?", new String[]{fixtureName}, null, null, null);
    try {
        if (c.getCount() == 0) {
            return null;
        } else {
            c.moveToFirst();
            return Pair.create(
                    c.getString(c.getColumnIndexOrThrow(IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_BASE)),
                    c.getString(c.getColumnIndexOrThrow(IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_CHILD)));
        }
    } finally {
        c.close();
    }
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public static List<String> getAllIndexedFixtureNames(SQLiteDatabase db) {
    Cursor c = db.query(IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_TABLE,
            new String[]{IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_NAME},
            null, null, null, null, null);
    List<String> fixtureNames = new ArrayList<>();
    try {
        if (c.moveToFirst()) {
            int desiredColumnIndex = c.getColumnIndexOrThrow(
                    IndexedFixturePathsConstants.INDEXED_FIXTURE_PATHS_COL_NAME);
            while (!c.isAfterLast()) {
                String name = c.getString(desiredColumnIndex);
                fixtureNames.add(name);
                c.moveToNext();
            }
        }
        return fixtureNames;
    } finally {
        if (c != null) {
            c.close();
        }
    }
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
protected static Pair<String, byte[]> getEntryFilenameAndKey(AndroidDbHelper helper,
                                                             String table,
                                                             int id) {
    Cursor c;
    c = helper.getHandle().query(table, HybridFileBackedSqlStorage.dataColumns,
            DatabaseHelper.ID_COL + "=?",
            new String[]{String.valueOf(id)}, null, null, null);

    try {
        c.moveToFirst();
        return new Pair<>(c.getString(c.getColumnIndexOrThrow(DatabaseHelper.FILE_COL)),
                c.getBlob(c.getColumnIndexOrThrow(DatabaseHelper.AES_COL)));
    } finally {
        if (c != null) {
            c.close();
        }
    }
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
protected static String getEntryFilename(AndroidDbHelper helper,
                                         String table, int id) {
    Cursor c;
    SQLiteDatabase db = helper.getHandle();

    String[] columns = new String[]{DatabaseHelper.FILE_COL};
    c = db.query(table, columns, DatabaseHelper.ID_COL + "=?",
            new String[]{String.valueOf(id)}, null, null, null);

    try {
        c.moveToFirst();
        return c.getString(c.getColumnIndexOrThrow(DatabaseHelper.FILE_COL));
    } finally {
        if (c != null) {
            c.close();
        }
    }
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
     * Runs an SQLite query and returns a MemoryFile for the
     * blob in column 0 of the first row. If the first column does
     * not contain a blob, an unspecified exception is thrown.
     *
     * @return A memory file, or {@code null} if the query returns no results
     *         or the value column 0 is NULL.
     * @throws IOException If there is an error creating the memory file.
     */
    // TODO: make this native and use the SQLite blob API to reduce copying
    private static MemoryFile simpleQueryForBlobMemoryFile(SQLiteDatabase db, String sql, String[] selectionArgs) 
            throws IOException {

        Cursor cursor = db.rawQuery(sql, selectionArgs);
        if (cursor == null) {
            return null;
        }
        try {
            if (!cursor.moveToFirst()) {
                return null;
            }
            byte[] bytes = cursor.getBlob(0);
            if (bytes == null) {
                return null;
            }
            MemoryFile file = new MemoryFile(null, bytes.length);
            file.writeBytes(bytes, 0, 0, bytes.length);
//            file.deactivate();
            return file;
        } finally {
            cursor.close();
        }
    }
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
@Override
public boolean update(SQLiteDatabase db, TransactionContext txContext, ContentValues values,
        Cursor c, boolean callerIsSyncAdapter) {

    long rawContactId = c.getLong(DataUpdateQuery.RAW_CONTACT_ID);

    if (values.containsKey(SKIP_PROCESSING_KEY)) {
        values.remove(SKIP_PROCESSING_KEY);
    } else {
        // Pre-process the photo if one exists.
        if (!preProcessPhoto(values)) {
            return false;
        }
    }
    // Do the actual update.
    if (!super.update(db, txContext, values, c, callerIsSyncAdapter)) {
        return false;
    }
    mSimpleAggregator.updatePhotoId(db, rawContactId);
    return true;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
public int deleteRawContact(long rawContactId, boolean callerIsSyncAdapter) {
    mProviderStatusUpdateNeeded = true;

    final SQLiteDatabase db = mDbHelper.get().getDatabase(true);

    // Find and delete stream items associated with the raw contact.
   Cursor c = db.query(Tables.STREAM_ITEMS,
            new String[]{StreamItems._ID},
            StreamItems.RAW_CONTACT_ID + "=?", new String[]{String.valueOf(rawContactId)},
            null, null, null);
    try {
        while (c.moveToNext()) {
            deleteStreamItem(db, c.getLong(0));
        }
    } finally {
        c.close();
    }

    if (callerIsSyncAdapter || rawContactIsLocal(rawContactId)) {
        int count = db.delete(Tables.RAW_CONTACTS, RawContacts._ID + "=" + rawContactId, null);
        return count;
    }
    return 0;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
/**
 * Delete data row by row so that fixing of primaries etc work correctly.
 */
private int deleteData(String selection, String[] selectionArgs, boolean callerIsSyncAdapter) {
    int count = 0;

    final SQLiteDatabase db = mDbHelper.get().getDatabase(true);

    // Note that the query will return data according to the access restrictions,
    // so we don't need to worry about deleting data we don't have permission to read.
    Uri dataUri = Data.CONTENT_URI;
    Cursor c = query(dataUri, DataRowHandler.DataDeleteQuery.COLUMNS, selection, selectionArgs, null);
    try {
        while(c.moveToNext()) {
            String mimeType = c.getString(DataRowHandler.DataDeleteQuery.MIMETYPE);
            DataRowHandler rowHandler = getDataRowHandler(mimeType);
            count += rowHandler.delete(db, mTransactionContext.get(), c);
        }
    } finally {
        c.close();
    }

    return count;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
private int deleteStreamItems(Uri uri, ContentValues values, String selection,
        String[] selectionArgs) {
    final SQLiteDatabase db = mDbHelper.get().getDatabase(true);
    int count = 0;
    final Cursor c = db.query(Views.STREAM_ITEMS, Projections.ID,
            selection, selectionArgs, null, null, null);
    try {
        c.moveToPosition(-1);
        while (c.moveToNext()) {
            count += deleteStreamItem(db, c.getLong(0));
        }
    } finally {
        c.close();
    }
    return count;
}
 

import net.sqlcipher.Cursor; //导入依赖的package包/类
private int updateRawContacts(ContentValues values, String selection, String[] selectionArgs, boolean callerIsSyncAdapter) {

        if (!callerIsSyncAdapter) {
            selection = DbQueryUtils.concatenateWhere(selection,  RawContacts.RAW_CONTACT_IS_READ_ONLY + "=0");
        }

        int count = 0;
        final SQLiteDatabase db = mDbHelper.get().getDatabase(true);
        Cursor cursor = db.query(Views.RAW_CONTACTS, Projections.ID, selection, selectionArgs, null, null, null);
        try {
            while (cursor.moveToNext()) {
                long rawContactId = cursor.getLong(0);
                updateRawContact(db, rawContactId, values, callerIsSyncAdapter);
                count++;
            }
        } finally {
            cursor.close();
        }

        return count;
    }