首先我们创建一个数据库帮助类PersonSQLLiteOpenHelper，单词拼写有点小错误。。
让这个类继承SQLiteOpenHelper
package com.example.android03db.db;import android.content.Context;import android.database.sqlite.SQLiteDatabase;import android.database.sqlite.SQLiteDatabase.CursorFactory;import android.database.sqlite.SQLiteOpenHelper;/** * 数据库帮助类，用于创建和管理数据库 * @author Administrator * */public class PersonSQLLiteOpenHelper extends SQLiteOpenHelper { /** * 数据库的构造函数 * @param context * @param name数据库名称 * @param factory游标工程 * @param version数据库版本 */ public PersonSQLLiteOpenHelper(Context context, String name, CursorFactory factory, int version) { super(context, "hzg01.db", null, 1);//依次是上下文，数据库的名称，版本，不能低于1 } public PersonSQLLiteOpenHelper(Context context) { super(context, "hzg01.db", null, 1);//依次是上下文，数据库的名称，版本，不能低于1 } /** * 数据库第一次创建时调用此方法 * 初始化一些表 */ @Override public void onCreate(SQLiteDatabase db) { //操作数据库 String sql="create table person(id integer primary key,name varchar(20),age integer)"; db.execSQL(sql);//创建person表 } /** * 数据库的版本号更新时回调此方法 */ @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { }}
接下来我们写一个DAO
package com.example.android03db.dao;import java.util.ArrayList;import java.util.List;import android.content.Context;import android.database.Cursor;import android.database.sqlite.SQLiteDatabase;import com.example.android03db.db.PersonSQLLiteOpenHelper;import com.example.android03db.entities.Person;public class PersonDao { private PersonSQLLiteOpenHelper personsql;//数据库的帮助类 public PersonDao(Context context){ personsql=new PersonSQLLiteOpenHelper(context); } /** * 添加到person表中一条数据 * @param p */ public void insert(Person p){ SQLiteDatabase db=personsql.getWritableDatabase(); if(db.isOpen()){//如果数据库打开执行添加的操作 //执行添加到数据库的操作 String sql="insert into person (name,age) values(?,?)"; db.execSQL(sql,new Object[]{p.getName(),p.getAge()}); db.close();//数据库关闭 } } public void delete(int id){ SQLiteDatabase db=personsql.getWritableDatabase();//获得可写的数据库对象 if(db.isOpen()){//如果数据库打开执行添加的操作 //执行添加到数据库的操作 db.execSQL("delete from person where id=?", new Integer[]{id}); db.close();//数据库关闭 } } public void update(int id,String name){ SQLiteDatabase db=personsql.getWritableDatabase(); if(db.isOpen()){//如果数据库打开执行添加的操作 //执行添加到数据库的操作 db.execSQL("update person set name=? where id=?", new Object[]{name,id}); db.close();//数据库关闭 } } public List queryAll(){ SQLiteDatabase db=personsql.getReadableDatabase();//获得一个只读的数据库对象 if(db.isOpen()){ //db.execSQL("select *from person"); Cursor cursor=db.rawQuery("select id,name,age from person", null); if(cursor!=null&&cursor.getCount()>0){ List persons=new ArrayList (); while(cursor.moveToNext()){ int id=cursor.getInt(0);//取第0列id String name=cursor.getString(1); int age=cursor.getInt(2); persons.add(new Person(id,name,age)); } db.close(); return persons; } db.close(); } return null; } public Person queryIntem(int id){ SQLiteDatabase db=personsql.getReadableDatabase();//获得一个只读的数据库对象 if(db.isOpen()){ Cursor cursor=db.rawQuery("select id,name,age from person where id=?", new String[]{id+""}); if(cursor!=null&&cursor.moveToFirst()){ int pid=cursor.getInt(0);//取第0列id String name=cursor.getString(1); int age=cursor.getInt(2); return new Person(pid,name,age); } } return null; } } 定义一个entity类Person
package com.example.android03db.entities;public class Person { private int id; private String name; private int age; public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public Person(int id, String name, int age) { super(); this.id = id; this.name = name; this.age = age; } public Person() { super(); } public Person(String name, int age) { super(); this.name = name; this.age = age; } @Override public String toString() { return "Person [id=" + id + ", name=" + name + ", age=" + age + "]"; } } 测试阶段
package com.example.android03db.test;import java.util.List;import android.test.AndroidTestCase;import android.util.Log;import com.example.android03db.dao.PersonDao;import com.example.android03db.db.PersonSQLLiteOpenHelper;import com.example.android03db.entities.Person;public class Test extends AndroidTestCase{ private static final String TAG = "Test"; public static void main(String[] args) { // TODO Auto-generated method stub } public void t(){ PersonSQLLiteOpenHelper pl=new PersonSQLLiteOpenHelper(getContext()); //第一次连接数据库时，创建数据库文件oncreate会被调用 pl.getReadableDatabase(); } public void testinsert(){ PersonDao dao=new PersonDao(getContext()); dao.insert(new Person("张三",25)); } public void testDelete(){ PersonDao dao=new PersonDao(getContext()); dao.delete(1); } public void testUpdate(){ PersonDao dao=new PersonDao(getContext()); dao.update(2, "李四"); } public void testQueryAll(){ PersonDao dao=new PersonDao(getContext()); List persons=dao.queryAll(); for(Person ps:persons){ Log.i(TAG, ps.toString());} } public void testQueryItem(){ PersonDao dao=new PersonDao(getContext()); Person p=dao.queryIntem(2); Log.i(TAG, p.toString()); }}