SQLite用户信息的增删改查

package com.scc.sqlite; import android.content.ContentValues; import android.content.Context; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteOpenHelper; import android.util.Log; import java.util.ArrayList; import java.util.List; /** * 创建人：gongtc * 创建时间：2021/6/21 * 功能描述：数据库帮助器SQLiteOpenHelper */ public class UserDBHelper extends SQLiteOpenHelper { private static final String DB_NAME = "user.db";//数据库的名称 private static UserDBHelper mHelper = null;//数据库帮助器的实例 private SQLiteDatabase mDB = null;//数据库的实例 public static final String TABLE_NAME = "user_info"; public static final String _ID = "_id"; public static final String COLUMN_NAME = "name"; public static final String COLUMN_AGE = "age"; public static final String COLUMN_UPDATE_TIME = "update_time"; /** * @param context 上下文环境（例如，一个 Activity） * DB_NAME 数据库名字 * factory null 一个可选的游标工厂（通常是 Null） * @param version 数据库模型版本的整数 * 会调用父类 SQLiteOpenHelper的构造函数 */ public UserDBHelper(Context context, int version) { super(context, DB_NAME, null, version); } //利用单例模式获取SQLiteOpenHelper的唯一实例 public static UserDBHelper getInstance(Context context, int version) { if (version > 0 && mHelper == null) { mHelper = new UserDBHelper(context, version); } return mHelper; } //打开数据库的读连接(查询数据库) public SQLiteDatabase openReadLink() { if (mDB == null || !mDB.isOpen()) { mDB = mHelper.getReadableDatabase(); } return mDB; } //打开数据库的写连接(可写数据库) public SQLiteDatabase openwriteLink() { if (mDB == null || !mDB.isOpen()) { mDB = mHelper.getWritableDatabase(); } return mDB; } //关闭数据库连接 public void closeLink() { if (mDB != null && mDB.isOpen()) { mDB.close(); } mDB = null; } //创建数据库，执行建表语句 @Override public void onCreate(SQLiteDatabase db) { Log.e(getClass().getName(), "onCreate"); //创建表语句 String SQL_CREATE_ENTRIES = "CREATE TABLE IF NOT EXISTS " + TABLE_NAME + "(" + _ID + " INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL," + COLUMN_NAME+" VARCHAR NOT NULL," + COLUMN_AGE+" INTEGER NOT NULL," + COLUMN_UPDATE_TIME+" VARCHAR NOT NULL" + "); "; //执行完整的sQL语句 db.execSQL(SQL_CREATE_ENTRIES); } /** * 当数据库需要修改的时候（两个数据库版本不同），Android系统会主动的调用这个方法。 * 一般我们在这个方法里边删除数据库表，并建立新的数据库表. */ @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { //这个数据库只是在线数据的缓存，所以它的升级策略是 //简单地丢弃数据并重新开始 Log.e(getClass().getName(), "onUpgrade"); //删除表语句 String SQL_DELETE_ENTRIES = "DROP TABLE IF EXISTS " + TABLE_NAME; db.execSQL(SQL_DELETE_ENTRIES); onCreate(db); } @Override public void onOpen(SQLiteDatabase db) { //每次成功打开数据库后首先被执行 super.onOpen(db); } //根据指定条件删除表记录 public int delete(String condition) { Log.e(getClass().getName(), "delete：" + condition); //执行删除记录动作，该语句返回删除记录的数目 return mDB.delete(TABLE_NAME, condition, null); } //删除表 public void deleteTable(SQLiteDatabase db) { String SQL_DELETE_ENTRIES = "DROP TABLE IF EXISTS " + TABLE_NAME; db.execSQL(SQL_DELETE_ENTRIES); } //往该表添加多条记录 public long insert(List<UserInfoBean> infoList) { long result = -1; for (int i = 0; i < infoList.size(); i++) { UserInfoBean info = infoList.get(i); //不存在唯一性重复的记录，则插入新记录 ContentValues cv = new ContentValues(); cv.put(_ID, info.get_id()); cv.put(COLUMN_NAME, info.getName()); cv.put(COLUMN_AGE, info.getAge()); cv.put(COLUMN_UPDATE_TIME, info.getUpdate_time()); //执行插入记录动作，该语句返回插入记录的行号 result = mDB.insert(TABLE_NAME, "", cv); if (result == -1) {//添加成功则返回行号，添加失败则返回-1 return result; } } return result; } //根据条件更新指定的表记录 public int update(UserInfoBean info, String condition) { ContentValues cv = new ContentValues(); cv.put(COLUMN_NAME, info.getName()); cv.put(COLUMN_AGE, info.getAge()); cv.put(COLUMN_UPDATE_TIME, info.getUpdate_time()); //执行更新记录动作，该语句返回更新的记录数量 return mDB.update(TABLE_NAME, cv, condition, null); } //根据指定条件查询记录，并返回结果数据列表 public List<UserInfoBean> rawQuery(String condition) { String sql = String.format ("select _id, name, age, update_time from %s where %s; ", TABLE_NAME, condition); List<UserInfoBean> infoList = new ArrayList<UserInfoBean>(); //执行记录查询动作，该语句返回结果集的游标 Cursor cursor = mDB.rawQuery(sql,null);//循环取出游标指向的每条记录 while (cursor.moveToNext()) { UserInfoBean info = new UserInfoBean(); info._id = cursor.getString(0);//取出字符串 info.name = cursor.getString(1);//取出字符串 info.age = cursor.getInt(2);//取出整型数 info.update_time = cursor.getString(3);//取出字符串 infoList.add(info); } cursor.close(); // 查询完毕，关闭数据库游标 return infoList; } //根据指定条件查询记录，并返回结果数据列表 public List<UserInfoBean> query() { List<UserInfoBean> infoList = new ArrayList<UserInfoBean>(); //执行记录查询动作，该语句返回结果集的游标 //SELECT语句内容作为 query()方法的参数，比如：要查询的表名，要获取的字段名，WHERE条件， //包含可选的位置参数，去替代WHERE条件中位置参数的值，GROUP BY条件，HAVING条件。 //除了表名，其他参数可以是null Cursor cursor = mDB.query(TABLE_NAME, null, null, null, null, null, null); //循环取出游标指向的每条记录 while (cursor.moveToNext()) { UserInfoBean info = new UserInfoBean(); info._id = cursor.getString(0);//取出字符串 info.name = cursor.getString(1);//取出字符串 info.age = cursor.getInt(2);//取出整型数 info.update_time = cursor.getString(3);//取出字符串 infoList.add(info); } cursor.close(); // 查询完毕，关闭数据库游标 return infoList; } }