Android   发布时间:2022-04-28  发布网站:大佬教程  code.js-code.com
大佬教程收集整理的这篇文章主要介绍了Android编程操作嵌入式关系型SQLite数据库实例详解大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。

本文实例分析了Android编程操作嵌入式关系型sqlite数据库方法分享给大家供大家参,具体如下:

sqlite特点

1.Android平台中嵌入了一个关系型数据库sqlite,和其他数据库不同的是sqlite存储数据时不区@L_801_10@型

例如一个字段声明为Integer类型,我们也可以将一个字符串存入,一个字段声明为布尔型,我们也可以存入浮点数。

除非是主键被定义为Integer,这时只能存储64位整数

2.创建数据库的表时可以不指定数据类型,例如:


3.sqlite@L_696_18@大部分标准sql语句,增删改查语句都是通用的,分页查询语句和MysqL相同

SELECT * FROMperson LIMIT 20 OFFSET 10
SELECT * FROMperson LIMIT 20,10

创建数据库

1.定义类继承sqliteOpenHelper
2.声明构造函数,4个参数
3.重写onCreate()方法
4. 重写upGrade()方法

例:

@H_801_38@ package cn.itcast.sqlite; import android.content.Context; import android.database.sqlite.sqliteDatabase; import android.database.sqlite.sqliteOpenHelper; import android.database.sqlite.sqliteDatabase.cursorFactory; public class DBOpenHelper extends sqliteOpenHelper { /** * 创建OpenHelper * @param context 上下文 * @param name 数据库名 * @param factory 游标工厂 * @param version 数据库版本,不要设置为0,如果为0则会每次都创建数据库 */ public DBOpenHelper(Context context,String name,cursorFactory factory,int version) { super(context,name,factory,version); } /** * 当数据库第一次创建的时候被调用 */ public void onCreate(sqliteDatabase db) { db.execsql("create table person(id INTEGER PRIMARY KEY AUTOINCREMENT,Name)"); } /** * 当数据库版本发生改变的时候被调用 */ public void onUpgrade(sqliteDatabase db,int oldVersion,int newVersion) { db.execsql("alter table person ADD balance"); } } public void testcreatedb() { DBOpenHelper Helper = new DBOpenHelper(getContext(),"itcast.db",null,2); Helper.getWritableDatabase(); // 创建数据库 }

CRUD操作

1.和JDBC访问数据库不同,操作sqlite数据库无需加载驱动,不用获取连接,直接可以使用

获取sqliteDatabase对象之后通过该对象直接可以执行sql语句:

@H_801_38@ sqliteDatabase.execsql() sqliteDatabase.rawQuery()

2.getReadableDatabase()和getWritableDatabase()的区别

查看源代码后我们发现getReadableDatabase()在通常情况下返回的就是getWritableDatabase()拿到的数据库只有在抛出异常的时候才会以只读方式打开

3.数据库对象缓存

getWritableDatabase()方法最后会使用一个成员变量记住这个数据库对象,下次打开时判断是否重用

4.sqliteDatabase封装了insert()delete()update()、query()四个方法也可以对数据库进行操作

这些方法封装了部分sql语句,通过参数进行拼接

执行crud操作有两种方式,第一种方式自己写sql语句执行操作,第二种方式是使用sqliteDatabase类调用响应的方法执行操作

execsql()方法可以执行INSERTdelete、update和CREATETABLE之类有更改行为的sql语句; rawQuery()方法用于执行SELEct语句。

第一种方式示例:

@H_801_38@ package cn.itcast.sqlite.service; import java.util.ArrayList; import java.util.List; import android.content.Context; import android.database.cursor; import android.database.sqlite.sqliteDatabase; import cn.itcast.sqlite.DBOpenHelper; import cn.itcast.sqlite.domain.Person; public class sqlPersonservice { private DBOpenHelper Helper; public sqlPersonservice(Context context) { Helper = new DBOpenHelper(context,2);//初始化数据库 } /** * 插入一个Person * @param p 要插入的Person */ public void insert(Person p) { sqliteDatabase db = Helper.getWritableDatabase(); //获取数据库 db.execsql("INSERT INTO person(name,phone,balancE) VALUES(?,?)",new Object[] { p.getName(),p.getPhone() }); db.close(); } /** * 根据ID删除 * @param id 要删除的PERSON的ID */ public void delete(Integer id) { sqliteDatabase db = Helper.getWritableDatabase(); db.execsql("deletE FROM person WHERE id=?",new Object[] { id }); db.close(); } /** * 更新Person * @param p 要更新的Person */ public void update(Person p) { sqliteDatabase db = Helper.getWritableDatabase(); db.execsql("updatE person SET name=?,phone=?,balance=? WHERE id=?",p.getPhone(),p.getBalance(),p.getId() }); db.close(); } /** * 根据ID查找 * @param id 要查的ID * @return 对应的对象,如果未找到返回null */ public Person find(Integer id) { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.rawQuery("SELECT name,balance FROM person WHERE id=?",new String[] { id.toString() }); Person p = null; if (cursor.moveToNext()) { String name = cursor.getString(cursor.getcolumnIndex("name")); String phone = cursor.getString(1); Integer balance = cursor.geTint(2); p = new Person(id,balancE); } cursor.close(); db.close(); return p; } /** * 查询所有Person对象 * @return Person对象集合,如未找到,返回一个size()为0的List */ public List<Person> findAll() { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.rawQuery("SELECT id,balance FROM person",null); List<Person> persons = new ArrayList<Person>(); while (cursor.moveToNext()) { Integer id = cursor.geTint(0); String name = cursor.getString(1); String phone = cursor.getString(2); Integer balance = cursor.geTint(3); persons.add(new Person(id,balancE)); } cursor.close(); db.close(); return persons; } /** * 查询某一页数据 * @param page 页码 * @param size 每页记录数 * @return */ public List<Person> findPage(int page,int sizE) { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.rawQuery("SELECT id,balance FROM person LIMIT ?,?" //,new String[] { String.valueOf((page - 1) * sizE),String.valueOf(sizE) }); List<Person> persons = new ArrayList<Person>(); while (cursor.moveToNext()) { Integer id = cursor.geTint(0); String name = cursor.getString(1); String phone = cursor.getString(2); Integer balance = cursor.geTint(3); persons.add(new Person(id,balancE)); } cursor.close(); db.close(); return persons; } /** * 获取记录数 * @return 记录数 */ public int getCount() { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.rawQuery("SELECT COUNT(*) FROM person",null); cursor.moveToNext(); return cursor.geTint(0); } }

第二种方式示例:

@H_801_38@ /** * 插入一个Person * @param p 要插入的Person */ public void insert(Person p) { sqliteDatabase db = Helper.getWritableDatabase(); ContentValues values = new ContentValues(); values.put("name",p.getName()); values.put("phone",p.getPhone()); values.put("balance",p.getBalance()); // 第一个参数是表名,第二个参数是如果要插入一条空记录时指定的某一列的名字,第三个参数是数据 db.insert("person",values); db.close(); } /** * 根据ID删除 * @param id 要删除的PERSON的ID */ public void delete(Integer id) { sqliteDatabase db = Helper.getWritableDatabase(); db.delete("person","id=?",new String[] { id.toString() }); db.close(); } /** * 更新Person * @param p 要更新的Person */ public void update(Person p) { sqliteDatabase db = Helper.getWritableDatabase(); ContentValues values = new ContentValues(); values.put("id",p.getId()); values.put("name",p.getBalance()); db.update("person",values,new String[] { p.getId().toString() }); db.close(); } /** * 根据ID查找 * @param id 要查的ID * @return 对应的对象,如果未找到返回null */ public Person find(Integer id) { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.query("person",new String[] { "name","phone","balance" },new String[] { id.toString() },null); Person p = null; if (cursor.moveToNext()) { String name = cursor.getString(cursor.getcolumnIndex("name")); String phone = cursor.getString(1); Integer balance = cursor.geTint(2); p = new Person(id,balancE); } cursor.close(); db.close(); return p; } /** * 查询所有Person对象 * @return Person对象集合,返回一个size()为0的List */ public List<Person> findAll() { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.query("person",new String[] { "id","name","id desc"); List<Person> persons = new ArrayList<Person>(); while (cursor.moveToNext()) { Integer id = cursor.geTint(0); String name = cursor.getString(1); String phone = cursor.getString(2); Integer balance = cursor.geTint(3); persons.add(new Person(id,balancE)); } cursor.close(); db.close(); return persons; } /** * 查询某一页数据 * @param page 页码 * @param size 每页记录数 * @return */ public List<Person> findPage(int page,int sizE) { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.query( // "person",(page - 1) * size + "," + sizE); List<Person> persons = new ArrayList<Person>(); while (cursor.moveToNext()) { Integer id = cursor.geTint(0); String name = cursor.getString(1); String phone = cursor.getString(2); Integer balance = cursor.geTint(3); persons.add(new Person(id,balancE)); } cursor.close(); db.close(); return persons; } /** * 获取记录数 * @return 记录数 */ public int getCount() { sqliteDatabase db = Helper.getReadableDatabase(); cursor cursor = db.query( // "person",new String[] { "COUNT(*)" },null); cursor.moveToNext(); return cursor.geTint(0); }

事务管理

1.使用在sqlite数据库时可以使用sqliteDatabase类中定义的相关方法控制事务

begintransaction() 开启事务
settransactionsuccessful() 设置事务成功标记
endtransaction() 结束事务

2.endtransaction()需要放在finally中执行,否则事务只有到超时的时候才自动结束,会降低数据库并发效率

例:

@H_801_38@ public void remit(int from,int to,int amount) { sqliteDatabase db = Helper.getWritableDatabase(); // 开启事务 try { db.begintransaction(); db.execsql("updatE person SET balance=balance-? WHERE id=?",new Object[] { amount,from }); System.out.println(1 / 0); db.execsql("updatE person SET balance=balance+? WHERE id=?",to }); // 设置事务标记 db.settransactionsuccessful(); } finally { // 结束事务 db.endtransaction(); } db.close(); }

希望本文所述对大家Android程序设计有所帮助。

大佬总结

以上是大佬教程为你收集整理的Android编程操作嵌入式关系型SQLite数据库实例详解全部内容,希望文章能够帮你解决Android编程操作嵌入式关系型SQLite数据库实例详解所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。
标签: