经常用得到的安卓数据库基类

Java代码

//创建数据库
public class DBCreate {
public static void CreateDatabase(SQLiteDatabase db) {
db.beginTransaction();
try {
create_NetTaskBuffer(db);
insert_SQL(db);
db.setTransactionSuccessful();
} catch (Exception e) {
e.printStackTrace();
} finally {
db.endTransaction();
}
}
// 缓存
private static void create_NetTaskBuffer(SQLiteDatabase db) {
db.execSQL("DROP TABLE IF EXISTS NetTaskBuffer");
StringBuilder sql = new StringBuilder();
sql.append("CREATE TABLE IF NOT EXISTS NetTaskBuffer (");
sql.append(" id INTEGER PRIMARY KEY AUTOINCREMENT,"); // 这一列不能修改
sql.append(" label TEXT COLLATE NOCASE,"); //
sql.append(" param TEXT COLLATE NOCASE,"); //
sql.append(" result TEXT COLLATE NOCASE,"); //
sql.append(" remark TEXT COLLATE NOCASE,");
sql.append(" time LONG)"); //
db.execSQL(sql.toString());
}
// 插入语句,初始化数据库使用
private static void insert_SQL(SQLiteDatabase db) {
}
}
//----------------------数据库操作基类--------------------------------------//
/**
* 数据库基本操作类,数据库的创建,更新的操作都在这里进行
*
* @author yizhe
* @date 2014-9-11
*/
public abstract class DBHelper extends SQLiteOpenHelper {
static String name = "hk.db"; // 数据库名称
static CursorFactory cursorFactory = null;
static int version = 1000;// 初始版本:1000
Context context;
protected ContentValues contentValues; // cursor对象转行中介,给子类使用
protected String tableName;
protected DBHelper(Context context, String tableName) {
super(context, name, cursorFactory, version);
this.context = context;
this.tableName = tableName;
}
/**
* 软件第一次安装的时候会调用,覆盖安装不会调用
*/
public void onCreate(SQLiteDatabase db) {
// 所有表的创建过程都在这里进行
DBCreate.createDatabase(db);
}
/**
* 覆盖安装,当版本号version发生变化的时候,这个方法才会被调用,而且只执行一次
*/
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
onCreate(db);
// if (oldVersion < 109) {
// onCreate(db);
// } else {
// }
}
/**
* 每次成功打开数据库后首先被执行
*/
public void onOpen(SQLiteDatabase db) {
super.onOpen(db); // 每次成功打开数据库后首先被执行
}
public void finalize() {
close();
}
// --------------------------sql方法---------------------------------//
/**
* 执行sql,没有返回
*/
public void execSQL(String sql) {
System.out.println("==execSQL==" + sql);
SQLiteDatabase db = getWritableDatabase();
db.execSQL(sql);
db.close();
}
/**
* 批量执行sql,内部启用事务
*
* @param list
* sql列表
* @return 是否执行成功
*/
public boolean execSQLBatch(ArrayList<String> list) {
SQLiteDatabase db = getWritableDatabase();
db.beginTransaction();
try {
for (String sql : list) {
db.execSQL(sql);
}
db.setTransactionSuccessful();
} catch (Exception e) {
e.printStackTrace();
return false;
} finally {
db.endTransaction();
db.close();
}
return true;
}
/**
* 根据id删除记录
*
* @param id
* 表中必须有"id"字段
* @return the number of rows affected if a whereClause is passed in, 0
* otherwise. To remove all rows and get a count pass "1" as the
* whereClause.
*/
public int delete(int id) {
SQLiteDatabase db = getWritableDatabase();
int result = db.delete(tableName, "id=?", new String[] { id + "" });
db.close();
return result;
}
/**
* 删除: 只需要写where 条件(不带where) 和参数
*
* @param whereStr
* 例如: "id=?"
* @param arr
* 例如: new String[] { "123" }
* @return 受影响的行
*/
public int delete(String whereStr, String[] arr) {
SQLiteDatabase db = getWritableDatabase();
int result = db.delete(tableName, whereStr, arr);
db.close();
return result;
}
/**
* 清空表
*/
public void clearTable() {
SQLiteDatabase db = getWritableDatabase();
db.execSQL("delete from " + tableName);
db.close();
}
/**
* 通用查询,多用于事务中
*/
public static Cursor Query(SQLiteDatabase db, String sql) {
System.out.println("==Query==" + sql);
return db.rawQuery(sql, new String[] {});
}
/**
* 通用执行sql,,多用于事务中
*
*/
public static void execSQL(SQLiteDatabase db, String sql) {
System.out.println("==execSQL==" + sql);
db.execSQL(sql);
}
}
//-------------------------下面是一个具体实现的DEMO-------------------------------//
/**
* dao类,实现基本的数据库操作<br/>
* 需要保存到数据库中的对象的属性不能使用基本类型,建议只使用Integer 和 String<br/>
* 做为通用对象,从demo创建只要修改tableName即可
*
* @author yizhe
* @date 2012-5-18
*/
public class NetTaskBufferDao extends DBHelper {
int expiryDays = 10; // 数据缓存有效期
public NetTaskBufferDao(Context context) {
super(context, "NetTaskBuffer");
}
// pojo的整数都需要使用Long类型或者Integer类型建议使用Long
public void iniContentValues(NetTaskBuffer pojo) {
contentValues = new ContentValues();
contentValues.put("id", pojo.id);
contentValues.put("label", pojo.label);
contentValues.put("param", pojo.param);
contentValues.put("result", pojo.result);
contentValues.put("remark", pojo.remark);
contentValues.put("time", pojo.time);
}
public NetTaskBuffer setBaseItem(Cursor cursor) {
NetTaskBuffer pojo = new NetTaskBuffer();
pojo.id = cursor.getInt(cursor.getColumnIndex("id"));
pojo.label = cursor.getString(cursor.getColumnIndex("label"));
pojo.param = cursor.getString(cursor.getColumnIndex("param"));
pojo.result = cursor.getString(cursor.getColumnIndex("result"));
pojo.remark = cursor.getString(cursor.getColumnIndex("remark"));
pojo.time = cursor.getLong(cursor.getColumnIndex("time"));
return pojo;
}
// --------------------自定义方法--------------------------------//
public String getBuffer(String label, String param) {
String sql = "select * from " + tableName
+ " where label=? and param=? ";
NetTaskBuffer obj = getOneAsSQL(sql, new String[] { label, param });
if (null == obj) {
return null;
}
Date time = new Date(obj.time);
Calendar c = Calendar.getInstance();
c.add(Calendar.DAY_OF_MONTH, -expiryDays);
if (time.compareTo(c.getTime()) < 0) {
delete(obj.id);
return null;
}
return obj.result;
}
public String getBuffer(String label, String param, String remark) {
String sql = "select * from " + tableName
+ " where label=? and param=? and remark=?";
NetTaskBuffer obj = getOneAsSQL(sql, new String[] { label, param,
remark });
if (null == obj) {
return null;
}
Date time = new Date(obj.time);
Calendar c = Calendar.getInstance();
c.add(Calendar.DAY_OF_MONTH, -expiryDays);
if (time.compareTo(c.getTime()) < 0) {
delete(obj.id);
return null;
}
return obj.result;
}
public void deleteBuffer(String label) {
String whereSql = " label=?";
delete(whereSql, new String[] { label });
}
public void deleteBuffer(String label, String param) {
String whereSql = " label=? and param=?";
delete(whereSql, new String[] { label, param });
}
public void deleteBuffer(String label, String param, String remark) {
String whereSql = " label=? and param=? and remark=?";
delete(whereSql, new String[] { label, param, remark });
}
// --------------------基础方法---------------------------------//
/**
* 根据sql获取list
*/
public ArrayList<NetTaskBuffer> getListAsSQL(String sql) {
SQLiteDatabase db = getReadableDatabase();
Cursor cursor = db.rawQuery(sql, new String[] {});
ArrayList<NetTaskBuffer> itemList = new ArrayList<NetTaskBuffer>();
for (cursor.moveToFirst(); !(cursor.isAfterLast()); cursor.moveToNext()) {
itemList.add(setBaseItem(cursor));
}
cursor.close();
db.close();
return itemList;
}
/**
* 根据ID获取一条记录
*/
public NetTaskBuffer getById(int id) {
String sql = "select * from " + tableName + " where id=" + id;
return getOneAsSQL(sql, null);
}
/**
* 返回结果中的提一条记录
*/
public NetTaskBuffer getOneAsSQL(String sql, String[] arr) {
SQLiteDatabase db = getReadableDatabase();
Cursor cursor = db.rawQuery(sql, arr);
try {
if (null != cursor && cursor.getCount() > 0) {
cursor.moveToFirst();
return setBaseItem(cursor);
}
} finally {
cursor.close();
db.close();
}
return null;
}
/**
* 保存对象到数据库,自动判断插入还是更像
*
* @return 返回更新的记录数,或者插入数据的id,如果返回值<=0表示失败
*/
public long save(NetTaskBuffer pojo) {
if (null == pojo.time || 0 == pojo.time) {
pojo.time = new Date().getTime();
}
Long idOrEffectRows = 0l;
if (null == pojo.id || pojo.id < 1) {
idOrEffectRows = insert(pojo);
} else {
idOrEffectRows = (long) update(pojo);
}
return idOrEffectRows;
}
/**
* 添加数据,自动插入id
*
* @return the row ID of the newly inserted row, or -1 if an error occurred
*/
public long insert(NetTaskBuffer pojo) {
SQLiteDatabase db = getWritableDatabase();// 获取可写SQLiteDatabase对象
iniContentValues(pojo); // ContentValues类似map，存入的是键值对
long result = db.insert(tableName, null, contentValues);
if (result != -1) {
pojo.id = (int) result;
}
db.close();
return result;
}
/**
* 根据ID更新记录的，跟插入的很像
*
* @return the number of rows affected
*
*/
public int update(NetTaskBuffer pojo) {
SQLiteDatabase db = getWritableDatabase();
iniContentValues(pojo); // 初始化键值对
int result = db.update(tableName, contentValues, "id=?",
new String[] { pojo.id + "" });
db.close();
return result;
}
}

