利用SQLite在android上实现增删改查
方法:
一、直接利用database.execSQL()方法输入完整sql语句进行操作
这种方法适用于复杂的sql语句,比如多表查询等等
这里适合于增删改,这个方法没有返回值,而查需要返回数据,故不适用
增实例:
database.execSQL("insert into student (name,age) values ('小李',45)");
查的话用database.rawQuery()方法,也是我们直接输入完整的sql语句
查实例:
Cursor cursor = database.rawQuery("select id,name,age from student where name=?",new String[] { "小李" });
二、利用系统直接封装好的API,原理是系统内部把参数拼成sql语句
适用于简单sql语句
增: 返回操作的行
long row=database.insert("student", null, values);
删: 返回受影响的行数
int n = database.delete("student", "name=? and age=?", new String[] {"饭饭", "20" });
改: 返回受影响的行数
int n = database.update("student", values, "name=?",new String[] { "饭饭" });
查: 返回数据表游标 (注意查不是select)
Cursor cursor = database.rawQuery("select id,name,age from student where name=?",new String[] { "小李" });
三、其它
1、数据库的连接有限,所以创建连接用完要关闭
2、将我们需要操作的数据写入ContentValues
3、查数据时,游标通过cursor.moveToNext()方法来确定下一行是否有值,有值就读取下一行的值
4、得到列的索引有两种方法:
通过查找列字段对应的位置得到
int id = cursor.getInt(cursor.getColumnIndex("id"));
直接通过列号得到
String name = cursor.getString(1);
代码:
com.fry.database.MySQLiteOpenHelper
package com.fry.database; import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log; public class MySQLiteOpenHelper extends SQLiteOpenHelper{ /*
* 1、context 上下文
* 2、那么数据库名称
* 3、factory
* 4、version 数据库文件的版本
*/ public MySQLiteOpenHelper(Context context,int version) {
super(context, "fanfan3.db", null, version);
// TODO Auto-generated constructor stub
} /* 数据库文件创建成功后调用
* (non-Javadoc)
* @see android.database.sqlite.SQLiteOpenHelper#onCreate(android.database.sqlite.SQLiteDatabase)
*/
@Override
public void onCreate(SQLiteDatabase db) {
Log.d("fanfan", "onCreate");
db.execSQL("CREATE TABLE student(id INTEGER PRIMARY KEY AUTOINCREMENT,name TEXT,age INTEGER)");
} /* 数据库文件更新后调用
* (non-Javadoc)
* @see android.database.sqlite.SQLiteOpenHelper#onUpgrade(android.database.sqlite.SQLiteDatabase, int, int)
*/
@Override
public void onUpgrade(SQLiteDatabase arg0, int arg1, int arg2) {
Log.d("fanfan", "onUpgrade");
} }
数据库类
com.fanfan.test.Test
package com.fanfan.test; import com.fry.database.MySQLiteOpenHelper; import android.annotation.SuppressLint;
import android.content.ContentValues;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.test.AndroidTestCase;
import android.util.Log; public class Test extends AndroidTestCase {
public void test1() {
MySQLiteOpenHelper helper = new MySQLiteOpenHelper(getContext(), 1);
SQLiteDatabase database = helper.getReadableDatabase();
helper.getWritableDatabase();
} // 系统提供的API可以解决简单问题,但是比如多表查询的问题,系统搞不定,我们可以自己用execSQL写sql语句
public void insert() {
MySQLiteOpenHelper helper = new MySQLiteOpenHelper(getContext(), 1);
SQLiteDatabase database = helper.getReadableDatabase();
// ContentValues values=new ContentValues();
// values.put("name", "饭饭");
// values.put("age", 20);
// long row=database.insert("student", null, values);
// Log.d("insert", "刚刚插入的是行的编号为: "+row);
// if(row==-1){
// String s="插入失败";
// Log.d("insert", s);
// }
// 不用系统API,自己写sql
database.execSQL("insert into student (name,age) values ('小李',45)");
// 关闭数据库连接
database.close();
} public void delete() {
MySQLiteOpenHelper helper = new MySQLiteOpenHelper(getContext(), 1);
SQLiteDatabase database = helper.getReadableDatabase();
// 返回受影响的行数
int n = database.delete("student", "name=? and age=?", new String[] {
"饭饭", "20" });
Log.d("delete", "返回受影响的行数为: " + n);
// 关闭数据库连接
database.close();
} public void update() {
MySQLiteOpenHelper helper = new MySQLiteOpenHelper(getContext(), 1);
SQLiteDatabase database = helper.getReadableDatabase();
ContentValues values = new ContentValues();
values.put("name", "小红");
// 返回受影响的行数 // 更改符合筛选条件的记录
int n = database.update("student", values, "name=?",
new String[] { "饭饭" });
// 更改表中所有记录
// int n=database.update("student", values, null, null);
Log.d("update", "返回受影响的行数为: " + n);
// 关闭数据库连接
database.close();
} public void select() {
MySQLiteOpenHelper helper = new MySQLiteOpenHelper(getContext(), 1);
// 创建数据库连接
SQLiteDatabase database = helper.getReadableDatabase();
/*
* distinct==true 剔除重复数据 table 表名 column 查询的列 selection 筛选条件
* selsetionArgs 指定筛选条件参数值 groupBy 分组 having 分组筛选 orderBy 排序 比如"age asc"
* limit 分页
*/
// select * from student where
// 返回的是一个结果集合
// Cursor cursor=database.query(true, "student", new
// String[]{"id","name","age"}, null, null, null, null, null, null); // 如果多表查询,上面的方法不行,因为database.execSQL没有返回值,我们无法返回结果
Cursor cursor = database.rawQuery(
"select id,name,age from student where name=?",
new String[] { "小李" }); // 下一行是否有数据
while (cursor.moveToNext()) {
// 具体得那一列的索引
// 通过索引得到
int id = cursor.getInt(cursor.getColumnIndex("id"));// id是第0列
// 直接通过列号得到
String name = cursor.getString(1);
int age = cursor.getInt(2);
String ans = "id: " + id + " name: " + name + " age: "
+ age;
Log.d("select", ans);
}
// 关闭数据库连接
database.close();
}
}
JUnit 测试增删改查