Android编程之SQLite数据库操作方法详解

public class AccountTable {
 public static final String TABLE_NAME = "account_table";
 public static final String UID = "uid";
 public static final String USERNAME = "username";
 public static final String USERNICK = "usernick";
 public static final String AVATAR_URL = "avatar_url";
 public static final String PORTRAIT = "portrait";
 public static final String OAUTH_TOKEN = "oauth_token";
 public static final String OAUTH_TOKEN_SECRET = "oauth_token_secret";
 public static final String INFOJSON = "json";
}

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import org.qii.weiciyuan.support.database.table.*;
class DatabaseHelper extends SQLiteOpenHelper {
 private static DatabaseHelper singleton = null;
 private static final String DATABASE_NAME = "weibo.db";
 private static final int DATABASE_VERSION = 16;
 static final String CREATE_ACCOUNT_TABLE_SQL = "create table " + AccountTable.TABLE_NAME
   + "("
   + AccountTable.UID + " integer primary key autoincrement,"
   + AccountTable.OAUTH_TOKEN + " text,"
   + AccountTable.OAUTH_TOKEN_SECRET + " text,"
   + AccountTable.PORTRAIT + " text,"
   + AccountTable.USERNAME + " text,"
   + AccountTable.USERNICK + " text,"
   + AccountTable.AVATAR_URL + " text,"
   + AccountTable.INFOJSON + " text"
   + ");";
 DatabaseHelper(Context context) {
  super(context, DATABASE_NAME, null, DATABASE_VERSION);
 }
 @Override
 public void onCreate(SQLiteDatabase db) {
  db.execSQL(CREATE_ACCOUNT_TABLE_SQL);
 }
 @Override
 public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
  switch (oldVersion) {
   default:
    deleteAllTable(db);
    onCreate(db);
  }
 }
 public static synchronized DatabaseHelper getInstance() {
  if (singleton == null) {
   singleton = new DatabaseHelper(GlobalContext.getInstance());
  }
  return singleton;
 }
 private void deleteAllTable(SQLiteDatabase db) {
  db.execSQL("DROP TABLE IF EXISTS " + AccountTable.TABLE_NAME);
 }
}

package com.hw.droid.hwcatalog;
public class DatabaseManager {
 private static DatabaseManager singleton = null;
 private SQLiteDatabase wsd = null;
 private SQLiteDatabase rsd = null;
 private DatabaseManager() {
 }
 public static DatabaseManager getInstance(Context context) {
  if (singleton == null) {
   synchronized (DatabaseManager.class) {
    if (singleton == null) {
     DatabaseHelper databaseHelper = DatabaseHelper.getInstance(context);
     singleton = new DatabaseManager();
     singleton.wsd = databaseHelper.getWritableDatabase();
     singleton.rsd = databaseHelper.getReadableDatabase();
    }
   }
  }
  return singleton;
 }
 public void initAccountTable(List<AccountData> listDatas) {
  if (listDatas == null || listDatas.size() <= 0) {
   return;
  }
  wsd.beginTransaction();
  try {
   for (AccountData data : listDatas) {
    insertAccountTable(data);
   }
   wsd.setTransactionSuccessful();
  } finally {
   wsd.endTransaction();
  }
 }
 private void insertAccountTable(AccountData accData) {
  String sql = "insert into " + AccountTable.TABLE_NAME + "(" + AccountTable.USERNAME + ", "
    + AccountTable.USERNICK + ", " + AccountTable.AVATAR_URL + ", " + AccountTable.PORTRAIT + ", "
    + AccountTable.OAUTH_TOKEN + ", " + AccountTable.OAUTH_TOKEN_SECRET + ", " + AccountTable.INFOJSON
    + " " + ")" + " values(?, ?, ?, ?, ?, ?, ?)";
  wsd.execSQL(sql,
    new Object[] { accData.getUserName(), accData.getUserNick(), accData.getUrl(), accData.getPort(),
      accData.getToken(), accData.getSecret(), accData.getJson(), accData.getThreads(), });
 }
 public List<AccountData> getAccountDatas() {
  List<AccountData> listDatas = selectAccountData();
  return listDatas;
 }
 private List<AccountData> selectAccountData() {
  List<AccountData> listAccountData = new ArrayList<AccountData>();
  String querySql = "select " + AccountTable.USERNAME + ", " + AccountTable.USERNICK + ", " + AccountTable.AVATAR_URL + ", " + AccountTable.PORTRAIT + ", " + AccountTable.OAUTH_TOKEN + ", " + AccountTable.OAUTH_TOKEN_SECRET + ", " + AccountTable.INFOJSON " " + " from " + BbsForumsTable.TABLE_NAME;
  Cursor cursor = rsd.rawQuery(querySql, null);
  if (cursor.moveToFirst()) {
   do {
    AccountData data = new AccountData();
    data.setUserName(cursor.getString(cursor.getColumnIndex(AccountTable.USERNAME)));
    data.setUserNick(cursor.getString(cursor.getColumnIndex(AccountTable.USERNICK)));
    data.setUrl(cursor.getString(cursor.getColumnIndex(AccountTable.AVATAR_URL)));
    data.setPort(cursor.getString(cursor.getColumnIndex(AccountTable.PORTRAIT)));
    data.setToken(cursor.getString(cursor.getColumnIndex(AccountTable.OAUTH_TOKEN)));
    data.setSecret(cursor.getString(cursor.getColumnIndex(AccountTable.OAUTH_TOKEN_SECRET)));
    data.setJson(cursor.getString(cursor.getColumnIndex(AccountTable.INFOJSON)));
    listAccountData.add(data);
   } while (cursor.moveToNext());
  }
  cursor.close();
  return listAccountData;
 }
 public void deleteBbsDatas() {
  String delSql = "delete from " + AccountTable.TABLE_NAME;
  wsd.execSQL(delSql);
 }
}

public void initAccountTable(List<AccountData> listDatas) {
 if (listDatas == null || listDatas.size() <= 0) {
  return;
 }
 wsd.beginTransaction();
 try {
  for (AccountData data : listDatas) {
   insertAccountTable(data);
  }
  wsd.setTransactionSuccessful();
 } finally {
  wsd.endTransaction();
 }
}