Android之Sqlite的增删查操作-低调大师

Android之Sqlite的增删查操作

2017-11-06 524

今天写了个sqlite CRUD的操作实例，这里做个笔记。android的存储方式有很多有sharedpreferenced、file、xml、sqlite等。

sqlite的介绍网络上实在是多，俺还是直接代码。对用户的注册情况进行CRUD操作。

1、首先创建个DBHelper继承SQLiteOpenHelper

package com.xzw.db.utils;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteDatabase.CursorFactory;
import android.database.sqlite.SQLiteOpenHelper;
/**
* 该类是一个数据库的帮助类，用于创建数据库
* @author xzw
*
*/
public class DBHelper extends SQLiteOpenHelper {
private static final String TAG = "DBHelper";
private String dbName;
private String tableName;
private String createTableSql;
/**
*
* @param context 上下文
* @param dbName 数据库名
* @param version 数据库版本号
* @param tableName 表名称
* @param createTableSql 建表Sql
*/
public DBHelper(Context context, String dbName,int version,String tableName,String createTableSql) {
super(context, dbName, null, version);
this.dbName = dbName;
this.tableName = tableName;
this.createTableSql = createTableSql;
}
@Override
public void onCreate(SQLiteDatabase db) {
db.execSQL(createTableSql);
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
String sql = "DROP TABLE IF EXISTS "+tableName;
db.execSQL(sql);
onCreate(db);
}
}

2、创建User对象

