当前位置：首页 > 行业动态 > 正文

安卓如何访问数据库

admin
行业动态
2025-04-22
3

安卓访问数据库的实现方式

本地数据库访问

SQLite数据库

SQLite是安卓内置的轻量级关系型数据库,适合存储本地数据。

核心步骤：

创建数据库帮助类：继承SQLiteOpenHelper，实现onCreate()（建表）和onUpgrade()（更新表）。
增删改查操作：通过SQLiteDatabase对象执行SQL语句。

示例代码：

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) {
        db.execSQL("CREATE TABLE user (id INTEGER PRIMARY KEY, name TEXT)");
    }
    @Override
    public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
        db.execSQL("DROP TABLE IF EXISTS user");
        onCreate(db);
    }
}

操作方法：

插入数据：db.insert()或execSQL("INSERT INTO...")
查询数据：db.query()或rawQuery()
更新/删除：db.update()或db.delete()

Room持久化库

Room是谷歌推荐的ORM框架，基于SQLite,提供编译时校验和抽象层。

核心组件：

Entity：标注数据库表结构。
DAO：定义数据操作接口（增删改查）。
Database：继承RoomDatabase,封装多个DAO。

示例代码：

// Entity定义
@Entity(tableName = "user")
public class User {
    @PrimaryKey(autoGenerate = true)
    public int id;
    public String name;
}
// DAO接口
@Dao
public interface UserDao {
    @Insert
    void insert(User user);
    @Query("SELECT  FROM user WHERE id = :userId")
    User getUserById(int userId);
}
// Database类
@Database(entities = {User.class}, version = 1)
public abstract class AppDatabase extends RoomDatabase {
    public abstract UserDao userDao();
}

远程数据库访问

使用Retrofit+OKHttp

适用于访问服务器上的MySQL、PostgreSQL等数据库，通常通过REST API交互。

实现步骤：

添加依赖：

implementation 'com.squareup.retrofit2:retrofit:2.9.0'
implementation 'com.squareup.retrofit2:converter-gson:2.9.0'

定义API接口：

public interface ApiService {
    @GET("users/{id}")
    Call<User> getUser(@Path("id") int id);
}

创建Retrofit实例：

Retrofit retrofit = new Retrofit.Builder()
    .baseUrl("https://api.example.com/")
    .addConverterFactory(GsonConverterFactory.create())
    .build();
ApiService apiService = retrofit.create(ApiService.class);

发送请求并处理响应：

apiService.getUser(1).enqueue(new Callback<User>() {
    @Override
    public void onResponse(Call<User> call, Response<User> response) {
        if (response.isSuccessful()) {
            User user = response.body();
        }
    }
    @Override
    public void onFailure(Call<User> call, Throwable t) {
        // 处理错误
    }
});

数据解析与异步处理

JSON解析：通过GsonConverterFactory自动转换。
异步处理：使用enqueue()方法避免阻塞主线程。
错误处理：捕获onFailure()中的异常，或自定义OkHttp拦截器。

其他访问方式

ContentProvider访问系统数据库

用于跨应用共享数据（如读取通讯录、短信）。

示例：读取联系人

ContentResolver resolver = getContentResolver();
Uri uri = ContactsContract.Contacts.CONTENT_URI;
Cursor cursor = resolver.query(uri, null, null, null, null);
while (cursor.moveToNext()) {
    String name = cursor.getString(cursor.getColumnIndex(ContactsContract.Contacts.DISPLAY_NAME));
}
cursor.close();

注意事项

线程管理：
- 本地数据库操作需在子线程执行（如AsyncTask、Coroutines）。
- Room支持LiveData和RxJava,自动异步处理。
数据库版本控制：
- 在SQLiteOpenHelper或RoomDatabase的onUpgrade()中处理迁移逻辑。
- Room可通过migrationStrategy简化版本升级。