android中使用SQLite进行CRUD操作的实例

在android中主要使用SQLite数据库进行对一些数据的存储，以下是相应的CRUD的实例。

package com.myclover.db.service;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper;

/**
 * 
 * @author myclover SQLite3支持
 *         NULL、INTEGER、REAL（浮点数字）、TEXT(字符串文本)和BLOB(二进制对象)数据类型
 *         sqlite3也接受varchar(n)、char(n)、decimal(p,s) 等数据类型
 */
public class DBOpenHelper extends SQLiteOpenHelper {

	private static final String DBNAME = "myclover.db";
	private static final int VERSION = 1;

	public DBOpenHelper(Context context) {
		super(context, DBNAME, null, VERSION);
	}

	public DBOpenHelper(Context context, String name, CursorFactory factory,
			int version) {
		super(context, name, factory, version);

	}

	@Override
	public void onCreate(SQLiteDatabase db) {
		db.execSQL("create table t_person (id integer primary key autoincrement , name varchar(30) , sex varchar(10) , age integer , amount real)");
	}

	@Override
	public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
		db.execSQL("drop table if exists t_person");
		onCreate(db);
	}

}

package com.myclover.db.service;

import java.util.ArrayList;
import java.util.List;

import com.myclover.db.bean.Person;

import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;

public class DBService {

	@SuppressWarnings("unused")
	private Context context;
	private DBOpenHelper dbHelper;

	public DBService(Context context) {
		dbHelper = new DBOpenHelper(context);
	}

	/**
	 * 功能描述： 保存单个用户信息
	 * 
	 * @param p
	 *            用户实例
	 */
	public void save(Person p) {
		SQLiteDatabase db = dbHelper.getWritableDatabase();
		db.execSQL("insert into t_person (name , sex , age , amount) values (? , ? , ? , ?)",
				new Object[] { p.getName(), p.getSex(), p.getAge(),
						p.getAmount() });
	}

	/**
	 * 功能描述： 更新用户信息
	 * 
	 * @param p
	 *            用户实例
	 */
	public void update(Person p) {
		SQLiteDatabase db = dbHelper.getWritableDatabase();
		db.execSQL("update t_person set name = ? , sex = ? , age = ? , amount = ? where id = ? ",
				new Object[] { p.getName(), p.getSex(), p.getAge(),
						p.getAmount(), p.getId() });
	}

	/**
	 * 功能描述： 通过用户id查询用户信息
	 * 
	 * @param id
	 *            用户id
	 * @return 返回值：如果存在，则返回用户实例，否则返回为null
	 */
	public Person findById(Integer id) {
		SQLiteDatabase db = dbHelper.getReadableDatabase();
		Cursor cs = db.rawQuery("select * from t_person where id = ? ",
				new String[] { String.valueOf(id) });
		if (cs.moveToNext()) {
			Person p = new Person();
			p.setId(cs.getInt(cs.getColumnIndex("id")));
			p.setName(cs.getString(cs.getColumnIndex("name")));
			p.setSex(cs.getString(cs.getColumnIndex("sex")));
			p.setAge(cs.getInt(cs.getColumnIndex("age")));
			p.setAmount(cs.getFloat(cs.getColumnIndex("amount")));
			cs.close();
			return p;
		}

		return null;
	}
	
	/**
	 * 功能描述： 通过用户姓名查询用户信息
	 * 
	 * @param name
	 *            用户姓名
	 * @return 返回值：如果存在，则返回用户实例，否则返回为null
	 */
	public Person findByName(String name) {
		SQLiteDatabase db = dbHelper.getReadableDatabase();
		Cursor cs = db.rawQuery("select * from t_person where name = ? ",
				new String[] { name });
		if (cs.moveToNext()) {
			Person p = new Person();
			p.setId(cs.getInt(cs.getColumnIndex("id")));
			p.setName(cs.getString(cs.getColumnIndex("name")));
			p.setSex(cs.getString(cs.getColumnIndex("sex")));
			p.setAge(cs.getInt(cs.getColumnIndex("age")));
			p.setAmount(cs.getFloat(cs.getColumnIndex("amount")));
			
			cs.close();
			return p;
		}
		
		return null;
	}

