Android Sqlite简单使用

1. 介绍

SQLite,是一款轻型的数据库,它能够支持Windows/Linux/Unix等等主流的操作系统,同样比起Mysql、PostgreSQL这两款开源的世界著名数据库管理系统来讲,它的处理速度比他们都快。Android系统支持SqliLite数据库。

2. 创建

建立Sqlite 数据库初始化文件 MyDBHelper.java ,其继承 SQLiteOpenHelper,实现构造函数,在其中创建名称为创建名称为 ”test.db“的,版本号为1的数据库,具体代码如下:

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

/**
 * 作者:周洲 on 2016/11/23 19:42
 * <p>
 * 邮箱:double0zhou@126.com
 */

public class MyDBHelper extends SQLiteOpenHelper {

    public MyDBHelper(Context context){
        super(context,"test.db",null,1);//创建名称为 ”test.db“的,版本号为1的数据库
    }

    @Override
    public void onCreate(SQLiteDatabase sqLiteDatabase) {

    }

    @Override
    public void onUpgrade(SQLiteDatabase sqLiteDatabase, int i, int i1) {

    }
}

在数据中创建自己所需的数据表,例如创建名称为testTable的数据表,其sql语言如下:

CREATE TABLE testTable (id INTEGER PRIMARY KEY AUTOINCREMENT,name text,sex text) //创建表 testTable ,其中id 为数字类型主键,并且自增长,name 为文本类型,sex为文本类型

在MyDBHelper的onCreate中创建上述表,代码如下:

    @Override
    public void onCreate(SQLiteDatabase sqLiteDatabase) {
        String sql ="CREATE TABLE testTable (id integer primary key autoincrement,name text,sex text)";
        sqLiteDatabase.execSQL(sql);
    }

此时,MyDBHelper 基础版完成。

3.使用

在数据表testTable 中插入一条数据:

INSERT INTO testTable (name,sex) VALUES('张三','男')

在Activity代码中使用如下:

                String sqlInsert="INSERT INTO testTable (name,sex) VALUES('张三','男')";//向数据表testTable中华插入一条数据
                MyDBHelper myDBHelper = new MyDBHelper(MainActivity.this);
                SQLiteDatabase sqLiteDatabase = myDBHelper.getWritableDatabase();
                sqLiteDatabase.execSQL(sqlInsert);
                sqLiteDatabase.close();
                myDBHelper.close();

在testTable 中查询数据

SELECT * FROM testTable //查询testTable 中所有数据

MainActivity中查询的代码:

                String sqlStr = "SELECT * FROM testTable";
                MyDBHelper myDBHelper1 = new MyDBHelper(MainActivity.this);
                SQLiteDatabase sqLiteDatabase1 = myDBHelper1.getReadableDatabase();
                Cursor cursor = sqLiteDatabase1.rawQuery(sqlStr, null);
                for (cursor.moveToFirst(); !cursor.isAfterLast(); cursor.moveToNext()) {
                    int id = cursor.getInt(0);
                    String name = cursor.getString(1);
                    String sex = cursor.getString(2);
                    HashMap<String,String>  map = new HashMap<>();
                    map.put("name",name);
                    map.put("sex",sex);
                    list.add(map);
                }
                if (cursor != null) {
                    cursor.close();
                }
                sLiteDatabase1.close();
                myDBHelper1.close();

上述方法包含了两种数据库操作,分别为无返回的数据库操作和有返回的数据库操作,此两种数据库操作基本可以实现sqlite增删改查四项基础功能。

4.封装

query,insert,update,delete 分别为Android 封装的查询、插入、更新、删除操作,方便了大家的使用。

insert(String table,String nullColumnHack,ContentValuesvalues)
参数1 表名称
参数2 空列的默认值
参数3 ContentValues类型的一个封装了列名称和列值的Map;

private void insert(SQLiteDatabase db){   
//实例化常量值   
ContentValues cValue = new ContentValues();   
//添加用户名   
cValue.put("sname","xiaoming");   
//添加密码   
cValue.put("snumber","01005");   
//调用insert()方法插入数据   
db.insert("stu_table",null,cValue);   
}   

delete(String table,String whereClause,String[] whereArgs)
参数1 表名称
参数2 删除条件
参数3 删除条件值数组

