使用嵌入式关系型SQLite数据库存储数据
|
一、使用嵌入式关系型SQLite数据库存储数据 在Android平台上，集成了一个嵌入式关系型数据库—SQLite，SQLite3支持
NULL、INTEGER、REAL（浮点数字）、TEXT(字符串文本)和BLOB(二进制对象)数据类型，虽然它支持的类型只有五种，但实际上sqlite3也接受varchar(n)、char(n)、decimal(p,s) 等数据类型，只不过在运算或保存时会转成对应的五种数据类型。
SQLite最大的特点是你可以把各种类型的数据保存到任何字段中，而不用关心字段声明的数据类型是什么。例如：可以在Integer类型的字段中存放字符串，或者在布尔型字段中存放浮点数，或者在字符型字段中存放日期型值。
但有一种情况例外：定义为INTEGER PRIMARY KEY的字段只能存储64位整数，
当向这种字段保存除整数以外的数据时，将会产生错误。
另外，
SQLite 在解析CREATE TABLE 语句时，会忽略
CREATE TABLE 语句中跟在字段名后面的数据类型信息，如下面语句会忽略
name字段的类型信息：
CREATE TABLE person (personid integer primary key
autoincrement, name varchar(20))
SQLite可以解析大部分标准SQL语句，如：
查询语句：select * from 表名
where 条件子句
group by 分组字句
having ... order by 排序子句
如：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 * from Account limit 3,5
插入语句：insert into 表名(字段列表) values(值列表)。如：
insert into person(name, age) values(‘传智’,3)
更新语句：update 表名
set 字段名=值
where 条件子句。如：update person set name=‘传智‘
where id=10
删除语句：delete from 表名
where 条件子句。如：delete from person
where id=10
|
|
二、SQLiteDatabase Android提供了一个名为SQLiteDatabase的类，该类封装了一些操作数据库的API，使用该类可以完成对数据进行添加(Create)、查询(Retrieve)、更新(Update)和删除(Delete)操作（这些操作简称为CRUD）。对SQLiteDatabase的学习，我们应该重点掌握execSQL()和rawQuery()方法。
execSQL()方法可以执行insert、delete、update和CREATE TABLE之类有更改行为的SQL语句；
rawQuery()方法用于执行select语句。
execSQL()方法的使用例子：
SQLiteDatabase db = ....;
db.execSQL("insert into person(name, age) values('传智播客', 4)");
db.close();
执行上面SQL语句会往person表中添加进一条记录，在实际应用中，
语句中的“传智播客”这些参数值会由用户输入界面提供，如果把用户输入的内容原样组拼到上面的insert语句，
当用户输入的内容含有单引号时，组拼出来的SQL语句就会存在语法错误。要解决这个问题需要对单引号进行转义，也就是把单引号转换成两个单引号。有些时候用户往往还会输入像“
&
”这些特殊SQL符号，为保证组拼好的SQL语句语法正确，必须对SQL语句中的这些特殊SQL符号都进行转义，显然，对每条SQL语句都做这样的处理工作是比较烦琐的。
SQLiteDatabase类提供了一个重载后的execSQL(String sql, Object[] bindArgs)方法，使用这个方法可以解决前面提到的问题，因为这个方法支持使用占位符参数(?)。使用例子如下：
SQLiteDatabase db = ....;
db.execSQL("insert into person(name, age) values(?,?)", new
Object[]{"传智播客", 4});
db.close();
execSQL(String sql, Object[] bindArgs)方法的第一个参数为SQL语句，第二个参数为SQL语句中占位符参数的值，参数值在数组中的顺序要和占位符的位置对应。
SQLiteDatabase的rawQuery()
用于执行select语句，使用例子如下：
SQLiteDatabase db = ....; Cursor cursor = db.rawQuery(“select * from person”,
null);
while (cursor.moveToNext()) {
int
personid = cursor.getInt(0); //获取第一列的值,第一列的索引从0开始
String name = cursor.getString(1);//获取第二列的值
int age = cursor.getInt(2);//获取第三列的值
}
cursor.close();
db.close();
rawQuery()方法的第一个参数为select语句；第二个参数为select语句中占位符参数的值，如果select语句没有使用占位符，该参数可以设置为null。带占位符参数的select语句使用例子如下：
Cursor cursor = db.rawQuery("select * from person where name
like ? and age=?", new String[]{"%传智%", "4"});
Cursor是结果集游标，用于对结果集进行随机访问，如果大家熟悉jdbc，
其实Cursor与JDBC中的ResultSet作用很相似。使用moveToNext()方法可以将游标从当前行移动到下一行，如果已经移过了结果集的最后一行，返回结果为false，否则为true。另外Cursor 还有常用的moveToPrevious()方法（用于将游标从当前行移动到上一行，如果已经移过了结果集的第一行，返回值为false，否则为true ）、moveToFirst()方法（用于将游标移动到结果集的第一行，如果结果集为空，返回值为false，否则为true ）和moveToLast()方法（用于将游标移动到结果集的最后一行，如果结果集为空，返回值为false，否则为true ）
。
|
|
1、SQLite的简单增删改查 import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import cn.zengfansheng.db.PersonDBOpenHelper;
/**
* 使用SQLite数据库的增删改查
*
* @author hacket
*
*/
public class PersonDao {
private PersonDBOpenHelper helper;
// 一初始化PersonDao就有一个helper实例
public PersonDao(Context context) {
helper = new PersonDBOpenHelper(context, "person.db", null, 1);
}
/**
* 1、添加数据到数据库
* @param name 要添加的用户名
* @param phone 要添加的电话号码
*/
public void add(String name,String phone) {
SQLiteDatabase database = helper.getWritableDatabase();
String sql = "insert into person(name,phone)values(?,?)";
database.execSQL(sql, new String[] { name, phone });
database.close();// 最好记得关闭数据库, 避免如果有过的打开的连接 导致数据库以后无法访问.
}
/**
* 2、根据name从数据库中查询数据
*
* @param name
* 依据的name用户名
* @return 如果有数据，返回true，否则返回false.
*/
public boolean select(String name) {
SQLiteDatabase database = helper.getReadableDatabase();
String sql = "select * from person where name = ?";
Cursor cursor = database.rawQuery(sql, new String[] { name });
boolean b = cursor.moveToFirst();
cursor.close();
database.close();
return b;
}
/**
* 3、根据用户名name根据数据库中的数据为新数据phone
*
* @param name
* 根据的用户名
* @param phone
* 新的电话号码
*/
public void update(String name, String phone) {
SQLiteDatabase database = helper.getWritableDatabase();
String sql = "update person set phone = ? where name = ?";
database.execSQL(sql, new String[] { phone, name });
database.close();
}
/**
* 4、根据用户名到数据库中删除指定的记录
* @param name 要删除的用户名
*/
public void delete(String name) {
SQLiteDatabase database = helper.getWritableDatabase();
String sql = "delete from person where name = ?";
database.execSQL(sql, new String[] { name });
database.close();
}
} |
|
2、测试框架测试 import android.database.sqlite.SQLiteDatabase;
import android.test.AndroidTestCase;
import cn.zengfansheng.db.PersonDBOpenHelper;
import cn.zengfansheng.personDao.PersonDao;
public class TestPersonDBOpenHelper extends AndroidTestCase {
// PersonDao personDao = new PersonDao(getContext()) 由于每一个测试的方法都要写，如果定义在这里，那么也不行，因为此时测试框架还没有起起来。
PersonDao personDao = null;
public void test() {
// getContext() 获取的是一个假的模拟的上下文 一个方便测试框架使用的上下文
PersonDBOpenHelper helper = new PersonDBOpenHelper(getContext(), "mydb.db", null,2);//不会创建数据库
SQLiteDatabase database = helper.getWritableDatabase();// 创建或者获取一个可读写的数据库
database.close();
}
/**
* 当测试框架准备好的时候执行的代码 适合做测试内容的初始化
*/
@Override
protected void setUp() throws Exception {
super.setUp();
personDao = new PersonDao(getContext());
}
/**
* 擦屁股
*/
@Override
protected void tearDown() throws Exception {
super.tearDown();
personDao = null;
}
/**
* 1、测试添加数据
*/
public void testAdd() {
// PersonDao personDao = new PersonDao(getContext());
personDao.add("hacket", "112");
}
/**
* 2、测试查询
*/
public void testSelect() {
PersonDao personDao = new PersonDao(getContext());
boolean b = personDao.select("hacket");
assertEquals(true, b);
}
/**
* 3、测试更新
*/
public void testUpdate() {
PersonDao personDao = new PersonDao(getContext());
personDao.update("hacket", "123454687");
}
/**
* 4、测试删除
*/
public void testDelete() {
PersonDao personDao = new PersonDao(getContext());
personDao.delete("hacket");
}
} |
|
3、小结： a） 数据库记得要关闭连接 避免如果有过多的打开的连接 导致数据库以后无法访问. database.close() b）游标要关闭 cursor.close(); c) 测试框架中的Context是个假的 // PersonDao personDao = new PersonDao(getContext()) 由于每一个测试的方法都要写，如果定义在这里，那么也不行，因为此时测试框架还没有起起来。 解决： /**
* 当测试框架准备好的时候执行的代码 适合做测试内容的初始化
*/
@Override
protected void setUp() throws Exception {
super.setUp();
personDao = new PersonDao(getContext());
} |