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);}@Overridepublic 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)");}@Overridepublic 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();}}

更多相关文章

随机推荐