import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
/**
 * 新增或者修改数据库的统一方法
 * @param tClass 传递一个class信息
 * @param models 这个class对应的实例的数组
 * @param <Model> 这个实例的泛型 限定条件是BaseModel
 */
public static<Model extends BaseModel> void save(final Class<Model> tClass, final Model... models) {
    if (models==null||models.length==0) return;
    // 当前数据库的一个管理者
    DatabaseDefinition definition = FlowManager.getDatabase(AppDatabase.class);
    // 提交一个事务
    definition.beginTransactionAsync(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            // 执行
            ModelAdapter<Model> adapter = FlowManager.getModelAdapter(tClass);
            // 保存
            adapter.saveAll(Arrays.asList(models));
            // 唤起通知
            instance.notifySave(tClass,models);
        }
    }).build().execute();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
/**
 * 删除数据库的的统一方法
 * @param tClass 传递一个class信息
 * @param models 这个class对应的实例的数组
 * @param <Model> 这个实例的泛型 限定条件是BaseModel
 */
public static<Model extends BaseModel> void delete(final Class<Model> tClass, final Model... models) {
    if (models==null||models.length==0) return;
    // 当前数据库的一个管理者
    DatabaseDefinition definition = FlowManager.getDatabase(AppDatabase.class);
    // 提交一个事务
    definition.beginTransactionAsync(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            // 执行
            ModelAdapter<Model> adapter = FlowManager.getModelAdapter(tClass);
            // 删除
            adapter.deleteAll(Arrays.asList(models));
            // 唤起通知
            instance.notifyDelete(tClass,models);
        }
    }).build().execute();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
/**
 * 从成员中找出成员对应的群，并对群进行更新
 *
 * @param members 群成员列表
 */
private void updateGroup(GroupMember... members) {
    // 不重复集合
    final Set<String> groupIds = new HashSet<>();
    for (GroupMember member : members) {
        // 添加群Id
        groupIds.add(member.getGroup().getId());
    }

    // 异步的数据库查询，并异步的发起二次通知
    DatabaseDefinition definition = FlowManager.getDatabase(AppDatabase.class);
    definition.beginTransactionAsync(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            // 找到需要通知的群
            List<Group> groups = SQLite.select()
                    .from(Group.class)
                    .where(Group_Table.id.in(groupIds))
                    .queryList();

            // 调用直接进行一次通知分发
            instance.notifySave(Group.class, groups.toArray(new Group[0]));

        }
    }).build().execute();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
public static void upDataBySynchronous(final ArrayList<SOListBean.ListBean> mListBeans, final String type){
    DatabaseDefinition database = FlowManager.getDatabase(LueansDB.class);
    database.executeTransaction(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            // do something here
            deleteSoDdata(type);
            saveSoData(mListBeans,type);
        }
    });
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@Override
public void onAdded() {
    ITransaction it = new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            // List all model tables here to delete.
            Delete.tables(Note.class);
        }
    };
    FlowManager.getDatabase(NoteDB.class).executeTransaction(it);
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
protected static void saveAllItems(final List<Model> models) {
    DatabaseDefinition databaseDefinition =
            FlowManager.getDatabase(AppDatabase.class); // execute  transaction
    databaseDefinition.executeTransaction(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            for (Model model : models) {
                model.insert();
            }
        }
    });
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
public static void saveBatch(final List<Model> insertModels) {
    //Save questions in batch

    DatabaseDefinition databaseDefinition =
            FlowManager.getDatabase(AppDatabase.class);
    databaseDefinition.executeTransaction(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            for (Model model : insertModels) {
                model.insert();
            }
        }
    });
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
/**
 * Saves the database as a backup on the {@link DefaultTransactionQueue}.
 * This will create a THIRD database to use as a backup to the backup in case somehow the overwrite fails.
 */
