查看 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) 删除:
1. 方法概要
1) 查看API文档 sqliteDatabase 中的
public long insert (String table,String nullColumnHack,ContentValues values)
插入一行数据到数据库中
public long insert (String table,String nullColumnHack,ContentValues values)
插入一行数据到数据库中
参数:table : 需要插入行的表的名称nullColumnHack : 这个参数是可选的,可以为null,sql 不允许插入一个至少一列都不命名的完全空的行。如果你提供的 values 是空的,而且
没有已知的的列名,这就是一个空行,这是不能被插入的。如果设置非空,nullColumnHack 参数提供一个可为空的列的名称,当插入的 values 是空的时候,就将这个列名置为NULL,然后values值插入。values : 指定行对应的列的值,这个类型很类似Map,key表示列的名称,values表示列的值返回值:返回新插入的行的ID,如果存在错误默认返回 -1
table : 表示表名
3) 查看API文档sqliteDatabase 中的
public int update (String table,ContentValues values,String[] whereArgs)
更新操作
参数 :返回所更新的数据库的行数
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。columns : 需要返回的列,如果要返回所有列则置为null。 selectionArgs : 过滤条件的占位符,这里的值会代替过滤语句中 "?"。having : 对分组过滤条件的占位符操作。
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