SQLite的增删改查(Google提供的API)
SQLiteDatabase
除了前面给大家介绍的
execSQL()
和
rawQuery()
方法,
SQLiteDatabase
还专门提供了对应于添加、删除、更新、
查询的操作方法:
insert()
、
delete()
、
update()
和
query()
。这些方法实际上是给那些不太了解
SQL
语法的菜鸟使
用的,对于熟悉
SQL
语法的程序员而言,直接使用
execSQL()
和
rawQuery()
方法执行
SQL
语句就能完成数据的添
加、删除、更新、查询操作。
Insert()
方法用于添加数据
,各个字段的数据使用
ContentValues
进行存放。
ContentValues
类似于
MAP
,相对于
MAP
,它提供了存取数据对应的
put(String key, Xxx value)
和
getAsXxx(String key)
方法,
key
为字段名称,
value
为字段值,
Xxx
指的是各种常用的数据类型,如:
String
、
Integer
等。
SQLiteDatabase db = databaseHelper.getWritableDatabase();
ContentValues values = new ContentValues();
values.put("name", "
传智播客
");
values.put("age", 4);
long rowid = db.insert(“person”, null, values);
//
返回新添记录的行号,与主键
id
无关
不管第三个参数是否包含数据,执行
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
。
delete()方法的使用:
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.delete("person", "personid<?", new String[]{"2"});
db.close();
上面代码用于从
person
表中删除
personid
小于
2
的记录。
update()
方法的使用:
SQLiteDatabase db = databaseHelper.getWritableDatabase();
ContentValues values = new ContentValues();
values.put(“name”, “
传智播客
”
);
//key
为字段名,
value
为值
db.update("person", values, "personid=?", new String[]{"1"});
db.close();
上面代码用于把
person
表中
personid
等于
1
的记录的
name
字段的值改为
“
传智播客
”
。
query()
方法实际上是把
select
语句拆分成了若干个组成部分,然后作为方法的输入参数:
SQLiteDatabase db = databaseHelper.getWritableDatabase();
Cursor cursor = db.query("person", new String[]{"personid,name,age"}, "name like ?", new String[]{"%
传智
%"}, null, null, "personid
desc", "1,2");
while (cursor.moveToNext()) {
int personid = cursor.getInt(0);
//
获取第一列的值
,
第一列的索引从
0
开始
String name = cursor.getString(1);
//
获取第二列的值
int age = cursor.getInt(2);
//
获取第三列的值
}
cursor.close();
db.close();
上面代码用于从
person
表中查找
name
字段含有
“
传智
”
的记录,匹配的记录按
personid
降序排序,对排序后的结果略过第一条记录,
只获取
2
条记录。
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
关键字后面的部分。
|
SQLite的增删改查(Google提供的API) 查看源码 insert的源码:
public long insertWithOnConflict(String table, String nullColumnHack,
ContentValues initialValues, int conflictAlgorithm) {
acquireReference();
try {
StringBuilder sql = new StringBuilder();
sql.append("INSERT");
sql.append(CONFLICT_VALUES[conflictAlgorithm]);
sql.append(" INTO ");
sql.append(table);
sql.append('(');
Object[] bindArgs = null;
int size = (initialValues != null && initialValues.size() > 0)
? initialValues.size() : 0;
if (size > 0) {
bindArgs = new Object[size];
int i = 0;
for (String colName : initialValues.keySet()) {
sql.append((i > 0) ? "," : "");
sql.append(colName);
bindArgs[i++] = initialValues.get(colName);
}
sql.append(')');
sql.append(" VALUES (");
for (i = 0; i < size; i++) {
sql.append((i > 0) ? ",?" : "?");
}
} else {
sql.append(nullColumnHack + ") VALUES (NULL");
}
sql.append(')');
SQLiteStatement statement = new SQLiteStatement(this, sql.toString(), bindArgs);
try {
return statement.executeInsert();
} finally {
statement.close();
}
} finally {
releaseReference();
}
}
1、首先是拼装字符串
2、当到'insert into tableName(' 时,遍历用户传递的ContentValues,将其key取出按照顺序拼装到sql语句中,
遍历完后,加上') values (',此时再次遍历ContentValues,将其中的value取出,拼接到sql语句中。
3、然后再拼接其他的。
|
import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import cn.zengfansheng.db.PersonDBOpenHelper;
/**
* 使用SQLite数据库的增删改查
*
* @author hacket
*
*/
public class PersonDa2 {
private PersonDBOpenHelper helper;
// 一初始化PersonDao就有一个helper实例
public PersonDa2(Context context) {
helper = new PersonDBOpenHelper(context, "person.db", null, 1);
}
/**
* 1、添加数据到数据库
* @param name 要添加的用户名
* @param phone 要添加的电话号码
*/
public boolean add(String name, String phone) {
SQLiteDatabase database = helper.getWritableDatabase();
// String sql = "insert into person(name,phone)values(?,?)";
// database.execSQL(sql, new String[] { name, phone });
ContentValues values = new ContentValues();
values.put("name", name);
values.put("phone", phone);
long rawid = database.insert("person", null, values);// (参数一:表名 参数二:某列为null时,为这个值
//参数三:为一个Map key:相当于person(name,phone)中的name和phone , value相当于values(?,?)中的值。
database.close();// 最好记得关闭数据库, 避免如果有过多的打开的连接 导致数据库以后无法访问.
return rawid > -1;
}
/**
* 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 });
Cursor cursor = database.query("person", null, "name=?", new String[]{name}, null, null, null);
boolean b = cursor.moveToFirst();
cursor.close();
database.close();
return b;
}
/**
* 3、根据用户名name根据数据库中的数据为新数据phone
*
* @param name
* 根据的用户名
* @param phone
* 新的电话号码
*/
public boolean update(String name, String phone) {
SQLiteDatabase database = helper.getWritableDatabase();
// String sql = "update person set phone = ? where name = ?";
// database.execSQL(sql, new String[] { phone, name });
ContentValues values = new ContentValues();
values.put("phone", phone);// 新的值,key为某一列,value为这一列的新值
int update = database.update("person", values, "name=?", new String[] { name });
database.close();
return update > 0;
}
/**
* 4、根据用户名到数据库中删除指定的记录
* @param name 要删除的用户名
*/
public boolean delete(String name) {
SQLiteDatabase database = helper.getWritableDatabase();
// String sql = "delete from person where name = ?";
// database.execSQL(sql, new String[] { name });
int delete = database.delete("person", "name=?", new String[] { name });
database.close();
return delete > 0;
}
|