	/**
	 * 功能描述： 通过用户id删除用户信息
	 * 
	 * @param ids
	 *            用户id
	 */
	public void delete(Integer... ids) {
		if (ids.length > 0) {
			StringBuffer sb = new StringBuffer();
			for (@SuppressWarnings("unused")
			int id : ids) {
				sb.append("?").append(",");
			}
			sb.deleteCharAt(sb.length() - 1);
			SQLiteDatabase db = dbHelper.getWritableDatabase();
			db.execSQL("delete from t_person where id in (" + sb + ")",(Object[]) ids);
		}
	}

	/**
	 * 功能描述： 通过分页功能查询用户列表
	 * 
	 * @param startNum
	 *            开始索引值
	 * @param perNum
	 *            每页显示的数目
	 * @return 返回值：返回用户列表信息
	 */
	public List<Person> getPerosns(int startNum, int perNum) {
		List<Person> lists = new ArrayList<Person>();
		SQLiteDatabase db = dbHelper.getReadableDatabase();
		Cursor cs = db
				.rawQuery("select * from t_person limit ? , ? ", new String[] {
						String.valueOf(startNum), String.valueOf(perNum) });
		while (cs.moveToNext()) {
			Person p = new Person();
			p.setId(cs.getInt(cs.getColumnIndex("id")));
			p.setName(cs.getString(cs.getColumnIndex("name")));
			p.setSex(cs.getString(cs.getColumnIndex("sex")));
			p.setAge(cs.getInt(cs.getColumnIndex("age")));
			p.setAmount(cs.getFloat(cs.getColumnIndex("amount")));
			lists.add(p);
		}
		cs.close();
		return lists;
	}

	/**
	 * 功能描述： 统计数据库中数据的数目
	 * 
	 * @return 返回值：返回数据的条数
	 */
	public long getTotalCounts() {
		SQLiteDatabase db = dbHelper.getReadableDatabase();
		Cursor cs = db.rawQuery("select count(*) from t_person ", null);
		if (cs.moveToNext()) {
			return cs.getLong(0);
		}
		return 0;
	}

	/**
	 * 功能描述： 使用事务进行控制两条信息的更新操作，从源用户转出指定金额到目的用户
	 * 
	 * @param id
	 *            源用户id
	 * @param amount
	 *            转换金额
	 * @param tid
	 *            目的用户id
	 */
	public void transAmount(int id, float amount, int tid) {
		SQLiteDatabase db = dbHelper.getWritableDatabase();
		// 开启事务
		db.beginTransaction();
		try {
			if (findById(id) != null && findById(tid) != null) {
				db.execSQL("update t_person set amount = amount - ? where id = ? ", new Object[] { amount, id });
				db.execSQL("update t_person set amount = amount + ? where id = ? ", new Object[] { amount, tid });
				// 设置事务的成功标志
				db.setTransactionSuccessful();
			}
		} catch (SQLException e) {
		} finally {
			// 结束事务，如果设置事务是否成功标志为成功时，则此时先提交事务再结束，否则就是回滚事务并结束
			db.endTransaction();
		}
	}
	
	/**
	 * 功能描述：
	 *         关闭数据库资源
	 */
	public void closeDB(){
		dbHelper.close();
	}

}

评论

3 楼 ginpq 2011-09-19  

请问DBService.java 和 DBSQLService.java　是两种不同的方式操作数据库吗？
会有什么区别吗？

2 楼 liushian 2011-07-15  

代码标准，注释详细。看得出楼主是一个优秀的程序员！

1 楼 liushian 2011-07-15  

很好！浅显易懂，我在我的程序中使用了。
谢谢！