import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的package包/类
public RetrievalAdapter(@NonNull DatabaseDefinition databaseDefinition) {
    DatabaseConfig databaseConfig = FlowManager.getConfig()
        .getConfigForDatabase(databaseDefinition.getAssociatedDatabaseClassFile());
    if (databaseConfig != null) {
        tableConfig = databaseConfig.getTableConfigForTable(getModelClass());
        if (tableConfig != null) {
            if (tableConfig.singleModelLoader() != null) {
                singleModelLoader = tableConfig.singleModelLoader();
            }

            if (tableConfig.listModelLoader() != null) {
                listModelLoader = tableConfig.listModelLoader();
            }
        }
    }
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的package包/类
/**
 * This method removes the sqlite_sequence table that contains the last autoincrement value for
 * each table
 */
private void deleteSQLiteMetadata() {
    String sqlCopy = "Delete from sqlite_sequence";
    DatabaseDefinition databaseDefinition =
            FlowManager.getDatabase(AppDatabase.class);
    databaseDefinition.getWritableDatabase().execSQL(sqlCopy);

}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的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.config.DatabaseDefinition; //导入依赖的package包/类
/**
 * This method removes the sqlite_sequence table that contains the last autoincrement value for
 * each table
 */
private static void deleteSQLiteMetadata() {
    String sqlCopy = "Delete from sqlite_sequence";
    DatabaseDefinition databaseDefinition =
            FlowManager.getDatabase(AppDatabase.class);
    databaseDefinition.getWritableDatabase().execSQL(sqlCopy);

}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public FlowSQLiteOpenHelper(@NonNull DatabaseDefinition databaseDefinition,
                            @NonNull DatabaseHelperListener listener) {
    super(FlowManager.getContext(), databaseDefinition.isInMemory() ? null : databaseDefinition.getDatabaseFileName(),
        null, databaseDefinition.getDatabaseVersion());

    OpenHelper backupHelper = null;
    if (databaseDefinition.backupEnabled()) {
        // Temp database mirrors existing
        backupHelper = new BackupHelper(FlowManager.getContext(),
            DatabaseHelperDelegate.getTempDbFileName(databaseDefinition),
            databaseDefinition.getDatabaseVersion(), databaseDefinition);
    }

    databaseHelperDelegate = new DatabaseHelperDelegate(listener, databaseDefinition, backupHelper);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public ModelAdapter(@NonNull DatabaseDefinition databaseDefinition) {
    super(databaseDefinition);
    if (getTableConfig() != null && getTableConfig().modelSaver() != null) {
        modelSaver = getTableConfig().modelSaver();
        modelSaver.setModelAdapter(this);
    }
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
@NonNull
protected DatabaseDefinition getDatabase() {
    if (database == null) {
        database = FlowManager.getDatabase(getDatabaseName());
    }
    return database;
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
@NonNull
public DatabaseDefinition getDatabaseDefinition() {
    if (databaseDefinition == null) {
        databaseDefinition = FlowManager.getDatabaseForTable(modelClass);
    }
    return databaseDefinition;
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public SQLCipherOpenHelper(DatabaseDefinition databaseDefinition, DatabaseHelperListener listener) {
    super(FlowManager.getContext(), databaseDefinition.isInMemory() ? null : databaseDefinition.getDatabaseFileName(), null, databaseDefinition.getDatabaseVersion());
    SQLiteDatabase.loadLibs(FlowManager.getContext());

    OpenHelper backupHelper = null;
    if (databaseDefinition.backupEnabled()) {
        // Temp database mirrors existing
        backupHelper = new BackupHelper(FlowManager.getContext(), DatabaseHelperDelegate.getTempDbFileName(databaseDefinition),
            databaseDefinition.getDatabaseVersion(), databaseDefinition);
    }

    databaseHelperDelegate = new DatabaseHelperDelegate(listener, databaseDefinition, backupHelper);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public WeatherData_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public Weather_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public Sys_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public Main_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public WeatherForecastData_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}
 

import com.raizlabs.android.dbflow.config.DatabaseDefinition; //导入依赖的package包/类
public Rain_Table(DatabaseDefinition databaseDefinition) {
  super(databaseDefinition);
}