八、android的SQLite数据库操作

我不是女神ヾ 2022-10-17 11:23 253阅读 0赞

在Android平台上，集成了一个嵌入式关系型数据库—SQLite，SQLite3支持 NULL、INTEGER、REAL（浮点数字）、TEXT(字符串文本)和BLOB(二进制对象)数据类型，虽然它支持的类型只有五种，但实际上sqlite3也接受varchar(n)、char(n)、decimal(p,s) 等数据类型，只不过在运算或保存时会转成对应的五种数据类型。SQLite最大的特点是你可以把各种类型的数据保存到任何字段中，而不用关心字段声明的数据类型是什么。例如：可以在Integer类型的字段中存放字符串，或者在布尔型字段中存放浮点数，或者在字符型字段中存放日期型值。但有一种情况例外：定义为INTEGER PRIMARY KEY的字段只能存储64位整数， 当向这种字段保存除整数以外的数据时，将会产生错误。 另外，SQLite在解析CREATETABLE 语句时，会忽略 CREATE TABLE 语句中跟在字段名后面的数据类型信息，如下面语句会忽略 name字段的类型信息

CREATE TABLE person (personid integer primary key autoincrement, name varchar(20))

SQLite可以解析大部分标准SQL语句，如：

查询语句：select \* from  表名 where 条件子句 group by 分组字句 having ... orderby 排序子句

如：select \* from person

select \* from person order by id desc

select name from person group by name having count(\*)>1

分页SQL与mysql类似，下面SQL语句获取5条记录，跳过前面3条记录

select \* from Account limit 5 offset 3 或者 select \* fromAccount limit 3,5

插入语句：insert into  表名(字段列表) values(值列表)。如： insert intoperson(name, age) values(‘名称’,3)

更新语句：update 表名 set 字段名=值 where 条件子句。如：update person set name=‘名称‘ where id=10

删除语句：delete from 表名 where 条件子句。如：delete from person  where id=10

我们在编写数据库应用软件时，需要考虑这样的问题：因为我们开发的软件可能会安装在很多用户的手机上，如果应用使用到了SQLite数据库，我们必须在用户初次使用软件时创建出应用使用到的数据库表结构及添加一些初始化记录，另外在软件升级的时候，也需要对数据表结构进行更新。那么，我们如何才能实现在用户初次使用或升级软件时自动在用户的手机上创建出应用需要的数据库表呢？总不能让我们在每个需要安装此软件的手机上通过手工方式创建数据库表吧？因为这种需求是每个数据库应用都要面临的，所以在Android系统，为我们提供了一个名为SQLiteOpenHelper的抽象类，必须继承它才能使用，它是通过对数据库版本进行管理来实现前面提出的需求。

为了实现对数据库版本进行管理，SQLiteOpenHelper类提供了两个重要的方法，分别是onCreate(SQLiteDatabase db)和onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion)，前者用于初次使用软件时生成数据库表，后者用于升级软件时更新数据库表结构。当调用SQLiteOpenHelper的getWritableDatabase()或者getReadableDatabase()方法获取用于操作数据库的SQLiteDatabase实例的时候，如果数据库不存在，Android系统会自动生成一个数据库，接着调用onCreate()方法，onCreate()方法在初次生成数据库时才会被调用，在onCreate()方法里可以生成数据库表结构及添加一些应用使用到的初始化数据。onUpgrade()方法在数据库的版本发生变化时会被调用，一般在软件升级时才需改变版本号，而数据库的版本是由程序员控制的，假设数据库现在的版本是1，由于业务的变更，修改了数据库表结构，这时候就需要升级软件，升级软件时希望更新用户手机里的数据库表结构，为了实现这一目的，可以把原来的数据库版本设置为2(有同学问设置为3行不行？当然可以，如果你愿意，设置为100也行)，并且在onUpgrade()方法里面实现表结构的更新。当软件的版本升级次数比较多，这时在onUpgrade()方法里面可以根据原版号和目标版本号进行判断，然后作出相应的表结构及数据更新。

