安卓中對SQLite資料庫的增刪改查
阿新 • • 發佈：2019-01-23
第一步:編寫一個java Bean
package com.itfom.entity;
public class Person {
private String name;
private int age;
private String phone;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
public String getPhone() {
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
}
//建立建構函式
public Person(){
}
public Person(String name,int age,String phone){
this.name=name;
this.age=age;
this.phone=phone;
}
//重寫toString
@Override
public String toString() {
return "姓名:"+name+"年齡:"+age+"電話:"+phone+"\n";
}
}
package com.itfom.helper;
import android.content.Context;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
public class OpenHelper extends SQLiteOpenHelper {
public OpenHelper(Context context) {
//這三個引數分別為上下文物件,資料庫名稱,遊標,版本號
super(context, "xsc.db", null, 1);
}
@Override
public void onCreate(SQLiteDatabase db) {
db.execSQL("create table person(name varchar(50),age integer,phone varchar(50))");
}
@Override
public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
// 注：生產環境上不能做刪除操作
db.execSQL("DROP TABLE IF EXISTS person");
onCreate(db);
}
}
第三步:建立資料庫的操作類
package com.itfom.entitydao;
import java.util.ArrayList;
import java.util.List;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import com.itfom.entity.Person;
import com.itfom.helper.OpenHelper;
public class PersonDao {
private OpenHelper helper = null;
/**
* 建構函式
* 呼叫getWritableDatabase()或getReadableDatabase()方法後，會快取SQLiteDatabase例項；
* 因為這裡是手機應用程式，一般只有一個使用者訪問資料庫，所以建議不關閉資料庫，保持連線狀態。
* getWritableDatabase()，getReadableDatabase的區別是當資料庫寫滿時，呼叫前者會報錯，呼叫後者不會，
* 所以如果不是更新資料庫的話，最好呼叫後者來獲得資料庫連線。
* 對於熟悉SQL語句的程式設計師最好使用exeSQL(),rawQuery(),因為比較直觀明瞭
* @param context
*/
public PersonDao(Context context){
helper = new OpenHelper(context);
}
//實現對該資料庫的增加
public void addPerson(Person person){
//獲取操作例項
SQLiteDatabase db = helper.getWritableDatabase();
//此方法推薦使用
String sqlStr="insert into person(name,age,phone)values(?,?,?)";
//執行SQL語句
db.execSQL(sqlStr,new Object[]{person.getName(),person.getAge(),person.getPhone()});
//關閉資料庫
db.close();
}
//實現對資料庫的刪除
public void deletePerson(String name){
//獲取資料庫操作的例項
SQLiteDatabase db=helper.getWritableDatabase();
//建立SQL字串
String sqlStr="delete from person where name=?";
db.execSQL(sqlStr,new String[]{name});
//關閉資料庫
db.close();
}
//實現對資料庫的修改
public void updatePerson(Person person){
//獲取資料庫的操作例項
SQLiteDatabase db=helper.getWritableDatabase();
//建立SQl字串
String sqlStr="update person set name=?,phone=?where age=?";
//執行SQL語句
db.execSQL(sqlStr, new Object[]{person.getName(),person.getPhone(),person.getAge()});
//關閉資料庫
db.close();
}
//實現對資料庫的查詢
public List<Person> selectPerson(){
//建立集合
List<Person> persons=new ArrayList<Person>();
//獲取資料庫操作例項
SQLiteDatabase db=helper.getReadableDatabase();
//建立Cursor物件
Cursor cursor=null;
try {
cursor = db.rawQuery("select * from person",null);
while(cursor.moveToNext()){
String name=cursor.getString(cursor.getColumnIndex("name"));
int age=cursor.getInt(cursor.getColumnIndex("age"));
String phone=cursor.getString(cursor.getColumnIndex("phone"));
//建立Person物件
Person p=new Person(name,age,phone);
//將創建出來的Person物件新增到集合中去
persons.add(p);
}
} catch (Exception e) {
e.printStackTrace();
}finally{
//關閉相應的資源
if(cursor!=null){
cursor.close();
}
if(db!=null){
db.close();
}
}
return persons;
}
}
第四步:開始測試
package com.itfom.sqlite;
import java.util.List;
import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.Toast;
import com.itfom.entity.Person;
import com.itfom.entitydao.PersonDao;
public class MainActivity extends Activity implements OnClickListener{
//尋找控制元件
Button btn_add,btn_delete,btn_update,btn_select;
//建立資料庫操作類的例項
PersonDao pd=null;
List<Person> persons=null;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
init();
}
//自定義一個方法初始化資料
public void init(){
//初始化控制元件
btn_add=(Button) findViewById(R.id.btn_add);
btn_delete=(Button) findViewById(R.id.btn_delete);
btn_update=(Button) findViewById(R.id.btn_update);
btn_select=(Button) findViewById(R.id.btn_select);
pd=new PersonDao(this);
//為每個控制元件設定監聽事件
btn_add.setOnClickListener(this);
btn_delete.setOnClickListener(this);
btn_update.setOnClickListener(this);
btn_select.setOnClickListener(this);
}
@Override
public void onClick(View v) {
switch (v.getId()) {
case R.id.btn_add:
//新增資料
//建立Person物件
for (int i = 0; i <100; i++) {
Person p=new Person("夏守成"+i,i,"1809527282");
pd.addPerson(p);
}
Toast.makeText(this, "新增資料成功", Toast.LENGTH_SHORT).show();
break;
case R.id.btn_delete:
//刪除資料
pd.deletePerson("夏守成0");
Toast.makeText(this, "刪除資料成功", Toast.LENGTH_SHORT).show();
break;
case R.id.btn_update:
//更新資料
//建立Person物件
Person p=new Person("劉丹", 21, "110");
pd.updatePerson(p);
Toast.makeText(this, "資料更新成功", Toast.LENGTH_SHORT).show();
break;
case R.id.btn_select:
//查詢資料
persons=pd.selectPerson();
//打印出這些資料
for (Person person : persons) {
System.out.println(person.toString());
}
Toast.makeText(this, "資料查詢成功", Toast.LENGTH_SHORT).show();
break;
default:
break;
}
}
}