sqlite使用总结

2016-08-08 本文已影响493人求闲居士

把最近使用数据库的经验总结下。

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;
    }
}

sqlite使用总结

1，获取数据库对象SQLiteDatabase

扩展

2，多线程操作

3，读写数据库优化

猜你喜欢

热点阅读