把最近使用数据库的经验总结下。
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;
}
}
网友评论