数据库操作

package com.itheima.sqlite.dao;

import java.util.ArrayList;
import java.util.List;

import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;

import com.itheima.sqlite.bean.Account;

public class AccountDao {
    private MyHelper helper;
    
    public AccountDao(Context context) {
        helper = new MyHelper(context);
    }

    public void insert(Account a) {
        SQLiteDatabase db = helper.getWritableDatabase();    // 获取SQLiteDatabase对象
        db.execSQL("INSERT INTO account(name, balance) VALUES(?, ?)", new Object[] { a.getName(), a.getBalance() });    // 执行一条SQL语句
        db.close();        // 关闭
    }

    public void delete(int id) {
        SQLiteDatabase db = helper.getWritableDatabase();    // 获取SQLiteDatabase对象
        db.execSQL("DELETE FROM account WHERE _id=?", new Object[] { id }); // 执行
        db.close();        // 关闭
    }

    public void update(Account a) {
        SQLiteDatabase db = helper.getWritableDatabase();    // 获取
        db.execSQL("UPDATE account SET name=?, balance=? WHERE _id=?", new Object[] { a.getName(), a.getBalance(), a.getId() }); // 执行
        db.close();        // 关闭
    }

    public Account query(int id) {
        SQLiteDatabase db = helper.getReadableDatabase();    // 先调用getWriteableDatabse(), 如果出了异常, 就开一个只读的
        Cursor c = db.rawQuery("SELECT name, balance FROM account WHERE _id=?", new String[] { id + "" });        // 执行查询语句, 得到结果集
        Account a = null;
        if (c.moveToNext()) {    // 判断结果集是否包含下一条数据, 如果包含, 指针自动向后移动
            String name = c.getString(0);                            // 从结果集中获取数据(根据列的索引获取)
            int balance = c.getInt(c.getColumnIndex("balance"));    // 从结果集中获取数据(先根据列名获取索引, 再根据索引获取数据)
            a = new Account(id, name, balance);    // 创建对象, 把数据设置到对象中
        }
        c.close();
        db.close();
        return a;    // 返回对象
    }
    
    public List<Account> queryAll() {
        SQLiteDatabase db = helper.getReadableDatabase();
        Cursor c = db.rawQuery("SELECT * FROM account", null);    // 查询表中所有数据
        List<Account> list = new ArrayList<Account>();
        while (c.moveToNext()) {
            int id = c.getInt(0);            // 获取表中的第一列(索引从0开始)
            String name = c.getString(1);    
            int balance = c.getInt(2);        
            list.add(new Account(id, name, balance));    // 把表中的数据封装成对象
        }
        c.close();
        db.close();
        return list;
    }
    
    public Cursor queryCursor() {
        SQLiteDatabase db = helper.getReadableDatabase();
        return db.rawQuery("SELECT * FROM account ORDER BY balance DESC", null);
    }
    
    public List<Account> queryPage(int pageSize, int pageNum) {
        String index = (pageNum - 1) * pageSize + "";        // 翻页时的起始索引
        String count = pageSize + "";                        // 查询多少条数据
        List<Account> list = new ArrayList<Account>();
        SQLiteDatabase db = helper.getReadableDatabase();
        Cursor c = db.rawQuery("SELECT * FROM account LIMIT ?,?", new String[] { index, count });    
        while (c.moveToNext()) {
            int id = c.getInt(0);            
            String name = c.getString(1);    
            int balance = c.getInt(2);        
            list.add(new Account(id, name, balance));    
        }
        c.close();
        db.close();
        return list;
    }
    
    public int queryCount() {
        SQLiteDatabase db = helper.getReadableDatabase();
        Cursor c = db.rawQuery("SELECT COUNT(*) FROM account", null);
        c.moveToNext();
        int count = c.getInt(0);
        c.close();
        db.close();
        return count;
    }
    
    public void remit(int fromId, int toId, int amount) {
        SQLiteDatabase db = helper.getWritableDatabase();
        try {
            db.beginTransaction();            // 开启事务
            db.execSQL("UPDATE account SET balance=balance-? WHERE _id=?", new Object[] { amount, fromId });
            db.execSQL("UPDATE account SET balance=balance+? WHERE _id=?", new Object[] { amount, toId });
            db.setTransactionSuccessful();    // 设置事务成功标记
        } finally {
            db.endTransaction();            // 结束事务
            db.close();
        }
    }

}

Myhelper.java

package com.itheima.sqlite.dao;

import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;

public class MyHelper extends SQLiteOpenHelper {    // 自定义类继承SQLiteOpenHelper

    public MyHelper(Context context) {                // 由于父类没有无参构造函数, 定义一个构造函数调用父类有参的构造函数
        /*
         * 参数1: Context代表应用程序的环境, 用来确定数据库文件的位置
         * 参数2: 数据文件的名字
         * 参数3: 用来创建Cursor(结果集)的工厂, 默认传null就可以
         * 参数4: 数据库的版本, 后期用来更新数据库, 从1开始
         */
        super(context, "itheima.db", null, 2);
    }

    @Override
    public void onCreate(SQLiteDatabase db) {    // 在数据库文件创建之后执行
        System.out.println("onCreate");
        db.execSQL("CREATE TABLE account(_id INTEGER PRIMARY KEY AUTOINCREMENT, name VARCHAR(20))");    // 执行SQL语句, 创建表
    }

    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {    // 在数据库版本提升之后执行
        System.out.println("onUpgrade");
        db.execSQL("ALTER TABLE account ADD balance INTEGER");
    }
    
}

一.SQLite数据库
1.SQLite数据库的特点
安卓手机自带, 小巧, 适合在手机中使用
不区分数据类型(主键除外)
SQL语句和MySQL几乎相同
SQLite不使用JDBC连接, 使用的是Android自有的API
每个数据库对应一个文件
* 2.创建数据库
定义类继承SQLiteOpenHelper, 实现onCreate(), onUpgrade()
创建该类对象, 调用getWritableDatabse()或者getReadableDatabse()
情况1: 数据库文件不存在, 创建文件, 打开数据库连接(得到SQLiteDatabase对象), 执行onCreate()方法
情况2: 数据库文件存在, 版本号没变, 打开数据库连接
情况3: 数据库文件存在, 版本号提升, 升级数据库, 打开数据库连接,执行onUpgrade()方法
情况4: 数据库文件存在, 版本号降低, 执行onDowngrade()方法, 方法中默认会抛出一个异常
* 3.创建表或修改表
SQLiteDatabase类的execSQL()方法可以执行一条SQL语句
如果希望创建数据库的时候就创建一些表, 那么这个操作就可以在onCreate()方法中执行
如果希望在数据库升级的时候做类似修改表添加表的操作, 可以在onUpgrade()方法中执行
*** 4.增删改查
execSQL()方法可以进行增删改操作
rawQuery()执行查询操作, 得到Cursor, 调用moveToNext()判断是否包含数据, 调用getString(), getInt()等方法获取数据
insert(), delete(), update(), query() 四个方法内部也是调用execSQL()和rawQuery()的, 它们在ContentProvider中使用更方便(明天讲)
* 5.事务管理
beginTransaction() 开启事务
setTransactionSuccessful() 设置事务成功标记
endTransaction() 结束事务.
事务结束的时候, 会把最后一个成功标记之前的操作提交, 成功标记之后的操作回滚