Android数据存储---SQLite-白红宇

Android数据存储---SQLite

阅读量：5748 次

发布时间：2019-06-18

本文共 6695 字，大约阅读时间需要 22 分钟。

SQLite是一款轻量级数据库，支持大部分SQL语句。

下面我们来看看如何使用：

1.写一个工具类继承SQLiteOpenHelper，建数据库，建person表

import android.content.Context;import android.database.sqlite.SQLiteDatabase;import android.database.sqlite.SQLiteOpenHelper;public class DBOpenHelper extends SQLiteOpenHelper {            // 定义工具类, 继承SQLiteOpenHelper		public DBOpenHelper(Context context) {			// 创建对象的时候, 需要传入上下文环境		super(context, "itcast.db", null, 4);		/*		 * 由于父类没有无参构造函数, 必须显式调用有参的构造函数		 * 参数1: 上下文环境, 用来确定数据库文件存储的目录		 * 参数2: 数据库文件的名字		 * 参数3: 生成游标的工厂, 填null就是使用默认的		 * 参数4: 数据库的版本, 从1开始，只能从低版本更新到高版本		 */	}	@Override	public void onCreate(SQLiteDatabase db) {		System.out.println("onCreate");		db.execSQL("CREATE TABLE person(id INTEGER PRIMARY KEY AUTOINCREMENT, name VARCHAR(20))");		// 执行SQL语句, 创建表	}	//数据库版本更新时调用此方法	@Override	public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {		System.out.println("onUpgrade");		db.execSQL("ALTER TABLE person ADD balance INTEGER");	}}

2.对Person对象进行增删改查

import java.util.ArrayList;import java.util.List;import cn.itcast.sqlite.domain.Person;import android.content.ContentValues;import android.content.Context;import android.database.Cursor;import android.database.sqlite.SQLiteDatabase;public class PersonDao {	private DBOpenHelper helper;		public PersonDao(Context context) {		helper = new DBOpenHelper(context);	}	public void insert(Person p) {		SQLiteDatabase db = helper.getWritableDatabase();	        // 获取数据库连接(可写的)		ContentValues values = new ContentValues();			// 类似于Map的容器, 键是String, 用来存放列名, 值是Object, 用来存要插入的数据		values.put("name", p.getName());				// 某些情况下, 程序会接收一个ContentValues参数, 这时用这种方式存储比较方便		values.put("balance", p.getBalance());		/*		 * 参数1：表名		 * 参数2：用于指定空值字段的名称		 * 参数3：插入的参数，null 表示用来在想插入一条除了主键全部为空的记录时使用		 * 返回：插入记录的id		 */		long id = db.insert("person", null, values);						System.out.println("插入的记录的id是: " + id);		db.close();	}		public void delete(int id) {		SQLiteDatabase db = helper.getWritableDatabase();		int rows = db.delete("person", "id=?", new String[] { id + "" });		System.out.println("删除了" + rows + "行");		db.close();	}	public void update(Person p) {		SQLiteDatabase db = helper.getWritableDatabase();		ContentValues values = new ContentValues();		values.put("name", p.getName());		values.put("balance", p.getBalance());		int rows = db.update("person", values, "id=?", new String[] { p.getId() + "" });		System.out.println("更新了" + rows + "行");		db.close();	}		//query one	public Person query(int id) {		SQLiteDatabase db = helper.getReadableDatabase();			// 获取数据库连接(可读的)		Cursor c = db.query("person", new String[] { "name", "balance" }, "id=?", new String[] { id + "" }, null, null, null);		Person p = null;		if (c.moveToNext()) {															// 判断游标是否包含下一条记录, 如果包含将游标向后移动一位			String name = c.getString(c.getColumnIndex("name"));		// 获取"name"字段的索引, 然后根据索引获取数据			int balance = c.getInt(1);												// 获取1号索引上的数据			p = new Person(id, name, balance);			}		c.close();		db.close();		return p;	}	//查询所有	public List
    
      queryAll() {		SQLiteDatabase db = helper.getReadableDatabase();							Cursor c = db.query("person", null, null, null, null, null, null);		List
     
       persons = new ArrayList
      
       ();		while (c.moveToNext()) {													Person p = new Person(c.getInt(0), c.getString(1), c.getInt(2));			persons.add(p);		}		c.close();		db.close();		return persons;	}	//此方法是在ListView设置SimpleCursorAdapter适配器时调用	public Cursor queryAllCursor() {		SQLiteDatabase db = helper.getReadableDatabase();						 /*         * 使用Cursor相关的Adapter时需要一个自增的列，且名字必需为 _id         */		Cursor c = db.query("person", new String[] { "id _id", "name", "balance" }, null, null, null, null, null);		return c;	}	//查询有多少记录	public int queryCount() {		SQLiteDatabase db = helper.getReadableDatabase();							Cursor c = db.query("person", new String[]{ "COUNT(*)" }, null, null, null, null, null);			c.moveToNext();		int count = c.getInt(0);		c.close();		db.close();		return count;	}	//分页	public List
       
         queryPage(int pageNum, int capacity) {				String offset = (pageNum - 1) * capacity + "";		// 偏移量		String len = capacity + "";									// 个数		SQLiteDatabase db = helper.getReadableDatabase();							Cursor c = db.query("person", null, null, null, null, null, null, offset + "," + len);			List
        
          persons = new ArrayList
         
          (); while (c.moveToNext()) { Person p = new Person(c.getInt(0), c.getString(1), c.getInt(2)); persons.add(p); } c.close(); db.close(); return persons; } //使用事物提交 public void remit(int from, int to, int amount) { SQLiteDatabase db = helper.getWritableDatabase(); try { db.beginTransaction(); // 开始事务 db.execSQL("UPDATE person SET balance=balance-? WHERE id=?", new Object[] { amount, from }); db.execSQL("UPDATE person SET balance=balance+? WHERE id=?", new Object[] { amount, to }); db.setTransactionSuccessful(); // 设置成功点, 在事务结束时, 成功点之前的操作会被提交 } finally { db.endTransaction(); // 结束事务, 将成功点之前的操作提交 db.close(); } } }

3.写一个Test类，测试方法

import java.util.List;import cn.itcast.sqlite.domain.Person;import android.database.Cursor;import android.test.AndroidTestCase;public class DBTest extends AndroidTestCase {	public void testCreateDatabase() {		DBOpenHelper helper = new DBOpenHelper(getContext());		helper.getWritableDatabase();			/*		 * 获取可写的数据连接		 * 数据库文件不存在时, 会创建数据库文件, 并且执行onCreate()方法		 * 数据库文件存在, 并且版本没有改变时, 不执行任何方法		 * 数据库文件存在, 版本提升, 执行onUpgrade()方法		 */	}		public void testInsert() {		PersonDao dao = new PersonDao(getContext());		dao.insert(new Person("xxx", 9999));	}		public void testDelete() {		PersonDao dao = new PersonDao(getContext());		dao.delete(106);	}		public void testUpdate() {		PersonDao dao = new PersonDao(getContext());		dao.update(new Person(2, "李四", 10000));		dao.update(new Person(3, "王五", 10000));	}		public void testQuery() {		PersonDao dao = new PersonDao(getContext());		System.out.println(dao.query(5));	}		public void testQueryAll() {		PersonDao dao = new PersonDao(getContext());		List
    
      persons = dao.queryAll();		for (Person p : persons)			System.out.println(p);	}		public void testQueryCount() {		PersonDao dao = new PersonDao(getContext());		System.out.println(dao.queryCount());	}		public void testQueryPage() {		PersonDao dao = new PersonDao(getContext());		List
     
       persons = dao.queryPage(2, 10);		for (Person p : persons)			System.out.println(p);	}		public void testRemit() {		PersonDao dao = new PersonDao(getContext());		dao.remit(3, 2, 1000);	}	public void testQueryAllCursor(){		PersonDao dao = new PersonDao(getContext());		Cursor c=dao.queryAllCursor();		while(c.moveToNext()){			System.out.println(c.getString(c.getColumnIndex("name")));		}	}	}