getWritableDatabase()和getReadableDatabase()方法都可以获取一个用于操作数据库的SQLiteDatabase实例。但getWritableDatabase() 方法以读写方式打开数据库，一旦数据库的磁盘空间满了，数据库就只能读而不能写，倘若使用getWritableDatabase()打开数据库就会出错。getReadableDatabase()方法先以读写方式打开数据库，如果数据库的磁盘空间满了，就会打开失败，当打开失败后会继续尝试以只读方式打开数据库。

1、工程结构：![SouthEast][]

SQLiteExpert目前优秀的SQLite查看工具：![SouthEast 1][]

数据库保存位置：![SouthEast 2][]

android sqlite数据库的存在条件：![SouthEast 3][]

2、Activicty：

package cn.huangjie.db;
    
    import android.app.Activity;
    import android.os.Bundle;
    
    public class DbActivity extends Activity {
        /** Called when the activity is first created. */
        @Override
        public void onCreate(Bundle savedInstanceState) {
            super.onCreate(savedInstanceState);
            setContentView(R.layout.main);
        }
    }

3、person的domain类

package cn.huangjie.domain;
    
    public class Person {
    	private Integer id;
    	private String name;
    	private Integer age;
    	
    	public Integer getId() {
    		return id;
    	}
    	public void setId(Integer id) {
    		this.id = id;
    	}
    	public String getName() {
    		return name;
    	}
    	public void setName(String name) {
    		this.name = name;
    	}
    	public Integer getAge() {
    		return age;
    	}
    	public void setAge(Integer age) {
    		this.age = age;
    	}
    	public Person(Integer id, String name, Integer age) {
    		this.id = id;
    		this.name = name;
    		this.age = age;
    	}
    	public Person(String name, Integer age) {
    		this.name = name;
    		this.age = age;
    	}
    	public Person() {
    	}
    	@Override
    	public String toString() {
    		return "Person [id=" + id + ", name=" + name + ", age=" + age + "]";
    	}
    	
    	
    }

4、数据库的操作工具类

package cn.huangjie.service;
    
    import android.content.Context;
    import android.database.sqlite.SQLiteDatabase;
    import android.database.sqlite.SQLiteOpenHelper;
    
    public class DBOpenHelper extends SQLiteOpenHelper{
    
    	public DBOpenHelper(Context context) {
    		//第二个参数为数据库名称,.db不一定要加
    		//第三个参数CursorFactory指定在执行查询时获得一个游标实例的工厂类,
    		//设置为null,代表使用系统默认的工厂类，用于迭代数据
    		//第四个参数版本号建议一开始为1，不能小于1	
    		super(context, "huangjie.db", null, 3);//保存在<包>/database/文件夹下
    		// TODO Auto-generated constructor stub
    	}
    
    	/**
    	 * 是在数据库第一次被创建的时候调用的
    	 * 适合生成数据库表,可以使用SQLiteDatabase
    	 * 对数据库的增删改查操作
    	 */
    	@Override
    	public void onCreate(SQLiteDatabase db) {
    		db.execSQL("CREATE TABLE IF NOT EXISTS person (personid integer primary key autoincrement, name varchar(20), age INTEGER)");
    	}
    
    	/**
    	 * 下面onUpgrade()方法中的注释是在数据库版本每次发生变化时都会把用户手机上的数据库表删除，然后再重新创建。
    	 * 一般在实际项目中是不能这样做的，正确的做法是在更新数据库表结构时，还要考虑用户存放于数据库中的数据不会丢失。
    	 * 该方法是在数据库的版本号变更的时候被调用的,比如之前是1现在改成了2版本
    	 */
    	@Override
    	public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
    //		db.execSQL("DROP TABLE IF EXISTS person");
    //        onCreate(db);
    		db.execSQL("ALTER TABLE person ADD phone VARCHAR(12) NULL");//允许phone字段为null
    	}
    
    }

