react-native 数据存储与读取 Storage 和 Sqlite

Storage


export async function getValueByKey(key,
                                    callback = () => {
                                    },
                                    callbackError = () => {
                                        ViewUtil.showToast(key + ' not found!');
                                    }) {
    try {
        var ret = await storage.load({
            key: key,
        });
        if (callback) {
            callback(ret);

        }
        return ret;
    } catch (e) {
        callbackError();
    }
}


export async function setKeyValue(  key, 
                                    value,
                                    callbackError = () => {
                                        ViewUtil.showToast(key + ':' + value + ' save error!');
                                    }) {
    try {
        storage.save({ key: key, data: value });
    } catch (e) {
        callbackError();
    }
}

Sqlite

SQLiteUtil.js

/**
 * Created by nick on 2017/6/9.
 */
import React, { Component } from 'react';
import SQLiteStorage from 'react-native-sqlite-storage';
import * as ConstantUtil from './ConstantUtil';
import * as ViewUtil from './ViewUtil';
import * as StorageUtil from './StorageUtil';
SQLiteStorage.DEBUG(ConstantUtil.config.sqliteDebuggable);
SQLiteStorage.enablePromise(false);

var database_name = ConstantUtil.config.sqliteDbName;//数据库文件
var database_version = ConstantUtil.config.sqliteDbVersion;//版本号
var database_displayname = ConstantUtil.config.sqliteDbDisplayName;
var database_size = ConstantUtil.config.sqliteDbSize;//-1应该是表示无限制
var db;
export default class SQLiteUtil extends Component {

    //TODO 数据库开关
    componentWillUnmount() {
        if (db) {
            this._successCB('close');
            db.close();
        } else {
            console.log('SQLiteStorage not open');
        }
    }

    open() {
        // {name: 'testDB', createFromLocation : 1},
        db = SQLiteStorage.openDatabase(
            database_name,
            database_version,
            database_displayname,
            database_size,
            () => {
                this._successCB('open');
            },
            (err) => {
                this._errorCB('open', err);
            });
        return db;
    }

    createTable() {
        if (!db) {
            this.open();
        }
        console.log(db);
        //创建用户表
        db.transaction((tx) => {
            tx.executeSql('CREATE TABLE IF NOT EXISTS t_order (' +
                'id INTEGER PRIMARY KEY  AUTOINCREMENT,' +
                'orderId VARCHAR,' +
                'createTime VARCHAR,' +
                'nowHolderId VARCHAR,' +
                'nowHolderName VARCHAR,' +
                'lastHolderId VARCHAR,' +
                'lastHolderName VARCHAR)'
                , [], () => {
                    this._successCB('executeSql');
                }, (err) => {
                    this._errorCB('executeSql', err);
                });
        }, (err) => {//所有的 transaction都应该有错误的回调方法，在方法里面打印异常信息，不然你可能不会知道哪里出错了。
            this._errorCB('transaction', err);
        }, () => {
            this._successCB('transaction');
        });
    }

    deleteData() {
        if (!db) {
            this.open();
        }
        db.transaction((tx) => {
            tx.executeSql('delete from t_order', [], () => {

            });
        });
    }

    dropTable() {
        db.transaction((tx) => {
            tx.executeSql('drop table t_order', [], () => {

            });
        }, (err) => {
            this._errorCB('transaction', err);
        }, () => {
            this._successCB('transaction');
        });
    }

    close() {
        if (db) {
            this._successCB('close');
            db.close();
        } else {
            console.log('SQLiteStorage not open');
        }
        db = null;
    }

    _successCB(name) {
        console.log('SQLiteStorage ' + name + ' success');
    }

    _errorCB(name, err) {
        console.log('SQLiteStorage ' + name);
        console.log(err);
    }

    render() {
        return null;
    }


    //TODO 数据库升级
    checkDataBaseUpdata() {
        StorageUtil.getValueByKeyDbVersion((ret) => {
            console.log(ret);
            let version = ret;
            if (version < database_version) {

                switch (version) {
                case 1:
                    this.migrateV1toV2();
                    // case 2:
                    //     migrateV2toV3();
                }

                StorageUtil.setValueOfDbVersion(database_version);
            }
        });

    }


