【Android】GreenDao数据库的使用方式 - ToB企服应用市场:ToB评测及商务社交产业平台

implementation 'org.greenrobot:greendao:3.3.0'

复制代码

apply plugin: 'org.greenrobot.greendao'
greendao {
schemaVersion 1 //定义数据库的版本号，用于处理数据库升级。
daoPackage 'com.example.dao' //指定生成的 DAO 类包名。
targetGenDir 'src/main/java' //指定生成的实体类包名。
}

复制代码

@Entity
public class UpdateBean{
@Id(autoincrement = true)
private Long id;
private String name;
// getters and setters
}

复制代码

public class UpdateOpenHelper extends DaoMaster.OpenHelper {
public UpdateOpenHelper(Context context, String name) {
super(context, name);
}
public UpdateOpenHelper(Context context, String name, SQLiteDatabase.CursorFactory factory) {
super(context, name, factory);
}
@Override
public void onDowngrade(SQLiteDatabase db, int oldVersion, int newVersion) {
DaoMaster.dropAllTables(wrap(db), true);
}
@Override
public void onUpgrade(Database db, int oldVersion, int newVersion) {
super.onUpgrade(db, oldVersion, newVersion);
}
}

复制代码

public class UpdateManager {
private Context mContext;
private static UpdateManager manager = new UpdateManager();
private static ConcurrentHashMap<String, DaoMaster> masterMap = new ConcurrentHashMap<>();
private static ConcurrentHashMap<String, DaoSession> daoSessionMap = new ConcurrentHashMap<>();
private static ConcurrentHashMap<String, UpdateOpenHelper> helperMap = new ConcurrentHashMap<>();
public static UpdateManager getInstance() {
return manager;
}
public void init(Context context) {
this.mContext = context;
}
private DaoMaster getDaoMaster(String dbName) {
if (!masterMap.containsKey(dbName)) {
UpdateOpenHelper openHelper = helperMap.get(dbName);
if (openHelper == null) {
UGDaoContext daoContext = new UGDaoContext(mContext);
openHelper = new UpdateOpenHelper(daoContext, dbName, null);
helperMap.put(dbName, openHelper);
}
DaoMaster master;
try {
master = new DaoMaster(openHelper.getWritableDatabase());
masterMap.put(dbName, master);
} catch (Exception e) {
e.printStackTrace();
}
}
return masterMap.get(dbName);
}
public DaoSession getDaoSession(String dbName) {
if (!daoSessionMap.containsKey(dbName)) {
DaoMaster master = getDaoMaster(dbName);
if (master != null) {
DaoSession session = master.newSession();
daoSessionMap.put(dbName, session);
}
}
return daoSessionMap.get(dbName);
}
/**
* 关闭指定数据库连接
*
* @param dbName 数据库名字
*/
public void closeConnection(String dbName) {
DaoSession session = daoSessionMap.get(dbName);
if (session != null) {
session.clear();
daoSessionMap.remove(dbName);
}
DaoMaster master = masterMap.get(dbName);
if (master != null) {
master = null;
masterMap.remove(dbName);
}
UpdateOpenHelper helper = helperMap.get(dbName);
if (helper != null) {
helper.close();
helperMap.remove(dbName);
}
}
/**
* 关闭所有数据库连接
*/
public void closeAllConnection() {
// 关闭所有DaoSessions
synchronized (this) {
for (String dbName : daoSessionMap.keySet()) {
closeConnection(dbName); // 关闭每一个连接
}
// 额外步骤：清理所有映射
daoSessionMap.clear();
masterMap.clear();
helperMap.clear();
}
}
}

复制代码