5、数据库的增删改查，sql语法

package cn.huangjie.service;
    
    import java.util.ArrayList;
    import java.util.List;
    
    import android.content.Context;
    import android.database.Cursor;
    import android.database.sqlite.SQLiteDatabase;
    import cn.huangjie.domain.Person;
    
    /**
     * Android提供了一个名为SQLiteDatabase的类，该类封装了一些操作数据库的API，
     * 使用该类可以完成对数据进行添加(Create)、查询(Retrieve)、更新(Update)和
     * 删除(Delete)操作（这些操作简称为CRUD）。对SQLiteDatabase的学习，我们应该
     * 重点掌握execSQL()和rawQuery()方法。 execSQL()方法可以执行insert、delete、
     * update和CREATE TABLE之类有更改行为的SQL语句； rawQuery()方法用于执行select语句。
     * @author user
     *
     */
    public class PersonService {
    	private DBOpenHelper dbOpenHelper;
    	
    	public PersonService(Context context){
    		this.dbOpenHelper = new DBOpenHelper(context);
    	}
    	
    	/**
    	 * 保存操作
    	 * @param person
    	 */
    	public void save(Person person){
    		/**
    		 * 第一次调用getWritableDatabase()或getReadableDatabase()方法后，
    		 * SQLiteOpenHelper会缓存当前的SQLiteDatabase实例，SQLiteDatabase
    		 * 实例正常情况下会维持数据库的打开状态，所以在你不再需要SQLiteDatabase
    		 * 实例时，请及时调用close()方法释放资源。一旦SQLiteDatabase实例被缓存，
    		 * 多次调用getWritableDatabase()或getReadableDatabase()方法得到的都是同一实例。
    		 */
    		SQLiteDatabase db = dbOpenHelper.getWritableDatabase();
    //		SQLiteDatabase db2 = dbOpenHelper.getWritableDatabase();
    		db.execSQL("insert into person(name,age)values(?,?)",
    				new Object[]{person.getName(), person.getAge()});
    		db.close();//当应用中只有一个地方使用数据库的时候可以不关闭它,提高性能
    	}
    	
    	/**
    	 * 删除操作
    	 * sql语句需要加上delete from table 加上from关键字才行
    	 * @param id
    	 */
    	public void delete(Integer id){
    		SQLiteDatabase db = dbOpenHelper.getWritableDatabase();
    		db.execSQL("delete from person where personid=?", new Object[]{id});
    	}
    	
    	/**
    	 * 更新操作
    	 * @param person
    	 */
    	public void update(Person person){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		db.execSQL("update person set name=?,age=? where personid=?", 
    			new Object[]{person.getName(),person.getAge(),person.getId()});
    	}
    	
    	/**
    	 * 查询记录
    	 * Cursor是结果集游标，用于对结果集进行随机访问，如果大家熟悉jdbc， 
    	 * 其实Cursor与JDBC中的ResultSet作用很相似。使用moveToNext()方法
    	 * 可以将游标从当前行移动到下一行，如果已经移过了结果集的最后一行，
    	 * 返回结果为false，否则为true。另外Cursor 还有常用的moveToPrevious()
    	 * 方法(用于将游标从当前行移动到上一行，如果已经移过了结果集的第一行，
    	 * 返回值为false，否则为true )、moveToFirst()方法（用于将游标移动到
    	 * 结果集的第一行，如果结果集为空，返回值为false，否则为true)和moveToLast()
    	 * 方法(用于将游标移动到结果集的最后一行，如果结果集为空，返回值为false，否则为true)
    	 * @param id
    	 * @return
    	 */
    	public Person find(Integer id){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		Cursor cursor = db.rawQuery("select * from person where personid=?", 
    				new String[]{String.valueOf(id)});
    		Person person = null;
    		if(cursor.moveToFirst()){
    			int personid = cursor.getInt(cursor.getColumnIndex("personid"));
    			String name = cursor.getString(cursor.getColumnIndex("name"));
    			int age = cursor.getInt(cursor.getColumnIndex("age"));
    			person = new Person(personid, name, age);
    		}
    		cursor.close();
    		return person;
    	}
    	
    	/**
    	 * 分页获取记录
    	 * @param offset 跳过前面多少条记录
    	 * @param maxResult 每页获取多少条记录
    	 * @return
    	 */
    	public List<Person> getScrollData(int offset, int maxResult){
    		List<Person> persons = new ArrayList<Person>();
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		Cursor cursor = db.rawQuery("select * from person limit ?,?", 
    				new String[]{String.valueOf(offset), String.valueOf(maxResult)});
    		while(cursor.moveToNext()){
    			int personid = cursor.getInt(cursor.getColumnIndex("personid"));
    			String name = cursor.getString(cursor.getColumnIndex("name"));
    			int age = cursor.getInt(cursor.getColumnIndex("age"));
    			Person person = new Person(personid, name, age);
    			persons.add(person);
    		}
    		cursor.close();
    		return persons;
    	}
    	
    	/**
    	 * 获取记录总数
    	 * 经sql查询,就算表中没有一条记录,count也会为1
    	 * @return
    	 */
    	public long getCount(){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		Cursor cursor = db.rawQuery("select count(*) from person", null);
    		cursor.moveToFirst();
    		long count = cursor.getLong(0);//第0个下标参数
    		cursor.close();
    		return count;
    	}
    	
    	/**
    	 * 模拟事务的处理
    	 */
    	public void payment(){
    		SQLiteDatabase db = dbOpenHelper.getWritableDatabase();
    		db.beginTransaction();//开启事务
    		try{
    			db.execSQL("update person set age = 88 where personid = 12");
    			db.execSQL("update person set age = 99 where personid = 13");
    			db.setTransactionSuccessful();//设置事务的标志为true
    		}finally{
    			/**
    			 * 结束事务有两种情况：commit和rollback
    			 * 事务的提交或回滚是由事务的标志决定的，如果事务的标志为true，
    			 * 事务就会提交，否则回滚，默认情况下事务的标志为false
    			 */
    			db.endTransaction();
    		}
    	}
    }

