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;
}
} |