【Android 开发】:数据存储之 SQLite 数据库操作(三)

前端之家收集整理的这篇文章主要介绍了【Android 开发】:数据存储之 SQLite 数据库操作(三)前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
上一讲中我们讲到了sqlite数据库的操作方法 [数据存储之SQLite数据库操作(二)],我们主要是以sql语句对数据库进行增删改查,这一讲我们来学习一下 Android 建议的对数据库的操作方法
查看 sqliteDatabase 中,在上一讲中有讲到 execsql (String sql,Object[] bindArgs) 这个方法,在这里Android建议我们在操纵数据库的时候用以下几种方式:
1) 插入:
insert(String,String,ContentValues)
insertOrThrow(String,ContentValues)
insertWithOnConflict(String,ContentValues,int)

2) 更新:
update(String,String[])
updateWithOnConflict(String,String[],int)

3) 删除
delete(String,String[])

[注]这一讲中我们就来使用Android推荐的这些操作数据库方法来进行数据库的操作,Demo 还是与上一讲类似,读者可以结合上一讲内容来学习,对比之间的不同。

1. 方法概要

1) 查看API文档 sqliteDatabase 中的
public long insert (String table,String nullColumnHack,ContentValues values)
插入一行数据到数据库
参数:
table : 需要插入行的表的名称
nullColumnHack : 这个参数是可选的,可以为null,sql 不允许插入一个至少一列都不命名的完全空的行。如果你提供的 values 是空的,而且
没有已知的的列名,这就是一个空行,这是不能被插入的。如果设置非空,nullColumnHack 参数提供一个可为空的列的名称,当插入的 values 是空的时候,就将这个列名置为NULL,然后values值插入。
values : 指定行对应的列的值,这个类型很类似Map,key表示列的名称,values表示列的值
返回值:
返回新插入的行的ID,如果存在错误默认返回 -1
[备注]第二个参数翻译的有些拘谨,我们可以这样理解
当在没有任何已知的列名的情况下,values参数为空的时候,insert是会失败的(数据库不允许插入一个空行),为了防止Insert()方法要求必须添加一条除了主键之外其它字段为Null值的记录,我们要在这里必须指定一个列名[因为values值是以ContentValues 的形式来存储的],到时候如果发现将要插入的行为空行时,就会将你指定的这个列名的值设为null,然后再将values值向NULL列中插入。查看源代码,我们可以发现 Android 中操作数据库方法底层也是通过构造sql语句来实现的。
2) 查看API文档sqliteDatabase 中
public int delete (String table,String whereClause,String[] whereArgs)
删除操作

table : 表示表名
whereClause : 可选项,是可以通过 sql语句中where语句来过滤条件删除的条目,如果是null 表示删除所有行
whereArgs : 紧跟第二个参数,作为删除过滤条件的占位符,详情请看下面程序 PersonDao2 的 deletePerson() 方法的操作。
如果是 0 表示未删除任何行,如果已经有删除行的操作 会得到 count > 0的数,表示删除的行数

3) 查看API文档sqliteDatabase 中的

public int update (String table,ContentValues values,String[] whereArgs)
更新操作

参数 :
table : 表示表名
values : Map 中指定列名用来更新新的值,如果是null 值则为修改为 NULL
whereClause : 可选项,支持sql中的更新语句,用来做条件过滤,如果设置null 则会更新所有行
whereArgs : 紧跟第二个参数,作为更新过滤条件的占位符,详情请看下面程序 PersonDao2 的updatePerson () 方法的操作。
返回所更新的数据库的行数

4)查看API文档sqliteDatabase 中

查询操作 query(),可以发现 sqliteDatabase 中有大量的 query() 查询的重载方法,其实这边它不管怎么重载,都是遵循 sql 语句来的这里我就剖析一个最为常见的查询方法,其他的读者自己查看文档说明.

public Cursor query (boolean distinct,String table,String[] columns,String selection,String[] selectionArgs,String groupBy,String having,String orderBy,String limit)
distinct : 判断是否返回的行是唯一值,如果想要返回唯一的行,则为true,否则为false。
table : 需要查询的表的名称
columns : 需要返回的列,如果要返回所有列则置为null。
selection : 过滤需要返回的行,格式遵从sqlsql WHERE 语句(除了Where关键字以外).如果返回给定表的所有行,则置为Null。
selectionArgs : 过滤条件的占位符,这里的值会代替过滤语句中 "?"。
groupBy : 过滤条件对行进行分组,格式遵从sqlsql GROUP BY 语句 (除了关键字GROUP BY之外),如果不分组,置为Null。
having : 对分组过滤条件的占位符操作。
orderBy : 如何进行排序,遵从sql中的sql ORDER BY 语句,如果是null表示使用默认的排序顺序。
limit :是否对数据库进行分页查询
返回值:
它返回的是一个游标,这个用法之前有讲过,不懂的可以查看前面几讲内容的介绍

2. 代码实现