public void backupDB() {
    if (!getDatabaseDefinition().backupEnabled() || !getDatabaseDefinition().areConsistencyChecksEnabled()) {
        throw new IllegalStateException("Backups are not enabled for : " + getDatabaseDefinition().getDatabaseName() + ". Please consider adding " +
            "both backupEnabled and consistency checks enabled to the Database annotation");
    }

    getDatabaseDefinition().beginTransactionAsync(new ITransaction() {
        @SuppressWarnings("ResultOfMethodCallIgnored")
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            Context context = FlowManager.getContext();
            File backup = context.getDatabasePath(getTempDbFileName());
            File temp = context.getDatabasePath(TEMP_DB_NAME + "-2-" + getDatabaseDefinition().getDatabaseFileName());

            // if exists we want to delete it before rename
            if (temp.exists()) {
                temp.delete();
            }

            backup.renameTo(temp);
            if (backup.exists()) {
                backup.delete();
            }
            File existing = context.getDatabasePath(getDatabaseDefinition().getDatabaseFileName());

            try {
                backup.getParentFile().mkdirs();
                writeDB(backup, new FileInputStream(existing));

                temp.delete();
            } catch (Exception e) {
                FlowLog.logError(e);

            }
        }
    }).build().execute();

}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@Override
public int bulkInsert(@NonNull final Uri uri, @NonNull final ContentValues[] values) {
    final int[] count = {0};
    getDatabase().executeTransaction(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            for (ContentValues contentValues : values) {
                count[0] += bulkInsert(uri, contentValues);
            }
        }
    });
    //noinspection ConstantConditions
    getContext().getContentResolver().notifyChange(uri, null);
    return count[0];
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
protected void executeTransaction(@NonNull ITransaction transaction) {
    cancel();
    currentTransaction = databaseDefinition
        .beginTransactionAsync(transaction)
        .error(error)
        .success(success)
        .build();
    currentTransaction.execute();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
public void executeTransaction(@NonNull ITransaction transaction) {
    DatabaseWrapper database = getWritableDatabase();
    try {
        database.beginTransaction();
        transaction.execute(database);
        database.setTransactionSuccessful();
    } finally {
        database.endTransaction();
    }
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@Override
public long writeWholeData() throws SQLException
{
    final List<User> users = new LinkedList<User>();
    for(int i = 0; i < NUM_USER_INSERTS; i++)
    {
        User newUser = new User();
        newUser.lastName = (getRandomString(10));
        newUser.firstName = (getRandomString(10));

        users.add(newUser);
    }

    final List<Message> messages = new LinkedList<Message>();
    for (int i = 0; i < NUM_MESSAGE_INSERTS; i++) {
        Message newMessage = new Message();
        newMessage.commandId = i;
        newMessage.sortedBy = System.nanoTime();
        newMessage.content = Util.getRandomString(100);
        newMessage.clientId = System.currentTimeMillis();
        newMessage
                .senderId = (Math.round(Math.random() * NUM_USER_INSERTS));
        newMessage
                .channelId = (Math.round(Math.random() * NUM_USER_INSERTS));
        newMessage.createdAt = ((int) (System.currentTimeMillis() / 1000L));

        messages.add(newMessage);
    }

    long start = System.nanoTime();

    FlowManager.getDatabase(DatabaseModule.NAME).executeTransaction(new ITransaction() {
        @Override
        public void execute(DatabaseWrapper databaseWrapper) {
            for (User user : users) {
                user.save();
            }
            Log.d(TAG, "Done, wrote " + NUM_USER_INSERTS + " users");

            for (Message message : messages) {
                message.save();
            }
            Log.d(TAG, "Done, wrote " + NUM_MESSAGE_INSERTS + " messages");
        }
    });

    return System.nanoTime() - start;
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@NonNull
private <TModel extends Model> ITransaction insertTransaction(Collection entities, Class<TModel> clazz) {
    ModelAdapter<? extends Model> modelAdapter = FlowManager.getModelAdapter(clazz);
    return FastStoreModelTransaction.insertBuilder(modelAdapter).addAll(entities).build();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@NonNull
private <TModel extends Model> ITransaction updateTransaction(Collection entities, Class<TModel> clazz) {
    ModelAdapter<? extends Model> modelAdapter = FlowManager.getModelAdapter(clazz);
    return FastStoreModelTransaction.updateBuilder(modelAdapter).addAll(entities).build();
}
 

import com.raizlabs.android.dbflow.structure.database.transaction.ITransaction; //导入依赖的package包/类
@NonNull
public Transaction.Builder beginTransactionAsync(@NonNull ITransaction transaction) {
    return new Transaction.Builder(transaction, this);
}