    migrateV1toV2() {

        this.createTableOrderMessageCountAndTaskReportCount();

    }


    createTableOrderMessageCountAndTaskReportCount() {
        if (!db) {
            this.open();
        }
        console.log(db);
        //创建用户表
        db.transaction((tx) => {
            tx.executeSql('CREATE TABLE IF NOT EXISTS tOrderMessageCountAndTaskReportCount (' +
                'id INTEGER PRIMARY KEY  AUTOINCREMENT,' +
                'orderId VARCHAR,' +
                'messageCount INTEGER,' +
                'taskReportCount INTEGER)'
                , [], () => {
                    this._successCB('executeSql');
                }, (err) => {
                    this._errorCB('executeSql', err);
                });
        }, (err) => {//所有的 transaction都应该有错误的回调方法，在方法里面打印异常信息，不然你可能不会知道哪里出错了。
            this._errorCB('transaction', err);
        }, () => {
            this._successCB('transaction');
        });
    }


    //todo 增删改查

    insertOrderData(orderData) {
        let len = orderData.length;
        if (!db) {
            this.open();
        }
        this.createTable();
        // this.deleteData();
        db.transaction((tx) => {
            for (let i = 0; i < len; i++) {
                let order = orderData[i];
                if (
                    order
                    && order.orderId
                    && order.createTime

                ) {
                    let orderId = order.orderId;
                    let createTime = order.createTime;
                    let nowHolderId = order.nowHolderId;
                    let nowHolderName = order.nowHolderName;
                    let lastHolderId = order.lastHolderId;
                    let lastHolderName = order.lastHolderName;


                    let sql = 'INSERT INTO t_order(orderId,createTime,nowHolderId,nowHolderName,lastHolderId,lastHolderName)' +
                        'values(?,?,?,?,?,?)';
                    tx.executeSql(sql, [orderId, createTime, nowHolderId, nowHolderName, lastHolderId, lastHolderName], () => {

                    }, (err) => {
                        console.log(err);
                    }
                    );
                }

            }
        }, (error) => {
            this._errorCB('transaction', error);
            ViewUtil.showToast('数据插入失败');
        }, () => {
            this._successCB('transaction insert data');
            ViewUtil.showToast('成功插入 ' + len + ' 条工单数据');
        });
    }


    selectAllOrderData(callback) {
        var orderData = [];
        let len = orderData.length;
        if (!db) {
            this.open();
        }
        // this.createTable();

        db.transaction((tx) => {
            tx.executeSql('SELECT * FROM t_order', [], (tx, results) => {
                console.log('Query completed');
                console.log(tx);
                console.log(results);
                callback(results.rows);
                // Get rows with Web SQL Database spec compliance.
                //
                // var len = results.rows.length;
                // for (let i = 0; i < len; i++) {
                //     let row = results.rows.item(i);
                //     console.log(`Record: ${row.name}`);
                // }
            });
        });

    }


    updateOrInsertOrderData(orderData) {
        if (!db) {
            this.open();
        }
        this.createTable();
        // this.deleteData();
        db.transaction((tx) => {
            let order = orderData;
            if (
                order
                && order.orderId
                && order.createTime

            ) {
                let orderId = order.orderId;
                let createTime = order.createTime;
                let nowHolderId = order.nowHolderId;
                let nowHolderName = order.nowHolderName;
                let lastHolderId = order.lastHolderId;
                let lastHolderName = order.lastHolderName;


                tx.executeSql('SELECT * FROM t_order where orderId=?', [orderId], (tx, results) => {
                    console.log('Query completed');
                    console.log(tx);
                    console.log(results);

                    if (0 < results.rows.length) {//update
                        let sql = 'UPDATE t_order SET createTime = ? nowHolderId = ? nowHolderName = ? lastHolderId = ? lastHolderName = ? WHERE orderId = ?;';
                        tx.executeSql(sql, [createTime, nowHolderId, nowHolderName, lastHolderId, lastHolderName, orderId], () => {

                        }, (err) => {
                            console.log(err);
                        }
                        );
                    } else {//insert
                        let sql = 'INSERT INTO t_order(orderId,createTime,nowHolderId,nowHolderName,lastHolderId,lastHolderName)' +
                            'values(?,?,?)';
                        tx.executeSql(sql, [orderId, createTime, nowHolderId, nowHolderName, lastHolderId, lastHolderName], () => {

                        }, (err) => {
                            console.log(err);
                        }
                        );
                    }
                });


            }


        }, (error) => {
            this._errorCB('transaction', error);
            ViewUtil.showToast('数据插入失败');
        }, () => {
            this._successCB('transaction insert data');
            ViewUtil.showToast('成功插入工单数据');
        });
    }


