把最近使用数据库的经验总结下。
1,获取数据库对象SQLiteDatabase
- 继承SQLiteOpenHelper,创建操作数据库要的助手类,用于获得SQLiteDatabase数据库对象。
getReadableDatabase(),getWritableDatabase()方法获取SQLiteDatabase,查看源码可以看到它是通过mContext.openOrCreateDatabase得到的,顾名思义,就是数据库存在就创建不存在就打开。。
-
Activity的context是ContextImpl的实例对象,在ContextImpl中可以看到,mContext.openOrCreateDatabase最终调用的是
SQLiteDatabase.openDatabase(f.getPath(), factory, flags, errorHandler);。
但context获取的数据库是本APP目录下的数据库:
String path = "/data/data/"+context.getPackageName()+ "/databases/"+dbname(*这不是源码中的代码,是为了看得更形象*)。
有兴趣的童靴可以看看应用的启动源码。
-
看到这你可能有个疑问了,既然我们可以直接获取数据库对象进行操作,为什么还要继承SQLiteOpenHelper进行获取?
其实从继承SQLiteOpenHelper所要实现的方法中就可以看出,onCreate在数据库被创建时调用,onUpgrade在SQLiteOpenHelper中设置数据库版本比本地高时调用。在源码中:
if (version == 0) { onCreate(db); } else { if (version > mNewVersion) { onDowngrade(db, version, mNewVersion); } else { //比本地数据库版本高时 onUpgrade(db, version, mNewVersion); } }
在使用别人的东西时时,如果不知其所以然,这对使用效率有很大的影响。当遇到未知bug时,当要优化代码时,当要改进时,都要理解他写的代码。
扩展
数据共享:context获取的数据库,是app目录下的数据库。当你做的几个app有共享数据时,可以把数据库文件放在一个sd卡的共同目录下,像context源码中一样通过获取指定目录下的数据库方法来获取数据库,用attach进行数据库连接(attach对View视图无效);
共享路径如:Environment.getExternalStorageDirectory().getAbsolutePath()
+ File.separator + "test" + File.separator + "test.db";
//attach语法
ATTACH DATABASE [Database Path] AS [Alias];
- [Database Path] :
i.绝对路径;
ii.相对路径,即要附加的数据库与当前维持连接数据库的相对地址。
- [Alias] :
附加数据库的别名。
当你想获取另一个app的数据进行跨数据库操作时,也可以复制那个数据库文件到自己这里(比如通过创建context对象读取文件)
Context c = createPackageContext("com.data.datatest",
Context.CONTEXT_INCLUDE_CODE | Context.CONTEXT_IGNORE_SECURITY);
FileInputStream fin = tempContext.openFileInput("test.db");
2,多线程操作
数据库的操作不被建议到主线程中执行,要在多线程中执行。
进行数据库操作时要注意一点:数据库的写入操作只能有一个! 否则会产生异常database is locked。
-
读操作也要在设置getWritableDatabase().enableWriteAheadLogging()后才能读写并行,disableWriteAheadLogging()方法关闭读写并行,默认情况下读和写是不能同时发生, 且一个数据库连接SqlHelper只能有一个读执行.如下使用:
public DbHelper(Context context , boolean enableWAL) { this(context, DEFAULT_DB_NAME, null, DEFAULT_VERSION); getWritableDatabase().enableWriteAheadLogging(); }
当你产生多个数据库连接(SQLiteOpenHelper )进行写入操作时,只能有一个进行写入,其他写入操作都会报出database is locked这个错误而写入失败。因为我现在是修改以前的项目,封装的数据库读写是在主线程中进行,当我在异步线程进行其他APP数据库数据复制时,很容易就出现这个错误。主线程进行读写因为则是顺序执行,所以并不会报这个错。
-
解决写入的database is locked的方法有很多,比如:在业务逻辑类中,使用时只有一个连接和数据库对象,当然要线程安全。像下面那样
public class DatabaseManager { private AtomicInteger mOpenCounter = new AtomicInteger(); private static DatabaseManager instance; private static SQLiteOpenHelper mDatabaseHelper; private SQLiteDatabase mDatabase; public static synchronized void initializeInstance(SQLiteOpenHelper helper) { if (instance == null) { instance = new DatabaseManager(); mDatabaseHelper = helper; } } public static synchronized DatabaseManager getInstance() { if (instance == null) { throw new IllegalStateException(DatabaseManager.class.getSimpleName() + " is not initialized, call initializeInstance(..) method first."); } return instance; } public synchronized SQLiteDatabase openDatabase() { if(mOpenCounter.incrementAndGet() == 1) { // Opening new database mDatabase = mDatabaseHelper.getWritableDatabase(); } return mDatabase; } public synchronized void closeDatabase() { if(mOpenCounter.decrementAndGet() == 0) { // Closing database mDatabase.close(); } } }
这样写缺点也很明显,读操作也只能执行一个,不能并行,因为只有一个连接SqlHelper。
所以,读操作和写操作可以分开,使得读可以多个,写只能一个。
3,读写数据库优化
- 使用Transaction优化大量数据操作。
当进行多次读写操作时,你使用的单条数据多次操作的方法。举个栗子:如有200条数据存在list中,使用for循环插入200次,你会发现它的执行速度十分的慢。
原因是:sqlite在没有显式使用事务的时候会为每条insert都使用事务操作,而sqlite数据库是以文件的形式存在磁盘中,就相当于每次访问时都要打开一次文件,如果对数据进行大量的操作,时间都耗费在I/O操作上,所以很慢。
所以我们要显式使用事务,因为我们开始事务后,进行的大量操作的语句都保存在内存中,当提交时才全部写入数据库,此时,数据库文件也就只用打开一次。
public void insertData(插入数据){
db.beginTransaction(); // 手动设置开始事务
for (ContentValues v : list) {
db.insert("表名", null, v);
}
db.setTransactionSuccessful(); // 设置事务处理成功,不设置会自动回滚不提交
db.endTransaction(); // 处理完成
db.close()
}
- 使用sql语句,将要执行sql进行拼接。但要注意的是,我百度到sql的最大长度为1000000(查API没有找到),所以长度还是要加以限制下。
我给出一些进行sql组装的工具方法,可以按自己的业务修改:
/**
* 获取指定数据库表的字段信息
*/
public EntityBean getTableFieldBean(Context context, String dbname, String table) {
if (null == table || null == context || !BS.pb.isPackageFileExist(context, 1, dbname))
return null;
SqlHelper db = null;
db = new SqlHelper(context, dbname);
SQLiteDatabase sdb = db.getReadableDatabase();
Cursor cur = null;
try {
int size = 0;
cur = (Cursor) sdb.rawQuery("PRAGMA table_info("+table+")", null);
if (null != cur && (size = cur.getCount()) > 0) {
EntityBean bean=new EntityBean();
for (int i = 0; i < size; i++) {
try {
cur.moveToPosition(i);
bean.set(cur.getString(cur.getColumnIndex("name")),"1");
} catch (Exception e) {
continue;
}
}
bean.remove("javaclass");
return bean;
}
return null;
} catch (Exception e) {
BS.pb.outErrorLog(this, "getTableFieldBean", e);
return null;
} finally {
if (null != cur)
cur.close();
if (null != sdb)
sdb.close();
if (null != db)
db.close();
}
}
//EntityBean是继承自LinkedHashMap,存储数据库和网络数据
public String getBeanInsertSql(Context context,String dbname,EntityBean bean){
try {
if(null!=bean){
if(null!=bean.get("javaclass"))
bean.remove("javaclass");
String[] md=null;
EntityBean tableMD=this.getTableFieldBean(context, dbname, bean.getbeanname());
if(null!=tableMD){
tableMD.remove("javaclass");
md=tableMD.getBeanFieldNames();
}else{
return null;
}
if(null!=md&&md.length>0){
int size=md.length;
String table=bean.getbeanname();
StringBuilder sb = new StringBuilder();
StringBuilder sb2= new StringBuilder();
for(int i=0;i<size;i++){
try {
String d = md[i];// 字段名称
if (null != bean.get(d) && !"".equals(bean.get(d) + "")&& !"null".equals(bean.get(d) + "")) {
sb.append(d).append(",");
sb2.append("'"+bean.get(d)+"'").append(",");
}
} catch (Exception e) {
continue;
}
}
String mds = sb+"";
String values = sb2+"";
mds = mds.substring(0, mds.length() - 1);
values = values.substring(0, values.length() - 1);
String sql = "insert into " + table + "(" + mds+ ") VALUES (" + values + ")";
return sql;
}
}
return null;
} catch (Exception e) {
BS.pb.outErrorLog(this, "getBeanInsertSql", e);
return null;
}
}