android SQLite数据库操作
使用嵌入式关系型SQLite数据库存储数据
CREATE TABLE person (personid integer primary key autoincrement, name varchar(20))
SQLite可以解析大部分标准SQL语句,如:
查询语句:select * from 表名 where 条件子句 group by 分组字句 having ... order by 排序子句
如:select * from person
select * from person order by id desc
select name from person group by name having count(*)>1
分页SQL与mysql类似,下面SQL语句获取5条记录,跳过前面3条记录
select * from Account limit 5 offset 3 或者 select * from Account limit 3,5
插入语句:insert into 表名(字段列表) values(值列表)。如: insert into person(name, age) values(‘chao’,3)
更新语句:update 表名 set 字段名=值 where 条件子句。如:update person set name=‘chao‘ where id=10
删除语句:delete from 表名 where 条件子句。如:delete from person where id=10
使用SQLiteOpenHelper对数据库进行版本管理
为了实现对数据库版本进行管理,SQLiteOpenHelper类提供了两个重要的方法,分别是onCreate(SQLiteDatabase db)和onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion),前者用于初次使用软件时生成数据库表,后者用于升级软件时更新数据库表结构。当调用SQLiteOpenHelper的getWritableDatabase()或者getReadableDatabase()方法获取用于操作数据库的SQLiteDatabase实例的时候,如果数据库不存在,Android系统会自动生成一个数据库,接着调用onCreate()方法,onCreate()方法在初次生成数据库时才会被调用,在onCreate()方法里可以生成数据库表结构及添加一些应用使用到的初始化数据。onUpgrade()方法在数据库的版本发生变化时会被调用,一般在软件升级时才需改变版本号,而数据库的版本是由程序员控制的,假设数据库现在的版本是1,由于业务的变更,修改了数据库表结构,这时候就需要升级软件,升级软件时希望更新用户手机里的数据库表结构,为了实现这一目的,可以把原来的数据库版本设置为2(有同学问设置为3行不行?当然可以,如果你愿意,设置为100也行),并且在onUpgrade()方法里面实现表结构的更新。当软件的版本升级次数比较多,这时在onUpgrade()方法里面可以根据原版号和目标版本号进行判断,然后作出相应的表结构及数据更新。
getWritableDatabase()和getReadableDatabase()方法都可以获取一个用于操作数据库的SQLiteDatabase实例。但getWritableDatabase() 方法以读写方式打开数据库,一旦数据库的磁盘空间满了,数据库就只能读而不能写,倘若使用getWritableDatabase()打开数据库就会出错。getReadableDatabase()方法先以读写方式打开数据库,如果数据库的磁盘空间满了,就会打开失败,当打开失败后会继续尝试以只读方式打开数据库。
//类没有实例化,是不能用作父类构造器的参数,必须声明为静态
private static final String name = "itcast"; //数据库名称
private static final int version = 1; //数据库版本
public DatabaseHelper(Context context) {
//第三个参数CursorFactory指定在执行查询时获得一个游标实例的工厂类,设置为null,代表使用系统默认的工厂类
super(context, name, null, version);
}
@Override public void onCreate(SQLiteDatabase db) {
db.execSQL("CREATE TABLE IF NOT EXISTS person (personid integer primary key autoincrement, name varchar(20), age INTEGER)");
}
@Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
db.execSQL(" ALTER TABLE person ADD phone VARCHAR(12) NULL "); //往表中增加一列
// DROP TABLE IF EXISTS person 删除表
}
}
在实际项目开发中,当数据库表结构发生更新时,应该避免用户存放于数据库中的数据丢失。
package com.example.db; import android.content.Context; import android.database.sqlite.SQLiteDatabase; import android.database.sqlite.SQLiteOpenHelper; public class DBCreate extends SQLiteOpenHelper { /** * 2 是版本号 * * @param context */ public DBCreate(Context context) { super(context, "bing.db", null, 2); // TODO 自动生成的构造函数存根 } @Override public void onCreate(SQLiteDatabase db) { // TODO 自动生成的方法存根 System.out.println("aaaaaaaaaaaaaaaaa onCreate"); db.execSQL("CREATE TABLE person(id integer primary key autoincrement,name VARCHAR(20))"); } /** * onUpgrade()方法在数据库的版本发生变化时会被调用,一般在软件升级时才需改变版本号 */ @Override public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) { // TODO 自动生成的方法存根 System.out.println("aaaaaaaaaaaaaaa onUpgrate"); db.execSQL("ALTER TABLE person ADD address VARCHAR(12) NULL "); } }
使用SQLiteDatabase操作SQLite数据库
execSQL()方法的使用例子:
SQLiteDatabase db = ....;
db.execSQL("insert into person(name, age) values(‘chao‘, 4)");
db.close();
执行上面SQL语句会往person表中添加进一条记录,在实际应用中, 语句中的“chao”这些参数值会由用户输入界面提供,如果把用户输入的内容原样组拼到上面的insert语句, 当用户输入的内容含有单引号时,组拼出来的SQL语句就会存在语法错误。要解决这个问题需要对单引号进行转义,也就是把单引号转换成两个单引号。有些时候用户往往还会输入像“ & ”这些特殊SQL符号,为保证组拼好的SQL语句语法正确,必须对SQL语句中的这些特殊SQL符号都进行转义,显然,对每条SQL语句都做这样的处理工作是比较烦琐的。 SQLiteDatabase类提供了一个重载后的execSQL(String sql, Object[] bindArgs)方法,使用这个方法可以解决前面提到的问题,因为这个方法支持使用占位符参数(?)。使用例子如下:
SQLiteDatabase db = ....;
db.execSQL("insert into person(name, age) values(?,?)", new Object[]{"chao", 4});
db.close();
execSQL(String sql, Object[] bindArgs)方法的第一个参数为SQL语句,第二个参数为SQL语句中占位符参数的值,参数值在数组中的顺序要和占位符的位置对应。
Cursor cursor = db.rawQuery(“select * from person”, null);
while (cursor.moveToNext()) {
int personid = cursor.getInt(0); //获取第一列的值,第一列的索引从0开始
String name = cursor.getString(1);//获取第二列的值
int age = cursor.getInt(2);//获取第三列的值
}
cursor.close();
db.close();
rawQuery()方法的第一个参数为select语句;第二个参数为select语句中占位符参数的值,如果select语句没有使用占位符,该参数可以设置为null。带占位符参数的select语句使用例子如下:
Cursor cursor = db.rawQuery("select * from person where name like ? and age=?", new String[]{"%chao%", "4"});
Cursor是结果集游标,用于对结果a集进行随机访问,如果大家熟悉jdbc, 其实Cursor与JDBC中的ResultSet作用很相似。使用moveToNext()方法可以将游标从当前行移动到下一行,如果已经移过了结果集的最后一行,返回结果为false,否则为true。另外Cursor 还有常用的moveToPrevious()方法(用于将游标从当前行移动到上一行,如果已经移过了结果集的第一行,返回值为false,否则为true )、moveToFirst()方法(用于将游标移动到结果集的第一行,如果结果集为空,返回值为false,否则为true )和moveToLast()方法(用于将游标移动到结果集的最后一行,如果结果集为空,返回值为false,否则为true ) 。
Insert()方法用于添加数据,各个字段的数据使用ContentValues进行存放。 ContentValues类似于MAP,相对于MAP,它提供了存取数据对应的put(String key, Xxx value)和getAsXxx(String key)方法, key为字段名称,value为字段值,Xxx指的是各种常用的数据类型,如:String、Integer等。
SQLiteDatabase db = databaseHelper.getWritableDatabase();
ContentValues values = new ContentValues();
values.put("name", "chao");
values.put("age", 4);
long rowid = db.insert(“person”, null, values);//返回新添记录的行号,与主键id无关
不管第三个参数是否包含数据,执行Insert()方法必然会添加一条记录,如果第三个参数为空,会添加一条除主键之外其他字段值为Null的记录。Insert()方法内部实际上通过构造insert SQL语句完成数据的添加,Insert()方法的第二个参数用于指定空值字段的名称,相信大家对该参数会感到疑惑,该参数的作用是什么?是这样的:如果第三个参数values 为Null或者元素个数为0, 由于Insert()方法要求必须添加一条除了主键之外其它字段为Null值的记录,为了满足SQL语法的需要, insert语句必须给定一个字段名,如:insert into person(name) values(NULL),倘若不给定字段名 , insert语句就成了这样: insert into person() values(),显然这不满足标准SQL的语法。对于字段名,建议使用主键之外的字段,如果使用了INTEGER类型的主键字段,执行类似insert into person(personid) values(NULL)的insert语句后,该主键字段值也不会为NULL。如果第三个参数values 不为Null并且元素的个数大于0 ,可以把第二个参数设置为null。
SQLiteDatabase db = databaseHelper.getWritableDatabase();
db.delete("person", "personid<?", new String[]{"2"});
db.close();
上面代码用于从person表中删除personid小于2的记录。
update()方法的使用:
SQLiteDatabase db = databaseHelper.getWritableDatabase();
ContentValues values = new ContentValues();
values.put(“name”, “chao”);//key为字段名,value为值
db.update("person", values, "personid=?", new String[]{"1"});
db.close();
上面代码用于把person表中personid等于1的记录的name字段的值改为“chao”。
SQLiteDatabase db = databaseHelper.getWritableDatabase();
Cursor cursor = db.query("person", new String[]{"personid,name,age"}, "name like ?", new String[]{"%chao%"}, null, null, "personid desc", "1,2");
while (cursor.moveToNext()) {
int personid = cursor.getInt(0); //获取第一列的值,第一列的索引从0开始
String name = cursor.getString(1);//获取第二列的值
int age = cursor.getInt(2);//获取第三列的值
}
cursor.close();
db.close();
上面代码用于从person表中查找name字段含有“chao”的记录,匹配的记录按personid降序排序,对排序后的结果略过第一条记录,只获取2条记录。
query(table, columns, selection, selectionArgs, groupBy, having, orderBy, limit)方法各参数的含义:
table:表名。相当于select语句from关键字后面的部分。如果是多表联合查询,可以用逗号将两个表名分开。
columns:要查询出来的列名。相当于select语句select关键字后面的部分。
selection:查询条件子句,相当于select语句where关键字后面的部分,在条件子句允许使用占位符“?”
selectionArgs:对应于selection语句中占位符的值,值在数组中的位置与占位符在语句中的位置必须一致,否则就会有异常。
groupBy:相当于select语句group by关键字后面的部分
having:相当于select语句having关键字后面的部分
orderBy:相当于select语句order by关键字后面的部分,如:personid desc, age asc;
limit:指定偏移量和获取的记录数,相当于select语句limit关键字后面的部分。
package dao; import java.util.ArrayList; import java.util.List; import android.content.Context; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; import android.util.Log; import com.example.db.DBCreate; import damain.Person; public class PersonDao { private DBCreate dbOpenHelper; public PersonDao(Context context) { dbOpenHelper = new DBCreate(context); } /** * 添加 * @param name * @param address */ public void add(String name,String address){ boolean result = find(name); if(result) return ; SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if(db.isOpen()){ db.execSQL("insert into person (name,address) values (?,?)",new Object[]{name,address}); db.close(); } } /** * * @param name */ public boolean find(String name){ boolean result; SQLiteDatabase db = dbOpenHelper.getReadableDatabase(); if(db.isOpen()){ Cursor cursor = db.rawQuery("select * from person where name = ?",new String[]{name}); if(cursor.moveToFirst()){ int index = cursor.getColumnIndex("address"); String address = cursor.getString(index); Log.i("chaoyongbing", "address="+address); result = true; } cursor.close(); result = false; db.close(); } result = false; return result; } public void delete(String name){ SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if(db.isOpen()){ db.execSQL("delete from person where name = ?",new Object[]{name}); db.close(); } } public void update(String name,String newname,String newaddress){ SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if(db.isOpen()){ db.execSQL("update person set name = ? , address = ? where name =?",new Object[]{newname,newaddress,name}); db.close(); } } public List<Person> getAllPerson(){ List<Person> persons = null; SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if(db.isOpen()){ persons = new ArrayList<Person>(); Cursor cursor = db.rawQuery("select * from person",null); while(cursor.moveToNext()){ Person person = new Person(); int index1 = cursor.getColumnIndex("name"); int index2 = cursor.getColumnIndex("address"); String name = cursor.getString(index1); String address = cursor.getString(index2); person.setName(name); person.setAddress(address); persons.add(person); } cursor.close(); db.close(); } return persons; } }
使用事务操作SQLite数据库
使用SQLiteDatabase的beginTransaction()方法可以开启一个事务,程序执行到endTransaction() 方法时会检查事务的标志是否为成功,如果程序执行到endTransaction()之前调用了setTransactionSuccessful() 方法设置事务的标志为成功则提交事务,如果没有调用setTransactionSuccessful() 方法则回滚事务。使用例子如下: SQLiteDatabase db = ....;db.beginTransaction();//开始事务
try {
db.execSQL("insert into person(name, age) values(?,?)", new Object[]{"chao", 4});
db.execSQL("update person set name=? where personid=?", new Object[]{"chao1", 1});
db.setTransactionSuccessful();//调用此方法会在执行到endTransaction() 时提交当前事务,如果不调用此方法会回滚事务
} finally {
db.endTransaction();//由事务的标志决定是提交事务,还是回滚事务
}
db.close();
上面两条SQL语句在同一个事务中执行。
综合示例代码:
package com.example.db; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import damain.Person; import dao.PersonDBDao; import dao.PersonDao; import android.app.Activity; import android.content.Context; import android.database.Cursor; import android.os.Bundle; import android.support.v4.widget.CursorAdapter; import android.view.LayoutInflater; import android.view.Menu; import android.view.View; import android.view.View.OnClickListener; import android.view.ViewGroup; import android.widget.AdapterView; import android.widget.AdapterView.OnItemClickListener; import android.widget.ArrayAdapter; import android.widget.BaseAdapter; import android.widget.Button; import android.widget.EditText; import android.widget.ListView; import android.widget.SimpleAdapter; import android.widget.SimpleCursorAdapter; import android.widget.TextView; import android.widget.Toast; public class MainActivity extends Activity implements OnClickListener { private ListView mListView; private List<Person> persons; private LayoutInflater inflater; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); inflater = (LayoutInflater) this .getSystemService(LAYOUT_INFLATER_SERVICE); setContentView(R.layout.main); mListView = (ListView) this.findViewById(R.id.lv_all_person); PersonDBDao person = new PersonDBDao(this); persons = person.findAll(); // mListView.setAdapter(new MyAdapter()); List<Map<String, String>> date = new ArrayList<Map<String, String>>(); for (Person person1 : persons) { HashMap<String, String> map = new HashMap<String, String>(); map.put("name", person1.getName()); map.put("address", person1.getAddress()); date.add(map); } /* * mListView.setAdapter(new SimpleAdapter(getBaseContext(), date, * R.layout.item, new String[] { "name", "address" }, new int[] { * R.id.tv_name1, R.id.tv_name2 })); */ String[] personarray = new String[persons.size()]; for (int i = 0; i < persons.size(); i++) { personarray[i] = persons.get(i).getName(); } /* * mListView.setAdapter(new ArrayAdapter<String>(getBaseContext(), * R.layout.item,R.id.tv_name1, personarray)); */ mListView .setAdapter(new SimpleCursorAdapter(getBaseContext(), R.layout.item, person.findAllbyCursor(), new String[] { "name", "address" }, new int[] { R.id.tv_name1, R.id.tv_name2 })); mListView.setOnItemClickListener(new OnItemClickListener() { @Override public void onItemClick(AdapterView<?> parent, View view, int position, long id) { // TODO 自动生成的方法存根 String name = persons.get(position).getName(); Toast.makeText(getBaseContext(), name, Toast.LENGTH_SHORT) .show(); } }); } public class MyAdapter extends BaseAdapter { /*** * 返回当前listview有多少个条目 */ @Override public int getCount() { // TODO 自动生成的方法存根 return persons.size(); } /** * 返回当前位置对应条目的object对象 */ @Override public Object getItem(int position) { // TODO 自动生成的方法存根 return persons.get(position); } /*** * 返回当前位置条目的id */ @Override public long getItemId(int position) { // TODO 自动生成的方法存根 return position; } /*** * 返回每一个条目的具体内容 */ @Override public View getView(int position, View convertView, ViewGroup parent) { // TODO 自动生成的方法存根 /* * TextView tv = new TextView(MainActivity.this); Person person = * persons.get(position); * tv.setText(person.getName()+" | "+person.getAddress()); * //System.out.println("我被点用了"+position); return tv; */ View view = inflater.inflate(R.layout.item, null); Person person = persons.get(position); TextView tv_name = (TextView) view.findViewById(R.id.tv_name1); TextView tv_address = (TextView) view.findViewById(R.id.tv_name2); tv_name.setText("name:" + person.getName()); tv_address.setText("address:" + person.getAddress()); return view; } } @Override public void onClick(View v) { // TODO 自动生成的方法存根 } }PersonDBDao.java:
package dao; import java.util.ArrayList; import java.util.List; import com.example.db.DBCreate; import com.example.db.MyDBHelper; import damain.Person; import android.content.ContentValues; import android.content.Context; import android.database.Cursor; import android.database.sqlite.SQLiteDatabase; public class PersonDBDao { private Context context; private MyDBHelper dbOpenHelper; public PersonDBDao(Context context) { this.context = context; dbOpenHelper = new MyDBHelper(context); } /* * 添加记录 */ public void add(String name, String address) { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if (db.isOpen()) { ContentValues values = new ContentValues(); values.put("name", name); values.put("address", address); db.insert("person", null, values); db.close(); } } /** * 删除记录 * * @param name */ public void delete(String name) { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if (db.isOpen()) { db.delete("person", "name=?", new String[] { name }); db.close(); } } /** * 改记录 * * @param newname * @param newaddress * @param name */ public void update(String newname, String newaddress, String name) { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if (db.isOpen()) { ContentValues values = new ContentValues(); values.put("name", newname); values.put("address", newaddress); db.update("person", values, "name=?", new String[] { name }); db.close(); } } /**** * 查找记录 */ public boolean find(String name) { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); // select name,address from person where name = ‘chao‘ // 排序 if (db.isOpen()) { Cursor cursor = db.query("person", null, "name=?", new String[] { name }, null, null, null); if (cursor.moveToFirst()) { cursor.close(); return true; } cursor.close(); db.close(); } return false; } public List<Person> findAll() { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); List<Person> persons = null; if (db.isOpen()) { Cursor cursor = db.query("person", null, null, null, null, null, null); persons = new ArrayList<Person>(); while (cursor.moveToNext()) { Person person = new Person(); String name = cursor.getString(cursor.getColumnIndex("name")); String address = cursor.getString(cursor .getColumnIndex("address")); person.setName(name); person.setAddress(address); persons.add(person); } cursor.close(); db.close(); } return persons; } public Cursor findAllbyCursor() { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); List<Person> persons = null; if (db.isOpen()) { /* * Cursor cursor = db.query("person", null, null, null, null, null, * null); */ Cursor cursor = db.rawQuery( "select id as _id,name,address from person", null); return cursor; } return null; } /*** * 银行转账模拟 */ public void transaction() { SQLiteDatabase db = dbOpenHelper.getWritableDatabase(); if (db.isOpen()) { try { db.beginTransaction(); // chaoyongbing0 1000快 db.execSQL("update person set money=? where name = ?", new Object[] { 1000, "chaoyongbing0" }); // chaoyongbing0 - 200 db.execSQL("update person set money=money-? where name = ?", new Object[] { 200, "chaoyongbing0" }); // chaoyongbing1 0快 db.execSQL("update person set money=? where name = ?", new Object[] { 0, "chaoyongbing1" }); // chaoyongbing1 +200 db.execSQL("update person set money=money+? where name = ?", new Object[] { 200, "chaoyongbing1" }); // 必须要有下面的语句,否则会默认回滚 db.setTransactionSuccessful(); } finally { db.endTransaction(); db.close(); } } } }Person.java:
package damain; public class Person { String name; String address; public String getName() { return name; } public void setName(String name) { this.name = name; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } }
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。