SQLit数据库 增 删 改 查

2017-02-14  本文已影响138人  CallMe001

SQLite数据库

范例:
public class MySQLiteOpenHelper extends SQLiteOpenHelper {
    // 数据库文件名
    private final static String DB_NAME = "my_database.db";
    // 数据库版本号
    private final static int DB_VERSION = 1;
    // 数据库表名
    public final static String TABLE_NAME = "table_person";

    /**
     * 创建数据库文件
     *
     * @param context 上下文
     * @param name    数据库文件名
     * @param factory 游标工厂, 如果为null,Android系统提供默认的游标
     * @param version 数据库版本号
     */
    public MySQLiteOpenHelper(Context context, String name, SQLiteDatabase.CursorFactory factory, int version) {
        super(context, name, factory, version);
    }

    //创建数据库文件:
    public MySQLiteOpenHelper(Context context) {
        //创建了名为"my_database.db"数据库,版本号 1  数据库地址: data/data/com.w.Demo/databases/my_database.db
        super(context, DB_NAME, null, DB_VERSION);
    }

    /**
     * 创建了数据库
     * @param db 系统返回的数据库对象
     */
    @Override
    public void onCreate(SQLiteDatabase db) {
        // 创建表语句,语义:如果不存在则创建表,字段包括:主键_id,name,age
        /*注意: SQ语句: exists后面空格,()不要忘记*/
        String sql = "create table if not exists " + TABLE_NAME + "(_id integer primary key autoincrement, name varchar, age integer)";
        // 执行创建表的数据库语句
        db.execSQL(sql);
    }

    /**
     * @param db  系统返回的数据库对象
     * @param oldVersion 旧版本
     * @param newVersion 新版本
     */
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        if (oldVersion != newVersion) {
            Log.d("TAG", "onUpgrade: onUpgrade");
        }
    }
}
MySQLiteOpenHelper mHelper =  new MySQLiteOpenHelper(this);
SQLiteDatabase dbSelect = mHelper.getReadableDatabase();
public SQLiteDatabase getDb() {
 //创建数据库 my_database.db
        String filePath = Environment.getExternalStorageDirectory() + "/my_database.db";
        SQLiteDatabase database = SQLiteDatabase.openOrCreateDatabase(filePath, null);
 //在数据库中创建一张表 table_person
        String sql = "create table if not exists table_person(_id integer primary key autoincrement, name varchar, age integer)";
 // 执行创建表的数据库语句
        database.execSQL(sql);
        return database;
}
SQLiteDatabase dbAdd = getDb();
ContentValues values = new ContentValues();
                values.put("name", "林志玲");
                values.put("age", 18);
                // table:要插入数据的表名
                //nullColumnHack:当插入数据为null时,nullColumnHack不允许为空,通过系统的处理保证了程序的稳定性;当插入数据不为null时,nullColumnHack排不上用场,为null
                // values:插入的数据
                dbAdd.insert("table_person", null, values);
//得到数据库
  SQLiteDatabase dbAdd = getDb();
                // 开始事务
                dbAdd.beginTransaction();
                try {
                    for (int i = 0; i < 10; i++) {
                        // 插入数据
                        String sql = "insert into table_person(name, age) values('林志玲', " + i + ")";
                        dbAdd.execSQL(sql);
                    }
                   //事务成功
                    dbAdd.setTransactionSuccessful();
                } catch (Exception e) {

                } finally {
                    //结束事务
                    dbAdd.endTransaction();
                }
                //关闭数据库,节约内存资源
                dbAdd.close();
 SQLiteDatabase dbDelete = getDb();
                // 删除数据库指定表中的数据
                // table:表名
                // whereClause:删除条件,格式“name = ?”
                // whereArgs:满足删除的条件,即删除的数据,格式“"张三"”
                dbDelete.delete("table_person", "name = ?", new String[]{"林志玲"});
                dbDelete.close();
ContentValues contentValues = new ContentValues();
                contentValues.put("name", "张三");
                contentValues.put("age", 25);
                SQLiteDatabase dbModify = getDb();
                // table:表名
                // values:更新的数据
                // whereClause:更新条件
                // whereArgs:满足更新的条件
                dbModify.update("table_person", contentValues, "name = ?", new String[]{"林志玲"});
                dbModify.close();
               //得到数据库;
                SQLiteDatabase dbSelect = getDb();
              // 查询数据库
                // table:表名
                // columns:被查询的列(字段),可以有很多个
                // selection:查询条件
                // selectionArgs:满足查询的条件
                // groupBy:指定分组(多数情况不使用)
                // having:分组筛选数据关键字(多数情况不使用)
                // orderBy:排序
                Cursor cursor = dbSelect.query("table_person", new String[]{"name", "age"}, null, null, null, null, null);
                int nameIndex = cursor.getColumnIndex("name");
                int ageIndex = cursor.getColumnIndex("age");
                //遍历数据库查询数据  
                while (cursor.moveToNext()) {
                    String name = cursor.getString(nameIndex);
                    int age = cursor.getInt(ageIndex);
                   showText = showText + "姓名: " + name + "\t年龄: " + age + "\n";
                }
                 Log.d("TAG", "数据: " + showText );
                dbSelect.close();
                cursor.close();

-注意事项:

上一篇下一篇

猜你喜欢

热点阅读