android SQLite数据库的增删改查以及事务的单元测试
废话少说，为了这个数据库整理一两天的时间，下面就把代码直接贴出来：创建androidproject 名称：db
创建包名:com.gohighsoft.db
新建一个Person实体类：
package com.gohighsoft.db;
public class Person {
private Integer id;
private String name;
private Integer age;
public Person() {
};
public Person(String name, Integer age) {
this.name = name;
this.age = 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 String toString() {
return "Person ";
}
}
新建工具类：
DataBaseHaler.java
package com.gohighsoft.db;
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 DataBaseHaler extends SQLiteOpenHelper {
private static final String NAME = "sharp.db";// 。db可有可无
private static final int version = 1;// 版本号不能为0
public DataBaseHaler(Context context) {
super(context, NAME, null, version);
}
@Override
public void onCreate(SQLiteDatabase db) {
Log.i("aa","1111111111111");
db.execSQL("CREATE TABLE person(personid integer primary key autoincrement,name varchar(20),age integer)");
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVewsion) {
Log.i("aa","22222222222222");
db.execSQL("DROP TABLE IF EXISTS PERSON");
onCreate(db);
}
}
新建一个service服务类：
PersonService.java
package com.gohighsoft.db;
import java.util.ArrayList;
import java.util.List;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
public class PersonService {
private DataBaseHaler databaseHelper;
private Context context;
public PersonService(Context context) {
this.context = context;
databaseHelper = new DataBaseHaler(context);
}
public void savesTrannces(Person person) {
Log.i("aa", "4444444444444");
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.beginTransaction();// 开始事务
try {
for(int i=0;i<100;i++){
db.execSQL("insert into person(name,age) values(?,?)",
new Object[] { person.getName(), person.getAge() });
}
db.execSQL("insert into personww(namedd,age) values(?,?)",
new Object[] { person.getName(), person.getAge() });
db.setTransactionSuccessful();
} catch (Exception e) {
//db.endTransaction();// 事务结束;
Log.i("aa","wwwwwwwwwwwwwwwwwwwwwwwww");
}
db.endTransaction();// 事务结束;
Log.i("aa", "55555555555555555555");
}
public void save1(Person person) {
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.beginTransaction();// 开始事务
Log.i("aa", "uuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuu");
try {
db.setTransactionSuccessful();
db.execSQL("insert into person(name,age) values('Tom',21)");
} catch (Exception e) {
Log.i("aa", "trttttttttttttttttttttttttttttttttttttttttttttt");
}
db.endTransaction();// 事务结束;
}
public void save2(Person person) {
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.beginTransaction();// 开始事务
Log.i("aa", "uuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuuu");
try {
db.setTransactionSuccessful();
for(int i=0;i<100;i++){
db.execSQL("insert into person(name,age) values(?,?)",
new Object[] { person.getName(), person.getAge() });
}
} catch (Exception e) {
Log.i("aa", "trttttttttttttttttttttttttttttttttttttttttttttt");
}
db.endTransaction();// 事务结束;
}
public void update(Person person) {
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.execSQL(
"update person set name=?,age=? where personid=?",
new Object[] { person.getName(), person.getAge(),
person.getId() });
}
public Person find(Integer id) {
SQLiteDatabase db = databaseHelper.getReadableDatabase();
Cursor cursor = db.rawQuery(
"select personid,name,age from person where personid=?",
new String[] { String.valueOf(id) });
if (cursor.moveToNext()) {
Person person = new Person();
person.setId(cursor.getInt(cursor.getColumnIndex("personid")));
person.setName(cursor.getString(1));
person.setAge(cursor.getInt(2));
return person;
}
cursor.close();
return null;
}
public void delete(Integer id) {
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.execSQL("delete fro person where personid=?", new Object[] { id });
}
public List<Person> getScrollData(int firstResult, int maxResult) {
List<Person> persons = new ArrayList<Person>();
SQLiteDatabase db = databaseHelper.getReadableDatabase();
Cursor cursor = db.rawQuery(
"select personid,name,age from person limit ?,?",
new String[] { String.valueOf(firstResult),
String.valueOf(maxResult) });// firstResult开始索引
while (cursor.moveToNext()) {// maxResult每页获取的记录数
Log.i("aa", "333333333333");
Person person = new Person();
person.setId(cursor.getInt(cursor.getColumnIndex("personid")));
person.setName(cursor.getString(1));
person.setAge(cursor.getInt(2));
persons.add(person);
}
cursor.close();
return persons;
}
public long getCount() {
SQLiteDatabase db = databaseHelper.getReadableDatabase();
Cursor cursor = db.rawQuery("select count(*) from person", null);
// 没有占位符参数的话，直接用null
cursor.moveToFirst();
Long count = cursor.getLong(0);
cursor.close();
return count;
}
}
新建测试类FileServiceTest.java
package com.gohighsoft.db;
import android.test.AndroidTestCase;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.List;
import android.content.Context;
import android.test.AndroidTestCase;
import android.util.Log;
public class FileServiceTest extends AndroidTestCase {
public void createDatabase() throws Throwable{
DataBaseHaler databaseHelper = new DataBaseHaler(getContext());
databaseHelper.getWritableDatabase();
}
public void testSave() throws Throwable{
PersonService personservice = new PersonService(this.getContext());
Person person = new Person("张大千",29);
personservice.save2(person);
}
public void tesetUpdate() throws Throwable{
PersonService personService = new PersonService(this.getContext());
Person person = personService.find(1);
person.setName("jim");
personService.update(person);
}
public void testCount() throws Throwable{
PersonService personService = new PersonService(this.getContext());
Log.i("aa",personService.getCount()+"");
}
public void testGetScrollData() throws Throwable{
PersonService personService = new PersonService(this.getContext());
List<Person> persons = personService.getScrollData(0,3);
for(Person person:persons){
Log.i("aa",person.toString());
}
}
public void TrancesTest() throws Throwable{
PersonService personService = new PersonService(this.getContext());
Person person = new Person("aaaaaaa",28);
personService.savesTrannces(person);
}
}
AndroidManifest.xml配置文件中添加单元测试的权限：
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.gohighsoft.db" android:versionCode="1"
android:versionName="1.0">
<application android:icon="@drawable/icon" android:label="@string/app_name">
<uses-library android:name="android.test.runner" />
<activity android:name=".MainActivity" android:label="@string/app_name">
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
<uses-sdk android:minSdkVersion="8" />
<instrumentation android:name="android.test.InstrumentationTestRunner"
android:targetPackage="com.gohighsoft.db" android:label="Tests for My App" />
</manifest>
好了，至此为止，在上面的单元测试怎删改查算是弄完了，通过运行测试类的方法就可以看到效果以及具体的方法用法了。不容易呵呵不懂得方法自己到晚上去查吧，为了上面的代码我忙着了两天，不想写注视了，不理解的自己去网站找吧,反正上面的代码都是我跑起来的
页:
[1]