安卓开发写入数据库

安卓中使用SQLite直接写入数据库

创建数据库帮助类

public class DBHelper extends SQLiteOpenHelper {
    private static final String DATABASE_NAME = "app.db";
    private static final int VERSION = 1;
    public DBHelper(Context context) {
        super(context, DATABASE_NAME, null, VERSION);
    }
    @Override
    public void onCreate(SQLiteDatabase db) {
        // 创建用户表
        String sql = "CREATE TABLE user(id INTEGER PRIMARY KEY AUTOINCREMENT,name TEXT,age INTEGER)";
        db.execSQL(sql);
    }
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        // 数据库升级处理
        db.execSQL("DROP TABLE IF EXISTS user");
        onCreate(db);
    }
}

执行写入操作

// 获取可写数据库
SQLiteDatabase db = new DBHelper(context).getWritableDatabase();
// 方式1：使用execSQL插入原始数据
String sql = "INSERT INTO user(name,age) VALUES('张三',25)";
db.execSQL(sql);
// 方式2：使用ContentValues插入数据
ContentValues values = new ContentValues();
values.put("name","李四");
values.put("age",30);
db.insert("user",null,values);
// 事务处理（推荐）
db.beginTransaction();
try {
    db.insert("user",null,values);
    db.setTransactionSuccessful();
} finally {
    db.endTransaction();
}

使用Room持久化库写入数据库

定义实体类

@Entity(tableName = "user")
public class User {
    @PrimaryKey(autoGenerate = true)
    public int id;
    @ColumnInfo(name = "name")
    public String name;
    @ColumnInfo(name = "age")
    public int age;
}

创建DAO接口

@Dao
public interface UserDao {
    @Insert
    void insertUser(User... users); // 支持批量插入
    @Insert(onConflict = OnConflictStrategy.REPLACE) // 主键冲突时替换
    void insertOrReplace(User user);
    @Query("SELECT  FROM user WHERE name LIKE :name")
    List<User> findByName(String name);
}

配置数据库

@Database(entities = {User.class},version = 1)
public abstract class AppDatabase extends RoomDatabase {
    public abstract UserDao userDao();
}

执行写入操作

AppDatabase db = Room.databaseBuilder(context,AppDatabase.class,"app.db").build();
User user = new User();
user.name = "王五";
user.age = 28;
// 单条插入
db.userDao().insertUser(user);
// 批量插入
List<User> users = new ArrayList<>();
users.add(new User(){{name="赵六";age=22;}});
users.add(new User(){{name="孙七";age=35;}});
db.userDao().insertUser(users.toArray(new User[0]));

关键差异对比表

注意事项清单

1. 线程管理：数据库操作需在子线程执行，主线程操作会抛出NetworkOnMainThreadException
2. 事务处理：批量操作必须使用事务包裹，保证原子性
3. 版本控制：数据库升级时需实现onUpgrade方法，处理数据迁移
4. 冲突策略：插入重复数据时需指定OnConflictStrategy（IGNORE/REPLACE等）
5. 资源释放：操作完成后需调用db.close()释放数据库连接

问题与解答

Q1：如何实现数据库版本升级时的数据迁移？

• A1：在Room中通过migration方法实现：

  Room.databaseBuilder(context,AppDatabase.class,"app.db")
    .addMigrations(new Migration(1,2) {
        @Override
        public void migrate(SupportSQLiteDatabase database) {
            database.execSQL("ALTER TABLE user ADD COLUMN address TEXT")；
        }
    }).build();

  传统SQLite需在onUpgrade方法中执行ALTER语句。

Q2：如何处理外键约束关系？

• A2：在Room实体类中使用@ForeignKey注解：

  @Entity(foreignKeys = @ForeignKey(entity = User.class,parentColumns = "id",childColumns = "user_id"))
  public class Order {
    @PrimaryKey(autoGenerate = true)
    public int id;
    public int user_id; // 关联用户表的外键
    public String product;
  }

  需在RoomDatabase中开启外键支持：.fallbackToDestructiveMigration().build()