6、数据库的增删改查，现成 sql方法

package cn.huangjie.service;
    
    import java.util.ArrayList;
    import java.util.List;
    import android.content.ContentValues;
    import android.content.Context;
    import android.database.Cursor;
    import android.database.sqlite.SQLiteDatabase;
    import cn.huangjie.domain.Person;
    
    /**
     * SQLiteDatabase还专门提供了对应于添加、删除、更新、查询的操作方法： 
     * insert()、delete()、update()和query() 。这些方法实际上是给那些不
     * 太了解SQL语法的菜鸟使用的，对于熟悉SQL语法的程序员而言，直接使用
     * execSQL()和rawQuery()方法执行SQL语句就能完成数据的添加、删除、更新、查询操作。
     * @author user
     *
     */
    public class OtherPersonService {
    	private DBOpenHelper dbOpenHelper;
    	
    	public OtherPersonService(Context context){
    		this.dbOpenHelper = new DBOpenHelper(context);
    	}
    	
    	/**
    	 *  Insert()方法用于添加数据，各个字段的数据使用ContentValues进行存放。
    	 *  ContentValues类似于MAP，相对于MAP，它提供了存取数据对应的
    	 *  put(String key, Xxx value)和getAsXxx(String key)方法，  key为字段名称，
    	 *  value为字段值，Xxx指的是各种常用的数据类型，如：String、Integer等。
    	 * @param person
    	 */
    	public void save(Person person){
    		SQLiteDatabase db = dbOpenHelper.getWritableDatabase();
    		//这两个db是同一个,因为dbOpenHelper对象内部有数据库实例的缓存功能
    		ContentValues values = new ContentValues();
    		values.put("name", person.getName());
    		values.put("age", person.getAge());
    		/**
    		 * 不管第三个参数是否包含数据，执行Insert()方法必然会添加一条记录，
    		 * 如果第三个参数为空，会添加一条除主键之外其他字段值为Null的记录。
    		 * Insert()方法内部实际上通过构造insert SQL语句完成数据的添加，Insert()
    		 * 方法的第二个参数用于指定空值字段的名称，相信大家对该参数会感到疑惑，
    		 * 该参数的作用是什么？是这样的：如果第三个参数values 为Null或者元素
    		 * 个数为0， 由于Insert()方法要求必须添加一条除了主键之外其它字段为
    		 * Null值的记录，为了满足SQL语法的需要， insert语句必须给定一个字段名，
    		 * 如：insert into person(name) values(NULL)，倘若不给定字段名 ， 
    		 * insert语句就成了这样： insert into person() values()，显然这不满足
    		 * 标准SQL的语法。对于字段名，建议使用主键之外的字段，如果使用了INTEGER
    		 * 类型的主键字段，执行类似insert into person(personid) values(NULL)的
    		 * insert语句后，该主键字段值也不会为NULL。如果第三个参数values 不为Null
    		 * 并且元素的个数大于0 ，可以把第二个参数设置为null。
    		 */
    		db.insert("person", null, values);//返回新添记录的行号，与主键id无关
    		db.close();//当应用中只有一个地方使用数据库的时候可以不关闭它,提高性能
    	}
    	
    	/**
    	 * 删除操作
    	 * @param id
    	 */
    	public void delete(Integer id){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		db.delete("person", "personid=?", new String[]{String.valueOf(id)});
    	}
    	
    	/**
    	 * 更新操作
    	 * @param person
    	 */
    	public void update(Person person){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		
    		ContentValues values = new ContentValues();
    		values.put("name", person.getName());
    		values.put("age", person.getAge());
    		db.update("person", values, "personid=?", new String[]{String.valueOf(person.getId())});
    	}
    	
    	/**
    	 * 查询记录
    	 * query()方法实际上是把select语句拆分成了若干个组成部分，然后作为方法的输入参数
    	 * query(table, columns, selection, selectionArgs, groupBy, having, orderBy, limit)方法各参数的含义：
    		table：表名。相当于select语句from关键字后面的部分。如果是多表联合查询，可以用逗号将两个表名分开。
    		columns：要查询出来的列名。相当于select语句select关键字后面的部分。
    		selection：查询条件子句，相当于select语句where关键字后面的部分，在条件子句允许使用占位符“?”
    		selectionArgs：对应于selection语句中占位符的值，值在数组中的位置与占位符在语句中的位置必须一致，否则就会有异常。
    		groupBy：相当于select语句group by关键字后面的部分
    		having：相当于select语句having关键字后面的部分
    		orderBy：相当于select语句order by关键字后面的部分，如：personid desc, age asc;
    		limit：指定偏移量和获取的记录数，相当于select语句limit关键字后面的部分。
    
    	 * @param id
    	 * @return
    	 */
    	public Person find(Integer id){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		//第二个参数columns传入为null表示selete所有的字段
    		Cursor cursor = db.query("person", null, "personid=?", new String[]{String.valueOf(id)}, null, null, null);
    		Person person = null;
    		if(cursor.moveToFirst()){
    			int personid = cursor.getInt(cursor.getColumnIndex("personid"));
    			String name = cursor.getString(cursor.getColumnIndex("name"));
    			int age = cursor.getInt(cursor.getColumnIndex("age"));
    			person = new Person(personid, name, age);
    		}
    		cursor.close();
    		return person;
    	}
    	
    	/**
    	 * 分页获取记录
    	 * @param offset 跳过前面多少条记录
    	 * @param maxResult 每页获取多少条记录
    	 * @return
    	 */
    	public List<Person> getScrollData(int offset, int maxResult){
    		List<Person> persons = new ArrayList<Person>();
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		//第二个参数columns传入为null表示selete所有的字段
    		Cursor cursor = db.query("person", null, null, null, null, null, null, offset + "," + maxResult);
    		while(cursor.moveToNext()){
    			int personid = cursor.getInt(cursor.getColumnIndex("personid"));
    			String name = cursor.getString(cursor.getColumnIndex("name"));
    			int age = cursor.getInt(cursor.getColumnIndex("age"));
    			Person person = new Person(personid, name, age);
    			persons.add(person);
    		}
    		cursor.close();
    		return persons;
    	}
    	
    	/**
    	 * 获取记录总数
    	 * 经sql查询,就算表中没有一条记录,count也会为1
    	 * @return
    	 */
    	public long getCount(){
    		SQLiteDatabase db = dbOpenHelper.getReadableDatabase();
    		Cursor cursor = db.query("person", new String[]{"count(*)"}, null, null, null, null, null);
    		cursor.moveToFirst();
    		long count = cursor.getLong(0);//第0个下标参数
    		cursor.close();
    		return count;
    	}
    	
    	public void payment(){}
    }