public class UGDaoContext extends ContextWrapper {
public UGDaoContext(Context base) {
super(base);
}
@Override
public File getDatabasePath(String name) {
String dbDir;
boolean isExistSDCar = Environment.getExternalStorageState().equals(Environment.MEDIA_MOUNTED);
if (isExistSDCar) {
dbDir = Environment.getExternalStorageDirectory().getAbsolutePath();
} else {
dbDir = Environment.getDataDirectory().getAbsolutePath();
}
String dbDirPath = dbDir + File.separator + "app_dao" + File.separator + "data_update";
Log.d("TAG", "数据库的文件夹地址：" + dbDirPath);
File dbDirFile = new File(dbDirPath);
if (!dbDirFile.exists()) {
dbDirFile.mkdirs();
}
String dbNamePath = dbDirPath + File.separator + name;
File dbNameFile = new File(dbNamePath);
boolean isSuccess = false;
if (!dbNameFile.exists()) {
try {
isSuccess = dbNameFile.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
} else {
isSuccess = true;
}
if (isSuccess) {
Log.d("TAG", "数据库的文件地址：" + dbNamePath);
return dbNameFile;
} else {
return super.getDatabasePath(name);
}
}
@Override
public SQLiteDatabase openOrCreateDatabase(String name, int mode, SQLiteDatabase.CursorFactory factory) {
return SQLiteDatabase.openOrCreateDatabase(getDatabasePath(name), null);
}
@Override
public SQLiteDatabase openOrCreateDatabase(String name, int mode, SQLiteDatabase.CursorFactory factory, DatabaseErrorHandler errorHandler) {
return SQLiteDatabase.openOrCreateDatabase(getDatabasePath(name), null);
}
}

复制代码

public class UpdateDaoUtil {
private UpdateManager manager;
public UpdateDaoUtil(Context context) {
manager = UpdateManager.getInstance();
manager.init(context);
}
/**
* 完成UpdateBean记录的插入
*/
public synchronized boolean insertUpdate(UpdateBean updateBean, String dbName) {
boolean flag = false;
if (manager.getDaoSession(dbName).getUpdateBeanDao().insert(updateBean) != -1) {
flag = true;
}
return flag;
}
/**
* 完成UpdateBean记录的插入
*/
public synchronized boolean insertUpdate(UpdateBean updateBean) {
boolean flag = false;
if (manager.getDaoSession(getCurrentDBName()).getUpdateBeanDao().insert(updateBean) != -1) {
flag = true;
}
return flag;
}
/**
* 完成UpdateBean列表记录的插入
*/
public synchronized boolean insertUpdate(List<UpdateBean> list) {
int frequency = 0;
UpdateBeanDao dao = manager.getDaoSession(getCurrentDBName()).getUpdateBeanDao();
for (UpdateBean updateBean : list) {
if (dao.insert(updateBean) == -1) {
frequency++;
}
}
return frequency == 0;
}
/**
* 删除单条记录
*/
public synchronized boolean deleteUpdateBean(UpdateBean updateBean, String dbName) {
boolean flag = false;
try {
manager.getDaoSession(dbName).delete(updateBean);
flag = true;
} catch (Exception e) {
e.printStackTrace();
}
return flag;
}
/**
* 删除单条记录
*/
public synchronized boolean deleteUpdateBean(UpdateBean updateBean) {
boolean flag = false;
try {
manager.getDaoSession(getCurrentDBName()).delete(updateBean);
flag = true;
} catch (Exception e) {
e.printStackTrace();
}
return flag;
}
/**
* 删除所有记录
*/
public synchronized boolean deleteAll(String dbname) {
boolean flag = false;
try {
manager.getDaoSession(dbname).deleteAll(UpdateBean.class);
flag = true;
} catch (Exception e) {
e.printStackTrace();
}
return flag;
}
/**
* 删除所有记录
*/
public synchronized boolean deleteAll() {
boolean flag = false;
try {
manager.getDaoSession(getCurrentDBName()).deleteAll(UpdateBean.class);
flag = true;
} catch (Exception e) {
e.printStackTrace();
}
return flag;
}
/**
* 查询数据库前 number 条数据
*/
public synchronized List<UpdateBean> queryDataNumber(int number, String dbname) {
QueryBuilder<UpdateBean> queryBuilder = manager.getDaoSession(dbname).queryBuilder(UpdateBean.class);
return queryBuilder.limit(number).list();
}
/**
* 查询数据库前 number 条数据
*/
public synchronized List<UpdateBean> queryDataNumber(int number) {
QueryBuilder<UpdateBean> queryBuilder = manager.getDaoSession(getCurrentDBName()).queryBuilder(UpdateBean.class);
return queryBuilder.limit(number).list();
}
/**
* 删除数据库前 number 条数据
*/
public synchronized void deleteDataNumber(int number, String dbname) {
UpdateBeanDao dao = manager.getDaoSession(dbname).getUpdateBeanDao();
List<UpdateBean> lists = dao.queryBuilder().limit(number).list();
dao.deleteInTx(lists);
}
/**
* 删除数据库前 number 条数据
*/
public synchronized void deleteDataNumber(int number) {
UpdateBeanDao dao = manager.getDaoSession(getCurrentDBName()).getUpdateBeanDao();
List<UpdateBean> lists = dao.queryBuilder().limit(number).list();
dao.deleteInTx(lists);
}
/**
* 查询所有记录
*/
public synchronized List<UpdateBean> queryAll(String dbName) {
return manager.getDaoSession(dbName).loadAll(UpdateBean.class);
}
/**
* 查询所有记录
*/
public synchronized List<UpdateBean> queryAll() {
return manager.getDaoSession(getCurrentDBName()).loadAll(UpdateBean.class);
}
/**
* 使用指定名称的数据库,每次查询200条未上传的数据
*
* @param dbname 数据库表名称
*/
public synchronized List<UpdateBean> queryListUpdate(String dbname) {
QueryBuilder<UpdateBean> queryBuilder = manager.getDaoSession(dbname).queryBuilder(UpdateBean.class);
return queryBuilder.where(UpdateBeanDao.Properties.IsUpdate.eq(0)).limit(200).list();
}
/**
* 更新是否上传状态
*
* @param list 上传数据的ID的list
*/
public synchronized void updateStatus(List<Long> list) {
DaoSession daoSession = manager.getDaoSession(getCurrentDBName());
UpdateBeanDao updateBeanDao = daoSession.getUpdateBeanDao();
try {
daoSession.runInTx(() -> {
for (Long id : list) {
UpdateBean bean = updateBeanDao.load(id);
if (bean != null) {
bean.setIsUpdate(1);
updateBeanDao.update(bean);
}
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 更新是否上传状态
*
* @param dbName 数据库表名字
* @param list 上传数据的ID的list
*/
public synchronized void updateStatus(String dbName, List<Long> list) {
DaoSession daoSession = manager.getDaoSession(dbName);
UpdateBeanDao updateBeanDao = daoSession.getUpdateBeanDao();
try {
daoSession.runInTx(() -> {
for (Long id : list) {
UpdateBean bean = updateBeanDao.load(id);
if (bean != null) {
bean.setIsUpdate(1);
updateBeanDao.update(bean);
}
}
});
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 使用queryBuilder进行查询未上传的数据
*/
public synchronized List<UpdateBean> queryItemByQueryBuilder(int isUpdate) {
QueryBuilder<UpdateBean> queryBuilder = manager.getDaoSession(getCurrentDBName()).queryBuilder(UpdateBean.class);
return queryBuilder.where(UpdateBeanDao.Properties.IsUpdate.eq(isUpdate)).limit(100).list();
}
/**
* 关闭当前日期资源
*/
public synchronized void close() {
manager.closeConnection(getCurrentDBName());
}
/**
* 关闭特定名字的数据资源
*/
public synchronized void close(String dbName) {
manager.closeConnection(dbName);
}
/**
* 关闭所有连接
*/
public synchronized void closeAll() {
manager.closeAllConnection();
}
/**
* 数据表的名称是当天的日期
*
* @return 当天日期
*/
private static String getCurrentDateFormatted() {
long currentTimeMillis = System.currentTimeMillis();
Date date = new Date(currentTimeMillis);
SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd", Locale.getDefault());
return sdf.format(date);
}
/**
* 获取当天数据库表的名称
*/
private static String getCurrentDBName() {
return getCurrentDateFormatted() + "_db";
}
/**
* 组装数据库名字
*
* @param dateTime 日期时间例如 20240814
*/
public static String setDBName(String dateTime) {
return dateTime + "_db";
}
}

复制代码

UpdateDaoUtil updateDaoUtil;

复制代码

updateDaoUtil = new UpdateDaoUtil(this);

复制代码

if (updateDaoUtil != null) {
Log.i("TAG", "将List数据存入本地数据库,存入条数 " + updateBeanList.size());
List<UpdateBean> list = new ArrayList<>(updateBeanList);
boolean update = updateDaoUtil.insertUpdate(list);
if (update) {
Log.i("TAG", "数据存入数据库正常");
}
}

复制代码

@Override
protected void onDestroy() {
super.onDestroy();
if (updateDaoUtil != null) {
updateDaoUtil.closeAll();
}
}

复制代码