private void delete(SQLiteDatabase db) {   
//删除条件   
String whereClause = "id=?";   
//删除条件参数   
String[] whereArgs = {String.valueOf(2)};   
//执行删除   
db.delete("stu_table",whereClause,whereArgs);   
}   

update(String table,ContentValues values,String whereClause, String[] whereArgs)
参数1 表名称
参数2 跟行列ContentValues类型的键值对Key-Value
参数3 更新条件(where字句) 参数4 更新条件数组

private void update(SQLiteDatabase db) {   
//实例化内容值 ContentValues values = new ContentValues();   
//在values中添加内容   
values.put("snumber","101003");   
//修改条件   
String whereClause = "id=?";   
//修改添加参数   
String[] whereArgs={String.valuesOf(1)};   
//修改   
db.update("usertable",values,whereClause,whereArgs);   
}   

public Cursor query(String table,String[] columns,String selection,String[] selectionArgs,String groupBy,String having,String orderBy,String limit);

各个参数的意义说明:

参数table:表名称

参数columns:列名称数组

参数selection:条件字句,相当于where

参数selectionArgs:条件字句,参数数组

参数groupBy:分组列

参数having:分组条件

参数orderBy:排序列

参数limit:分页查询限制

参数Cursor:返回值,相当于结果集ResultSet

Cursor是一个游标接口,提供了遍历查询结果的方法,如移动指针方法move(),获得列值方法getString()等.

Cursor游标常用方法

方法名称 方法描述 getCount() 获得总的数据项数 isFirst() 判断是否第一条记录 isLast() 判断是否最后一条记录
moveToFirst() 移动到第一条记录 moveToLast() 移动到最后一条记录 move(int offset) 移动到指定记录
moveToNext() 移动到下一条记录 moveToPrevious() 移动到上一条记录
getColumnIndexOrThrow(String columnName) 根据列名称获得列索引 getInt(int
columnIndex) 获得指定列索引的int类型值 getString(int columnIndex)
获得指定列缩影的String类型值

private void query(SQLiteDatabase db) {   
//查询获得游标   
Cursor cursor = db.query ("usertable",null,null,null,null,null,null);   
for (cursor.moveToFirst(); !cursor.isAfterLast(); cursor.moveToNext()) {
                Object obj = cls.newInstance();
                for (int i = 0; i < cursor.getColumnCount(); i++) {
                    //cursor.getString(i)
                    }
                }
                resultList.add(obj);
            }
            if (cursor != null) {
                cursor.close();
            }
}  

5.数据库的升级

onUpgrade 数据库的升级

        if (oldVersion < DATABASE_VERSION) {
            try {
                 onCreate(db);
              //  UpdateDB(db);
            } catch (Exception e) {
                // TODO: handle exception
                Log.e("Sql_error", e.getMessage().toString());
            }
        }

6.数据的批量操作

beginTransaction,endTransaction

        DBHelper db = new DBHelper(context);
        SQLiteDatabase dataBase = db.getWritableDatabase();
        try {
            dataBase.beginTransaction(); // 手动设置开始事务
            for (int i = 0; i < jsonArray.length(); i++) {
                JSONObject itemdata = (JSONObject) jsonArray.get(i);
                dataBase.insert(cls.getSimpleName(), null, InSertContentValues(cls, itemdata));
            }
            dataBase.setTransactionSuccessful(); // 设置事务处理成功,不设置会自动回滚不提交
            Log.i("SQLite", "Success insert info into SqliteDatabase " + cls.getSimpleName());

        } catch (Exception e) {
            Log.e("SQLite ERROR " + cls.getSimpleName(), e.getMessage().toString());
        } finally {
            dataBase.endTransaction(); // 处理完成
            dataBase.close();
            db.close();
        }

7.数据库的封装

单例模式

public class SingletonC {  

/** 
    * 单例对象实例 
     */  
    private static SingletonKerriganD instance = null;  
  
    public static SingletonC getInstance() {  
       if (instance == null) {  
            synchronized (SingletonC.class) {  
               if (instance == null) {  
instance = new SingletonC();  
}  
}  
      }  
        return instance;  
}  
}  

源碼鏈接

点赞