1) 程序布局文件 activity_main.xml,这里只是定义了几个按钮,就不贴出来了

2) DBOpenHelper.java 用来创建数据库使用

package com.android.sqlitedemo.db;

import android.content.Context;
import android.database.sqlite.sqliteDatabase;
import android.database.sqlite.sqliteOpenHelper;

public class DBOpenHelper extends sqliteOpenHelper {

    private static String name = "mydb.db"; // 表示数据库名称
    private static int version = 1; // 表示数据库的版本号

    public DBOpenHelper(Context context) {
        super(context,name,null,version);
        // TODO Auto-generated constructor stub
    }

    // 当数据库创建的时候,是第一次被执行,完成对数据库的表的创建
    @Override
    public void onCreate(sqliteDatabase db) {
        // TODO Auto-generated method stub
        // sqlite 数据创建支持的数据类型: 整型数据,字符串类型,日期类型,二进制的数据类型
        // 数据库这边有一个特点,就是sqlite数据库中文本类型没有过多的约束,也就是可以把布尔类型的数据存储到文本类型中,这样也是可以的
        String sql = "create table person(id integer primary key autoincrement,name varchar(64),address varchar(64),sex varchar(8))";
        db.execsql(sql); // 完成数据库的创建
    }

    @Override
    public void onUpgrade(sqliteDatabase db,int oldVersion,int newVersion) {
        // TODO Auto-generated method stub
    }

}
3) PersonService2.java 定义操作数据库(增删改查)的接口
package com.android.sqlitedemo.service;

import android.content.ContentValues;

import java.util.List;
import java.util.Map;


/**
 * 定义好增删改查接口
 * @author xukunhui
 *
 */
public interface PersonService2 {

    public boolean addPersion(ContentValues values); 
    
    public boolean deletePerson(String whereClause,String[] whereArgs);
    
    public boolean updatePerson(ContentValues values,String[] whereArgs);
    
    //使用 Map<String,String> 做一个封装,比如说查询数据库的时候返回的单条记录
    public Map<String,String> viewPerson(String selection,String[] selectionArgs);
    
    //使用 List<Map<String,String>> 做一个封装,比如说查询数据库的时候返回的多条记录
    public List<Map<String,String>> listPersonMaps(String selection,String[] selectionArgs);
}
3) PersonDao2.java 实现操作数据库的增删改查的功能
package com.android.sqlitedemo.dao;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.sqliteDatabase;

import com.android.sqlitedemo.db.DBOpenHelper;
import com.android.sqlitedemo.service.PersonService2;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class PersonDao2 implements PersonService2 {

    private DBOpenHelper helper = null;

    public PersonDao2(Context context) {
        helper = new DBOpenHelper(context);
    }

    @Override
    public boolean addPersion(ContentValues values) {
        // TODO Auto-generated method stub
        boolean flag = false;
        sqliteDatabase database = null;
        long id = -1;
        try {
            database = helper.getWritableDatabase();
            id = database.insert("person",values);
            flag = (id != -1 ? true : false);
        } catch (Exception e) {
            // TODO: handle exception
        } finally {
            if (database != null) {
                database.close();
            }
        }
        return flag;
    }

    @Override
    public boolean deletePerson(String whereClause,String[] whereArgs) {
        // TODO Auto-generated method stub
        boolean flag = false;
        sqliteDatabase database = null;
        int count = 0;
        try {
            database = helper.getWritableDatabase();
            count = database.delete("person",whereClause,whereArgs);
            flag = (count > 0 ? true : false);
        } catch (Exception e) {
            // TODO: handle exception
        } finally {
            if (database != null) {
                database.close();
            }
        }
        return flag;
    }

    @Override
    public boolean updatePerson(ContentValues values,String[] whereArgs) {
        // TODO Auto-generated method stub
        boolean flag = false;
        sqliteDatabase database = null;
        int count = 0; // 影响数据库的行数
        try {
            database = helper.getWritableDatabase();
            count = database.update("person",values,whereArgs);
            flag = (count > 0 ? true : false);
        } catch (Exception e) {
            // TODO: handle exception
        } finally {
            if (database != null) {
                database.close();
            }
        }
        return flag;
    }

    // 查询单条记录
    @Override
    public Map<String,String[] selectionArgs) {
        // TODO Auto-generated method stub
        // select * from
        // * 表示 返回的列的名称(投影查询) from
        sqliteDatabase database = null;
        Cursor cursor = null;
        Map<String,String> map = new HashMap<String,String>();
        try {
            database = helper.getReadableDatabase();
            cursor = database.query(true,"person",selection,selectionArgs,null); //查询单条记录,记录是唯一的,所以第一个参数置为 true.
            int cols_len = cursor.getColumnCount(); // 获取游标个数,即查询所得的结果数目
            while (cursor.moveToNext()) {
                for (int i = 0; i < cols_len; i++) {
                    String cols_name = cursor.getColumnName(i);
                    String cols_values = cursor.getString(cursor.getColumnIndex(cols_name));
                    if (cols_values == null) {
                        cols_values = "";
                    }
                    map.put(cols_name,cols_values);
                }
            }
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        } finally {
            if (database != null) {
                database.close();
            }
        }
        return map;
    }

    // 查询多条记录
    @Override
    public List<Map<String,String[] selectionArgs) {
        // TODO Auto-generated method stub
        sqliteDatabase database = null;
        Cursor cursor = null;
        List<Map<String,String>> list = new ArrayList<Map<String,String>>();
        try {
            database = helper.getReadableDatabase();
            cursor = database.query(false,null); //查询所有记录,所以有重复的数据也要全部检出,所以第一参数置为false.
            int cols_len = cursor.getColumnCount();
            while (cursor.moveToNext()) {
                Map<String,String>();
                for (int i = 0; i < cols_len; i++) {
                    String cols_name = cursor.getColumnName(i);
                    String cols_values = cursor.getString(cursor.getColumnIndex(cols_name));
                    if (cols_values == null) {
                        cols_values = "";
                    }
                    map.put(cols_name,cols_values);
                }
                list.add(map);
            }
        } catch (Exception e) {
            // TODO: handle exception
            e.printStackTrace();
        } finally {
            if (database != null) {
                database.close();
            }
        }
        return list;
    }
}

