android SQLite数据库的增删改查以及事务的单元测试

sm702

废话少说，为了这个数据库整理一两天的时间，下面就把代码直接贴出来：

创建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 [age=" + age + ",id=" + id + ",name" + name + "]";
}
}

新建工具类：

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>



好了，至此为止，在上面的单元测试怎删改查算是弄完了，通过运行测试类的方法就可以看到效果以及具体的方法用法了。不容易呵呵不懂得方法自己到晚上去查吧，为了上面的代码我忙着了两天，不想写注视了，不理解的自己去网站找吧,反正上面的代码都是我跑起来的