JAVA 数据库操作工具类----sqllite
2024-10-08 15:36:16
package com.asc.db; import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper; /**
* 数据库公共类,提供基本数据库操作*/
public class DBManager {
// 默认数据库
private static final String DB_NAME = "asc.db"; // 数据库版本
private static final int DB_VERSION = 1; // 执行open()打开数据库时,保存返回的数据库对象
private SQLiteDatabase mSQLiteDatabase = null; // 由SQLiteOpenHelper继承过来
private DatabaseHelper mDatabaseHelper = null; // 本地Context对象
private Context mContext = null; private static DBManager dbConn= null; // 查询游标对象
private Cursor cursor; /**
* SQLiteOpenHelper内部类
*/
private static class DatabaseHelper extends SQLiteOpenHelper { DatabaseHelper(Context context) {
// 当调用getWritableDatabase()或 getReadableDatabase()方法时,创建一个数据库
super(context, DB_NAME, null, DB_VERSION);
} @Override
public void onCreate(SQLiteDatabase db) {
db.execSQL("CREATE TABLE ad_record(id PRIMARY KEY NOT NULL, adUrl TEXT, apMac TEXT, createDate DATETIME);");
} @Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
db.execSQL("DROP TABLE IF EXISTS ad_record");
onCreate(db);
}
} /**
* 构造函数
*
* @param mContext
*/
private DBManager(Context mContext) {
super();
this.mContext = mContext;
} public static DBManager getInstance(Context mContext){
if (null == dbConn) {
dbConn = new DBManager(mContext);
}
return dbConn;
} /**
* 打开数据库
*/
public void open() {
mDatabaseHelper = new DatabaseHelper(mContext);
mSQLiteDatabase = mDatabaseHelper.getWritableDatabase();
} /**
* 关闭数据库
*/
public void close() {
if (null != mDatabaseHelper) {
mDatabaseHelper.close();
}
if (null != cursor) {
cursor.close();
}
} /**
* 插入数据
* @param tableName 表名
* @param nullColumn null
* @param contentValues 名值对
* @return 新插入数据的ID,错误返回-1
* @throws Exception
*/
public long insert(String tableName, String nullColumn,
ContentValues contentValues) throws Exception {
try {
return mSQLiteDatabase.insert(tableName, nullColumn, contentValues);
} catch (Exception e) {
throw e;
}
} /**
* 通过主键ID删除数据
* @param tableName 表名
* @param key 主键名
* @param id 主键值
* @return 受影响的记录数
* @throws Exception
*/
public long delete(String tableName, String key, int id) throws Exception {
try {
return mSQLiteDatabase.delete(tableName, key + " = " + id, null);
} catch (Exception e) {
throw e;
}
} /**
* 查找表的所有数据
* @param tableName 表名
* @param columns 如果返回所有列,则填null
* @return
* @throws Exception
*/
public Cursor findAll(String tableName, String [] columns) throws Exception{
try {
cursor = mSQLiteDatabase.query(tableName, columns, null, null, null, null, null);
cursor.moveToFirst();
return cursor;
} catch (Exception e) {
throw e;
}
} /**
* 根据主键查找数据
* @param tableName 表名
* @param key 主键名
* @param id 主键值
* @param columns 如果返回所有列,则填null
* @return Cursor游标
* @throws Exception
*/
public Cursor findById(String tableName, String key, int id, String [] columns) throws Exception {
try {
return mSQLiteDatabase.query(tableName, columns, key + " = " + id, null, null, null, null);
} catch (Exception e) {
throw e;
}
} /**
* 根据条件查询数据
* @param tableName 表名
* @param names 查询条件
* @param values 查询条件值
* @param columns 如果返回所有列,则填null
* @param orderColumn 排序的列
* @param limit 限制返回数
* @return Cursor游标
* @throws Exception
*/
public Cursor find(String tableName, String [] names, String [] values, String [] columns, String orderColumn, String limit) throws Exception{
try {
StringBuffer selection = new StringBuffer();
for (int i = 0; i < names.length; i++) {
selection.append(names[i]);
selection.append(" = ?");
if (i != names.length - 1) {
selection.append(",");
}
}
cursor = mSQLiteDatabase.query(true, tableName, columns, selection.toString(), values, null, null, orderColumn, limit);
cursor.moveToFirst();
return cursor;
} catch (Exception e) {
throw e;
}
} /**
*
* @param tableName 表名
* @param names 查询条件
* @param values 查询条件值
* @param args 更新列-值对
* @return true或false
* @throws Exception
*/
public boolean udpate(String tableName, String [] names, String [] values, ContentValues args) throws Exception{
try {
StringBuffer selection = new StringBuffer();
for (int i = 0; i < names.length; i++) {
selection.append(names[i]);
selection.append(" = ?");
if (i != names.length - 1) {
selection.append(",");
}
}
return mSQLiteDatabase.update(tableName, args, selection.toString(), values) > 0;
} catch (Exception e) {
throw e;
}
} /**
* 执行sql语句,包括创建表、删除、插入
*
* @param sql
*/
public void executeSql(String sql) {
mSQLiteDatabase.execSQL(sql);
} }
最新文章
- 【BZOJ-1146】网络管理Network DFS序 + 带修主席树
- WebService -- Java 实现之 CXF (WebService 服务器端接口)
- 动态页面 servlet
- 分布式缓存技术redis学习系列(三)——redis高级应用(主从、事务与锁、持久化)
- Hyper-V初涉_虚拟磁盘链错误的解决方案
- Canvas绘画功能(待补充)
- django xadmin多个model的数据渲染在统一个template中
- Java设计模式-适配器模式(Adapter)
- Navicat for MySQL数据库管理工具
- [转载] leveldb日知录
- HTML5新增结构标签
- 非刚性图像配准 matlab简单示例 demons算法
- WPF4多点触摸事件
- 掀起Azure AD的盖头来&mdash;&mdash;深入理解Microsoft Graph应用程序和服务权限声明
- 【VSTS 日志】TFS 2015 Update 1 发布 – Git和TFVC代码库可以混合使用了
- JavaWeb之 JSP:自定义标签的创建和使用
- Spring Boot + Spring Cloud 构建微服务系统(九):配置中心(Spring Cloud Config)
- 洗礼灵魂,修炼python(58)--爬虫篇—【转载】urllib3模块
- JsTree使用一例
- ffmpeg 下载安装和简单应用
热门文章
- 棍子Sticks(poj_1011)[经典搜索]
- Linux系统常用运维命令汇总
- Spring Boot Security 使用教程
- N3K异常重启(案例)
- windows下的环境搭建配置redis
- CentOS上安装elasticsearch
- 人工神经网络(从原理到代码) Step 01 感知器 梯度下降
- php 基础 PHP保留两位小数的几种方法
- PHP的isset()、is_null、empty()使用总结
- Unknown column '×;×;' in 'where clause',出现这个问题,如何处理?