7、sql的测试类

package cn.huangjie.test;
    
    import java.util.List;
    import android.test.AndroidTestCase;
    import android.util.Log;
    import cn.huangjie.domain.Person;
    import cn.huangjie.service.DBOpenHelper;
    import cn.huangjie.service.OtherPersonService;
    import cn.huangjie.service.PersonService;
    
    public class PersonServiceTest extends AndroidTestCase{
    	
    	public void testCreateDB() throws Exception{
    		DBOpenHelper dbOpenHelper = new DBOpenHelper(getContext());
    		/**
    		 * 这两个方法都可以进行创建数据库
    		 * 区别:如果数据库的磁盘空盘没满的情况下,调用getReadableDatabase
    		 * 实际上就是调用getWritableDatabase
    		 * 如果数据库的磁盘空间满的情况下调用getWritableDatabase会异常,因为不能写了
    		 * 调用getReadableDatabase这个方法返回只能读不能写的实例
    		 */
    //		dbOpenHelper.getReadableDatabase();
    		dbOpenHelper.getWritableDatabase();
    	}
    	
    	PersonService service = null;
    	//在测试方法运行前执行该setUp方法
    	@Override
    	protected void setUp() throws Exception {
    		service = new PersonService(this.getContext());
    //		service = new OtherPersonService(this.getContext());
    	}
    
    	//测试保存功能
    	public void testSave(){
    		for(int i=0; i<10; i++){
    			Person person = new Person("huangjie"+i, 10+i);
    			service.save(person);
    		}
    	}
    	
    	//测试删除功能
    	public void testDelete(){
    		service.delete(10);
    	}
    	
    	//测试更新功能
    	public void testUpdate(){
    		Person person = new Person(7,"hhh7",70);
    		service.update(person);
    	}
    	
    	//测试查询功能
    	public void testFind(){
    		Log.i("PersonServiceTest", service.find(9).toString());
    	}
    	
    	//测试分页获取
    	public void testScrollData(){
    		List<Person> list = service.getScrollData(5, 10);
    		for(Person person : list){
    			Log.i("PersonServiceTest", person.toString());
    		}
    	}
    	
    	//测试获取总数
    	public void testCount(){
    		Log.i("PersonServiceTest_Count", String.valueOf(service.getCount()));
    	}
    	
    	//测试事务
    	public void testPayment(){
    		service.payment();
    	}
    }

工程下载地址：

[SouthEast]: /images/20221014/4c96441548fe4f358c11fc8073f43cfa.png
[SouthEast 1]: /images/20221014/7d9b9a1bf85544a68163372ea3e5d9d3.png
[SouthEast 2]: /images/20221014/55ddb965e2764dbc90b08802dcd8e6ca.png
[SouthEast 3]: /images/20221014/f5c216e4f0dd49b9ac7089f300779e04.png