package com.xzw.db.bean;
public class User {
private Integer userid;
private String userName;
private String password;
private String sex;
private long regTime;
public User() {
}
public User(String userName, String password, String sex, long regTime) {
this.userName = userName;
this.password = password;
this.sex = sex;
this.regTime = regTime;
}
public User(Integer userid, String userName, String password, String sex,
long regTime) {
this.userid = userid;
this.userName = userName;
this.password = password;
this.sex = sex;
this.regTime = regTime;
}
public Integer getUserid() {
return userid;
}
public void setUserid(Integer userid) {
this.userid = userid;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getSex() {
return sex;
}
public void setSex(String sex) {
this.sex = sex;
}
public long getRegTime() {
return regTime;
}
public void setRegTime(long regTime) {
this.regTime = regTime;
}
@Override
public String toString() {
// TODO Auto-generated method stub
return "[User]userid = " + userid + " ,userName = " + userName
+ ", password = " + password + ", sex = " + sex + ",regTime = "
+ regTime;
}
}

3、创建UserStorage进行crud处理。

package com.xzw.db.utils;
import java.util.ArrayList;
import java.util.List;
import com.xzw.db.bean.User;
import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
public class UserStorage {
private static final String TAG = "UserStorage";
private static final String DB_NAME = "user_data.db";
public static final String TABLE_NAME = "user_data";
private static final int DB_VERSION = 1;
static final String COLUM_ID = "_id";
static final String COLUM_USER_NAME = "username";
static final String COLUM_PASSWORD = "password";
static final String COLUM_SEX = "sex";
static final String COLUM_REG_TIME = "reg_time";
private String mCreateTableSql = "create table if not exists " + TABLE_NAME
+ "("+COLUM_ID+" integer primary key autoincrement,"
+COLUM_USER_NAME + " text not null,"
+COLUM_PASSWORD + " text not null,"
+COLUM_SEX + " text,"
+COLUM_REG_TIME + " bigint not null"
+")";
private DBHelper dbHelper;
public UserStorage(Context context){
dbHelper = new DBHelper(context, DB_NAME, DB_VERSION, TABLE_NAME, mCreateTableSql);
}
/**
* 插入数据
* @param cv
* @return
*/
public long insert(ContentValues cv){
//以写的方式创建或打开数据库
SQLiteDatabase db = dbHelper.getWritableDatabase();
long result = db.insert(TABLE_NAME, null, cv);
db.close(); //操作完成记得关闭数据库
if(result > 0 ){
Log.i(TAG, "[Insert] success:" + result);
}else{
Log.e(TAG, "Failed to insert into " + TABLE_NAME);
}
return result;
}
/**
* 批量插入多条数据
* @param cvs
* @return
*/
public int insert(List<ContentValues> cvs){
int count = 0;
SQLiteDatabase db = dbHelper.getWritableDatabase();
for(ContentValues cv : cvs){
long id = insert(cv,db);
count += id>0?1:0;
}
db.close();
return count;
}
/**
* 插入数据
* @param cv
* @param db
* @return
*/
private long insert(ContentValues cv,SQLiteDatabase db){
long result = db.insert(TABLE_NAME, null, cv);
if(result > 0 ){
Log.i(TAG, "[Insert] success:" + result);
}else{
Log.e(TAG, "Failed to insert into " + TABLE_NAME);
}
return result;
}
/**
* 根据id更新记录
* @param cv
* @param id
* @return
*/
public int updateUserById(ContentValues cv,String id){
SQLiteDatabase db = dbHelper.getWritableDatabase();
int result = db.update(TABLE_NAME, cv, "_id=?", new String[]{id});
db.close();
if(result > 0 ){
Log.i(TAG, "[Update] success:" + result);
}else{
Log.e(TAG, "Failed to upate " + TABLE_NAME);
}
return result;
}
/**
* 获取所有列
* @return
*/
public String[] getColumns(){
return new String[]{COLUM_ID,COLUM_USER_NAME,COLUM_PASSWORD,COLUM_SEX,COLUM_REG_TIME};
}
public List<User> getAllUser(){
List<User> users = new ArrayList<User>();
SQLiteDatabase db = dbHelper.getReadableDatabase();
Cursor cursor = db.query(TABLE_NAME, getColumns(), null, null, null, null, COLUM_ID);
while(cursor.moveToNext()){
User user = fillUser(cursor);
//添加user到集合中
users.add(user);
}
cursor.close(); //游标使用完成后记得关闭
db.close();
return users;
}
private User fillUser(Cursor cursor) {
User user = new User();
user.setUserid(cursor.getInt(cursor.getColumnIndex(COLUM_ID)));
user.setUserName(getValueByColumnName(cursor,COLUM_USER_NAME));
user.setPassword(getValueByColumnName(cursor,COLUM_PASSWORD));
user.setSex(getValueByColumnName(cursor,COLUM_SEX));
user.setRegTime(cursor.getLong(cursor.getColumnIndex(COLUM_REG_TIME)));
return user;
}
/**
* 根据ID获取数据
* @param id
* @return
*/
public User getUserById(String id){
SQLiteDatabase db = dbHelper.getReadableDatabase();
String where = "_id=?";
String[] selectionArgs = new String[]{id};
Cursor cursor = db.query(TABLE_NAME, getColumns(), where, selectionArgs, null, null, null);
User user = null;
if(cursor.moveToFirst()){
user = fillUser(cursor);
}
cursor.close(); //游标使用完成后记得关闭
db.close();
return user;
}
/**
* 根据id删除记录
* @param id
* @return
*/
public int deleteById(String id){
SQLiteDatabase db = dbHelper.getWritableDatabase();
int result = db.delete(TABLE_NAME, "_id=?", new String[]{id});
db.close();
if(result > 0 ){
Log.i(TAG, "[Delete] success:" + result);
}else{
Log.e(TAG, "Failed to delete from " + TABLE_NAME);
}
return result;
}
//获取字段值
private String getValueByColumnName(Cursor cursor,String columnName){
return cursor.getString(cursor.getColumnIndex(columnName));
}
/**
* 清空表数据
* @param id
* @return
*/
public void clear(){
SQLiteDatabase db = dbHelper.getWritableDatabase();
db.delete(TABLE_NAME, null, null);
db.close();
}
}

4、编写UserService进行业务处理。

package com.xzw.db.utils;
import java.util.ArrayList;
import java.util.List;
import android.content.ContentValues;
import android.content.Context;
import android.os.storage.StorageManager;
import com.xzw.db.bean.User;
public class UserService {
private UserStorage userStorage;
public UserService(Context context){
userStorage = new UserStorage(context);
}
/**
* 保存用户
*
* @param user
* @return
*/
public long saveUser(User user){
ContentValues cv = fillContentValues(user);
long count = userStorage.insert(cv);
return count;
}
/**
* 批量保存用户
* @param users
* @return
*/
public long saveUser(List<User> users){
List<ContentValues> contentValues = new ArrayList<ContentValues>();
for(User user:users){
ContentValues cv = fillContentValues(user);
contentValues.add(cv);
}
long count = userStorage.insert(contentValues);
return count;
}
/**
* 根据id修改数据
* @param user
* @return
*/
public int updateUserById(User user){
ContentValues contentValues = fillContentValues(user);
return userStorage.updateUserById(contentValues, user.getUserid().toString());
}
/**
* 获取所有用户信息
* @return
*/
public List<User> getAllUser(){
return userStorage.getAllUser();
}
/**
* 根据id获取用户信息
* @param id
* @return
*/
public User getUserById(String id){
return userStorage.getUserById(id);
}
/**
* 根据id删除数据
* @param id
* @return
*/
public int deleteById(String id){
return userStorage.deleteById(id);
}
/**
* 删除所有数据
*/
public void deleteAll(){
userStorage.clear();
}
/**
* 填充数据
* @param user
* @return
*/
private ContentValues fillContentValues(User user) {
//以下代码比较多地方会用带，故将其抽象成为方法。也是一种优化手段
ContentValues cv = new ContentValues();
cv.put(UserStorage.COLUM_USER_NAME, user.getUserName());
cv.put(UserStorage.COLUM_PASSWORD, user.getPassword());
cv.put(UserStorage.COLUM_SEX, user.getSex());
cv.put(UserStorage.COLUM_REG_TIME, user.getRegTime());
return cv;
}
}

以上是整个业务流程了。现在使用AndroidTestCase进行测试

创建TestUser继承AndroidTestCase

package com.xzw.db;
import java.util.ArrayList;
import java.util.List;
import com.xzw.db.bean.User;
import com.xzw.db.utils.UserService;
import com.xzw.db.utils.UserStorage;
import android.test.AndroidTestCase;
import android.util.Log;
public class TestUser extends AndroidTestCase {
private static final String TAG = "TestUser";
/**
* 测试添加用户
*/
public void testSave(){
UserService userService = new UserService(this.getContext());
User user = new User("xzw", "123456", "男", System.currentTimeMillis());
userService.saveUser(user);
}
/**
* 测试批量添加用户
*/
public void testBatchSave(){
UserService userService = new UserService(this.getContext());
List<User> users = new ArrayList<User>();
for(int i=0;i<10;i++){
User user = new User("hh-"+i, "123456", (i%2==0)?"男":"女", System.currentTimeMillis());
users.add(user);
}
userService.saveUser(users);
}
public void testGetAllUser(){
UserService userService = new UserService(this.getContext());
List<User> users =userService.getAllUser();
for(User user : users){
Log.i(TAG, user.toString());
}
}
public void testGetUserById(){
UserService userService = new UserService(this.getContext());
User user =userService.getUserById("2");
Log.i(TAG, user.toString());
}
public void testUpdateUser(){
UserService userService = new UserService(this.getContext());
User user = userService.getUserById("2");
user.setUserName("测试用户");
userService.updateUserById(user);
}
public void testDeleteById(){
UserService userService = new UserService(this.getContext());
userService.deleteById("1");
}
}

代码全部编写完毕，运行前需要在AndroidManifest.xml文件添加

<manifest xmlns:android="http://schemas.android.com/apk/res/android"
package="com.xzw.db"
android:versionCode="1"
android:versionName="1.0" >
<uses-sdk
android:minSdkVersion="8"
android:targetSdkVersion="15" />
<application
android:icon="@drawable/ic_launcher"
android:label="@string/app_name"
android:theme="@style/AppTheme" >
<uses-library android:name="android.test.runner"/>
<activity
android:name=".MainActivity"
android:label="@string/title_activity_main" >
<intent-filter>
<action android:name="android.intent.action.MAIN" />
<category android:name="android.intent.category.LAUNCHER" />
</intent-filter>
</activity>
</application>
<instrumentation android:name="android.test.InstrumentationTestRunner"
android:targetPackage="com.xzw.db" android:label="Tests for My App"/>
</manifest>

以上就是整个sqlite crud的操作了。

查询所有用户信息：

根据id进行查询。

update后查询的结果。

以上就是完整的过程了。

本文转自xuzw13 51CTO博客，原文链接：http://blog.51cto.com/xuzhiwei/1054965，如需转载请自行联系原作者

微信关注我们

原文链接：https://yq.aliyun.com/articles/478383

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

android之webview无网络情况下简单处理

android的webview是如何使用的网络上一搜索就是一大页面的资料。通常我们通过webview来访问web页面都是在网络的情况下，一旦没有网络就会显示"无法找到该网页"的信息，这样会暴露我们的连接，所以我们需要一个有好的提示，并且不会暴露链接的方法。这时候WebViewClient的onReceivedError方法就派上了用场！废话不多说直接上代码。 1、创建android的工程，编写main.xml布局代码 <RelativeLayoutxmlns:android="http://schemas.android.com/apk/res/android" xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent" android:layout_height="match_parent"> <WebView android:id="@+id/webview" android:layout_width="fill_parent" android:layou...

2017-11-07

922

让动画不再僵硬：Facebook Rebound Android动画库介绍

official site：http://facebook.github.io/rebound github :https://github.com/facebook/rebound Rebound是facebook推出的一个弹性动画库，可以让动画看起来真实自然，像真实世界的物理运动，带有力的效果，使用的参数则是facebook的origami中使用的。官网上有一个简单的JS版本来做demo，如果说到evernote、LinkedIn、flow等应用也在使用这个动画库，是不是会显得更厉害些呢。 Spring spring = mSpringSystem .createSpring() .setSpringConfig(SpringConfig.fromOrigamiTensionAndFriction(86, 7)) .addListener(new SimpleSpringListener() { @Override public void onSpringUpdate(Spring spring) { float value = (float) spring.getCurren...

2017-11-07

633

发表评论

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。