4) MainActivity.java 点击按钮触发操作数据的事件
package com.android.sqlitedemo;

import java.util.List;
import java.util.Map;

import com.android.sqlitedemo.dao.PersonDao2;
import com.android.sqlitedemo.db.DBOpenHelper;
import com.android.sqlitedemo.service.PersonService2;

import android.os.Bundle;
import android.app.Activity;
import android.content.ContentValues;
import android.util.Log;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;

public class MainActivity extends Activity {

    private Button button1;
    private Button button2;
    private Button button3;
    private Button button4;
    private Button button5;
    private Button button6;

    private static final String TAG = "MainActivity";

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        initComponent();
        button1.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                // TODO Auto-generated method stub
                DBOpenHelper helper = new DBOpenHelper(MainActivity.this);
                // 调用 getWritableDatabase()或者 getReadableDatabase()其中一个方法数据库建立
                helper.getWritableDatabase();
            }
        });
        button2.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                // TODO Auto-generated method stub
                PersonService2 service2 = new PersonDao2(MainActivity.this);
                ContentValues values = new ContentValues();
                values.put("name","AHuier");
                values.put("address","XIAMEN");
                values.put("sex","male");
                boolean flag = service2.addPersion(values);
                Log.i(TAG,"---- addPersion --->" + flag);
            }
        });
        button3.setOnClickListener(new OnClickListener() {
            @Override
            public void onClick(View v) {
                PersonService2 service2 = new PersonDao2(MainActivity.this);
                // 删除sql语句 :delete from person where id = ?
                // 不包含 where 关键字
                boolean flag = service2.deletePerson(" id = ? ",new String[] {
                    "4"
                });
                Log.i(TAG,"---- deletePerson ---->" + flag);
            }
        });
        button4.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                // TODO Auto-generated method stub
                PersonService2 service2 = new PersonDao2(MainActivity.this);
                ContentValues values = new ContentValues();
                values.put("name","female");
                boolean flag = service2.updatePerson(values," id = ? ",new String[] {
                    "1"
                });
                Log.i(TAG,"---- updatePerson --->" + flag);
            }
        });
        button5.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                PersonService2 service2 = new PersonDao2(MainActivity.this);
                Map<String,String> map = service2.viewPerson(" id = ? ",new String[] { "2" });
                Log.i(TAG,"---- viewPerson --->" + map.toString());
            }
        });
        button6.setOnClickListener(new OnClickListener() {

            @Override
            public void onClick(View v) {
                PersonService2 service2 = new PersonDao2(MainActivity.this);
                // select * from person
                List<Map<String,String>> list = service2.listPersonMaps(null,null);
                Log.i(TAG,"---- viewPerson --->" + list.toString());
            }
        });
    }

    @Override
    public boolean onCreateOptionsMenu(Menu menu) {
        // Inflate the menu; this adds items to the action bar if it is present.
        getMenuInflater().inflate(R.menu.main,menu);
        return true;
    }

    private void initComponent() {
        button1 = (Button) findViewById(R.id.button1);
        button2 = (Button) findViewById(R.id.button2);
        button3 = (Button) findViewById(R.id.button3);
        button4 = (Button) findViewById(R.id.button4);
        button5 = (Button) findViewById(R.id.button5);
        button6 = (Button) findViewById(R.id.button6);
    }

}

3. 程序执行过程

1) 插入数据


2) 删除ID = 4 的数据


3) 修改ID = 1 的数据


4) 返回查询的单条记录和多条记录




附该 Demo 的源代码下载地址: http://download.csdn.net/my/uploads

猜你在找的Sqlite相关文章