Android在Sqlite3中的應用及多線程使用數(shù)據(jù)庫的建議(實例代碼)

更新時間：2022年04月24日 15:06:06 作者：水云間1980

這篇文章主要介紹了Android在Sqlite3中的應用及多線程使用數(shù)據(jù)庫的建議,包括編寫數(shù)據(jù)庫具體操作類、增刪改查，通過實例代碼介紹了在實際中的應用，需要的朋友可以參考下

1、首先先建立一個DatabaseHelper類，繼承自SQLiteOpenHelper，用于建立數(shù)據(jù)庫，并可更新數(shù)據(jù)庫例如我新建了兩張表

public class DatabaseHelper extends SQLiteOpenHelper {

    private static DatabaseHelper _databaseHelper;
    private static final String TAG = DatabaseHelper.class.getSimpleName();
    public synchronized static DatabaseHelper getInstance(Context context)
    {
        if(_databaseHelper==null)
        {
            _databaseHelper = new DatabaseHelper(context,"cgjlb",null,2);
        }
        return _databaseHelper;
    }
    public synchronized static void destoryInstance(){
        if(_databaseHelper!=null){
            _databaseHelper=null;
    public DatabaseHelper(@Nullable Context context, @Nullable String name, @Nullable SQLiteDatabase.CursorFactory factory, int version) {
        super(context, name, factory, version);
    @Override
    public void onCreate(SQLiteDatabase sqLiteDatabase) {
        //主表記錄
        String sql = "create table t_share(_id integer primary key autoincrement,sharenum text,sharename text,shareprice real,sharelastprice real,addtime text,uptime text,bl real)";
        sqLiteDatabase.execSQL(sql);
        //記錄歷史表
        sql = "create table t_sharehis(_id integer primary key autoincrement,shareid integer, shareprice real,uptime text)";
    public void onUpgrade(SQLiteDatabase sqLiteDatabase, int i, int i1) {
        Log.d(TAG, "onUpgrade: upddatabase");
        sqLiteDatabase.execSQL("drop table t_share");
        sqLiteDatabase.execSQL("drop table t_sharehis");
        onCreate(sqLiteDatabase);
}

2、編寫數(shù)據(jù)庫具體操作類、增刪改查我都寫了

public class ShareDbService {

    SQLiteDatabase db = null;
    DatabaseHelper databaseHelper;
    private static final String TAG = ShareDbService.class.getSimpleName();
    public ShareDbService(Context context) {
        databaseHelper = DatabaseHelper.getInstance(context);
        db = databaseHelper.getWritableDatabase();
    }
    public void addShareInfo(ShareBean shareBean)
    {
        int Id = getShareId(shareBean.getShareNum());
        if(Id==-1) {
            ContentValues values = new ContentValues();
            values.put("sharenum", shareBean.getShareNum());
            values.put("sharename", shareBean.getShareName());
            values.put("shareprice", shareBean.getSharePrice());
            values.put("sharelastprice", shareBean.getShareLastPrice());
            values.put("uptime", shareBean.getUptime());
            values.put("addtime",shareBean.getAddtime());
            double shareprice = shareBean.getSharePrice();
            double sharelastprice = shareBean.getShareLastPrice();
            double bl = (sharelastprice-shareprice)/shareprice*100;
            values.put("bl", new DecimalFormat("0.00").format(bl));
            db = databaseHelper.getWritableDatabase();
            db.insert("t_share", null, values);
            ShareHisBean shareHisBean = new ShareHisBean();
            shareHisBean.setShareId(getShareId(shareBean.getShareNum()));
            shareHisBean.setSharePrice(shareBean.getSharePrice());
            shareHisBean.setUpTime(shareBean.getUptime());
            addShareHis(shareHisBean);
            db.close();
        }
    private void addShareHis(ShareHisBean shareHisBean){
        ContentValues values = new ContentValues();
        values.put("shareid", shareHisBean.getShareId());
        values.put("shareprice", shareHisBean.getSharePrice());
        values.put("uptime", shareHisBean.getUptime());
        db.insert("t_sharehis", null, values);
        db.close();
    public void refreshShare(ShareHisBean shareHisBean,double sharePrice){
        try {
            //更新信息主表
            values.put("uptime", shareHisBean.getUptime());
            values.put("sharelastprice", shareHisBean.getSharePrice());
            String[] args = {String.valueOf(shareHisBean.getShareId())};
            double sharelastprice = shareHisBean.getSharePrice();
            double bl = (sharelastprice - sharePrice) / sharePrice * 100;
            values.put("bl", bl);
            db.update("t_share", values, "_Id=?", new String[]{String.valueOf(shareHisBean.getShareId())});
            //添加記錄
            values = new ContentValues();
            values.put("shareid", shareHisBean.getShareId());
            values.put("shareprice", shareHisBean.getSharePrice());
            db.insert("t_sharehis", null, values);
        }catch(Exception ex){
            ex.printStackTrace();
        finally {
    public void delShare(String Id){
        db.delete("t_share","_Id=?",new String[]{Id});
        db.delete("t_sharehis","shareid=?",new String[]{Id});
    private int getShareId(String shareNum) {
        db = databaseHelper.getReadableDatabase();
        String sql = "select _Id from t_share where sharenum='" + shareNum + "'";
        int Id = -1;
        Cursor cursor = db.rawQuery(sql, null);
        if (cursor != null) {
            while (cursor.moveToNext()){
                Id = cursor.getInt(0);
            }
        cursor.close();
        return Id;
    public List<ShareBean> getShareList(){
        List<ShareBean> shareBeans = new ArrayList<>();
        String sql = "select _id,sharenum,sharename,shareprice,sharelastprice,uptime,addtime,bl from t_share order by _Id desc";
                ShareBean shareBean = new ShareBean();
                shareBean.set_Id(cursor.getInt(0));
                shareBean.setShareNum(cursor.getString(1));
                shareBean.setShareName(cursor.getString(2));
                shareBean.setSharePrice(cursor.getDouble(3));
                shareBean.setShareLastPrice(cursor.getDouble(4));
                shareBean.setUptime(cursor.getString(5));
                shareBean.setAddtime(cursor.getString(6));
                shareBean.setBl(cursor.getDouble(7));
                shareBeans.add(shareBean);
        return shareBeans;
    public List<ShareHisBean> getShareListHis(int ShareId){
        List<ShareHisBean> shareHisBeans = new ArrayList<>();
        String sql = "select _id,shareid,shareprice,uptime from t_sharehis where shareid='"+String.valueOf(ShareId)+"' order by _id desc";
                ShareHisBean shareHisBean = new ShareHisBean();
                shareHisBean.set_Id(cursor.getInt(0));
                shareHisBean.setShareId(cursor.getInt(1));
                shareHisBean.setSharePrice(cursor.getDouble(2));
                shareHisBean.setUpTime(cursor.getString(3));
                shareHisBeans.add(shareHisBean);
        return shareHisBeans;
    public ShareBean getShareInfo(int ShareId) {
        ShareBean shareBean = new ShareBean();
        //_id integer primary key autoincrement,sharenum text,sharename text,shareprice real,sharelastprice real,addtime text,uptime text,bl real
        String sql = "select _id,sharenum,sharename,shareprice,sharelastprice,addtime,uptime,bl from t_share where _Id='"+String.valueOf(ShareId)+"'";
            if (cursor.moveToNext()){
                shareBean.setAddtime(cursor.getString(5));
                shareBean.setUptime(cursor.getString(6));
        return shareBean;
}

3、實際中的應用，就舉一個例子吧，數(shù)據(jù)庫操作不用開新線程，直接在主線程里弄就行

ShareDbService shareDbService = new ShareDbService(getContext());
 shareDbService.delShare(String.valueOf(shareBean.get_Id()));

4、需要注意的是SQLite不支持多線程，最好是能批量修改，否則很麻煩，如果一定要多線程，比如循環(huán)請求網(wǎng)絡更新數(shù)據(jù)庫時，可以使用CountDownLatch，先將數(shù)據(jù)弄在一個集合里，等子線程全部執(zhí)行完成后，再更新數(shù)據(jù)庫。此方法具體應用如下

先聲明一個變量

CountDownLatch latch;

實際應用代碼

//設置多線程 個數(shù)，一共用多少個線程一定要寫清楚，后面是要減的。
        latch = new CountDownLatch(count);
        for (int i = 0; i < count; i++) {            
            new Thread(()-> {
                try {
                    //網(wǎng)絡請求等操作
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    //這里會自動減1操作，一定要寫。
                    latch.countDown();
                }
            }).start();
        };
        try {
            latch.await();
           //最后執(zhí)行主程序，比如更新數(shù)據(jù)庫
            Toast.makeText(getContext(), "刷新成功", Toast.LENGTH_SHORT).show();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

到此這篇關于Android在Sqlite3中的應用及多線程使用數(shù)據(jù)庫的建議的文章就介紹到這了,更多相關android Sqlite3多線程內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Android使用Intent顯示實現(xiàn)頁面跳轉(zhuǎn)
這篇文章主要為大家詳細介紹了Android使用Intent顯示實現(xiàn)頁面跳轉(zhuǎn)，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2018-08-08
Android多渠道打包時獲取當前渠道的方法
這篇文章主要介紹了Android多渠道打包時獲取當前渠道的方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2020-01-01
解決android studio 打包發(fā)現(xiàn)generate signed apk 消失不見問題
這篇文章主要介紹了解決android studio 打包發(fā)現(xiàn)generate signed apk 消失不見問題，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-09-09
Flutter開發(fā)之路由與導航的實現(xiàn)
這篇文章主要介紹了Flutter開發(fā)之路由與導航的實現(xiàn),文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2019-12-12
Flutter狀態(tài)管理Provider示例解析
這篇文章主要為大家介紹了Flutter狀態(tài)管理Provider示例解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2022-12-12
解析Android 8.1平臺SystemUI 導航欄加載流程
這篇文章主要介紹了Android 8.1平臺SystemUI 導航欄加載流程，非常不錯，具有一定的參考借鑒價值,需要的朋友可以參考下
2019-11-11
Android媒體開發(fā)之音樂播放器
這篇文章主要為大家詳細介紹了Android媒體開發(fā)之音樂播放器，播放SD卡中的音樂，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2017-12-12
Android webView如何輸出自定義網(wǎng)頁
這篇文章主要介紹了Android webView如何輸出自定義網(wǎng)頁,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-09-09
Android6.0動態(tài)申請權限所遇到的問題小結
這篇文章給大家介紹了Android6.0動態(tài)申請權限所遇到的問題，在沒給大家介紹這下問題之前，先給大家說下基本定義和基本使用方式，本文給大家介紹的非常詳細，具有參考借鑒價值，對android 6.0 動態(tài)權限遇到問題感興趣的朋友一起看看吧
2016-11-11
Android之內(nèi)置和外置sdcard路徑顯示并且寫入數(shù)據(jù)的方法
今天小編就為大家分享一篇Android之內(nèi)置和外置sdcard路徑顯示并且寫入數(shù)據(jù)的方法，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2018-08-08