时间： 2024-10-07 18:08:02

经常用得到的安卓数据库基类的相关文章

面向对象编程、模块内高内聚、模块间低耦合、数据库操作工具类

一.web.config帮助类(ConfigHelper.cs) 1 using System; 2 using System.Collections.Generic; 3 using System.Configuration; 4 using System.Reflection; 5 6 namespace Common 7 { 8 /// <summary> 9 /// web.config操作类 10 /// author:陈彦斌 11 /// 时间:2019年7月14日23:32:08

通用权限管理系统基类中数据库的连接

public class BaseController : Controller { /// <summary> /// 用户中心Dbhelper /// </summary> public IDbHelper DbHelperUserCenter = GetDbConnection(BaseSystemInfo.UserCenterDbType, BaseSystemInfo.UserCenterDbConnection, ConfigHelper.GetConfigBool(&

基于MVC4+EasyUI的Web开发框架形成之旅--基类控制器CRUD的操作

在上一篇随笔中,我对Web开发框架的总体界面进行了介绍,其中并提到了我的<Web开发框架>的控制器的设计关系,Web开发框架沿用了我的<Winform开发框架>的很多架构设计思路和特点,对Controller进行了封装.使得控制器能够获得很好的继承关系,并能以更少的代码,更高效的开发效率,实现Web项目的开发工作,整个控制器的设计思路如下所示. 从上图的设计里面可以看到,我把主要能通过抽象封装的CRUD方法都放到了BusinessController<B, T>类里面,

phpcms V9 数据模型基类

在学习<phpcms V9首页模板文件解析>的第七步,我们看到content_model类,文件路径:phpcms/model/content_model.class.php 从代码中,可以得知content_model类继承于model类.那么model类又是什么呢? 下面请看数据模型基类model类的解析.文件路径:phpcms\libs\classes\model.class.php 代码及注释,如下所示: 1 <?php 2 /** 3 * model.class.php 数据模

关于java可变（协变）返回类型的解说之一------------基类与派生类

在java代码中,人们惯性的认为一个方法中只能返回一种返回值或者无返回.博主在做开发过程中碰到了这样一种情况,安卓客户端请求数据,后台可能返回两种结果(1)访问令牌失效,无数据返回.(2)正常获取数据. 这样的情况下需要根据访问令牌标识来判断是否有数据返回.当无效时返回用户重新登录提示,正常时则返回数据.显然,返回的结果有两种,那么一个方法里面只能返回一种类型的禁锢使得开发起来略显笨拙.使得开发起来相当难受. 思考良久,又结合C++协变返回类型的启发.摘抄原文中的一句话:在C++中,只要原来的返

Entity Framework 实体框架的形成之旅--为基础类库接口增加单元测试，对基类接口进行正确性校验（10）

本篇介绍Entity Framework 实体框架的文章已经到了第十篇了,对实体框架的各个分层以及基类的封装管理,已经臻于完善,为了方便对基类接口的正确性校验,以及方便对以后完善或扩展接口进行回归测试,那么建立单元测试就有很大的必要,本篇主要介绍如何利用VS创建内置的单元测试项目进行实体框架的基类接口测试. 在采用单元测试这个事情上,很多人可能想到了NUnit单元测试工具和NMock工具进行处理,其实微软VS里面也已经为我们提供了类似的单元测试工具了,可以不需要使用这个第三方的单元测试工具,经试

一步一步搭建开发框架(三)基类基接口

1,AdoNetDal和EfDal都实现IDal这个接口,公共的方法写到接口中,接口中的代码! 1 namespace PCITC.OA.IDal 2 { 3 public interface IUserInforDal 4 { 5 UserInfor Add(UserInfor userInfor); 6 7 bool Update(UserInfor userInfor); 8 9 bool Delete(UserInfor userInfor); 10 11 int Delete(para

基类中定义的虚函数在派生类中重新定义时，其函数原型，包括返回类型、函数名、参数个数、参数类型及参数的先后顺序，都必须与基类中的原型完全相同 but------> 可以返回派生类对象的引用或指针

您查询的关键词是:c++primer习题15.25 以下是该网页在北京时间 2016年07月15日 02:57:08 的快照: 如果打开速度慢,可以尝试快速版:如果想更新或删除快照,可以投诉快照. 百度和网页 http://bbs.csdn.net/topics/380238133 的作者无关,不对其内容负责.百度快照谨为网络故障时之索引,不代表被搜索网站的即时页面. 首页精选版块移动开发 iOS Android Qt WP 云计算 IaaS Pass/SaaS 分布式计算/Hadoop J