    //TableOrderMessageCountAndTaskReportCount
    selectFromTableOrderMessageCountAndTaskReportCountByOrderId(callback, orderId) {
        // return;
        let orderData = { orderId: orderId, messageCount: 0, taskReportCount: 0 };
        if (!db) {
            this.open();
        }

        db.transaction((tx) => {
            tx.executeSql('SELECT * FROM tOrderMessageCountAndTaskReportCount where orderId=?', [orderId], (tx, results) => {
                console.log('Query completed');
                console.log(tx);
                console.log(results);
                callback(results.rows);
                // Get rows with Web SQL Database spec compliance.
                //
                // var len = results.rows.length;
                // for (let i = 0; i < len; i++) {
                //     let row = results.rows.item(i);
                //     console.log(`Record: ${row.name}`);
                // }
            });
        });
    }


    updateOrInsertDataTableOrderMessageCountAndTaskReportCount(orderData) {
        // return ;
        if (!db) {
            this.open();
        }
        this.createTableOrderMessageCountAndTaskReportCount();
        db.transaction((tx) => {
            let order = orderData;
            if (
                order
                && order.orderId

            ) {
                let orderId = order.orderId;
                let messageCount = order.messageCount || 0;
                let taskReportCount = order.taskReportCount || 0;


                tx.executeSql('SELECT * FROM tOrderMessageCountAndTaskReportCount where orderId=?', [orderId], (tx, results) => {
                    console.log('Query completed');
                    console.log(tx);
                    console.log(results);
                    console.log(order);

                    if (0 < results.rows.length) {//update
                        let sql = 'UPDATE tOrderMessageCountAndTaskReportCount SET messageCount = ?, taskReportCount = ? WHERE orderId = ?;';
                        console.log(sql);
                        tx.executeSql(sql, [messageCount, taskReportCount, orderId], () => {
                            global.TmpDataUtil.orderMessageCountOld = messageCount;
                            global.TmpDataUtil.orderTaskReportCountOld = taskReportCount;
                        }, (err) => {
                            console.log(err);
                        }
                        );
                    } else {//insert
                        let sql = 'INSERT INTO tOrderMessageCountAndTaskReportCount(orderId,messageCount,taskReportCount)' +
                            'values(?,?,?)';
                        console.log(sql);

                        tx.executeSql(sql, [orderId, messageCount, taskReportCount], () => {
                            global.TmpDataUtil.orderMessageCountOld = messageCount;
                            global.TmpDataUtil.orderTaskReportCountOld = taskReportCount;
                        }, (err) => {
                            console.log(err);
                        }
                        );
                    }
                });


            }


        }, (error) => {
            this._errorCB('transaction', error);
            ViewUtil.showToast('数据插入失败');
        }, () => {
            this._successCB('transaction insert data');
            // ViewUtil.showToast('成功插入工单数据');
        });
    }


}

ConstantUtil.js


var ConstantUtil = {
    config: {
        sqliteDebuggable: false,
        sqliteDbDisplayName: 'testDb',
        sqliteDbName: 'test.db',
        sqliteDbVersion: 2,
        sqliteDbSize: -1,//-1应该是表示无限制
    },
};

module.exports = ConstantUtil;

最后编辑于：2017.12.11 02:13:31

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 212,332评论 6赞 493
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,508评论 3赞 385
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 157,812评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,607评论 1赞 284
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,728评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 49,919评论 1赞 290
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 39,071评论 3赞 410
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,802评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,256评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,576评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,712评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,389评论 4赞 332
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 40,032评论 3赞 316
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,798评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,026评论 1赞 266
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,473评论 2赞 360
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,606评论 2赞 350

react-native 数据存储与读取 Storage 和 Sqlite

Storage

Sqlite

推荐阅读更多精彩内容