Android學習筆記—-SQLiteDatabase 自帶添加、刪除、更新、查詢的操作方法:實現添加,刪除,更新,查詢,和分頁,統計

7.除瞭前面給大傢介紹的execSQL()和rawQuery()方法, SQLiteDatabase還專門提供瞭對應

 

 

於添加、刪除、更新、查詢的操作方法: insert()、delete()、update()和query() 。這些

 

 

方法實際上是給那些不太瞭解SQL語法的菜鳥使用的,對於熟悉SQL語法的程序員而言,直接

 

 

使用execSQL()和rawQuery()方法執行SQL語句就能完成數據的添加、刪除、更新、查詢操作

 

 

————————————————————–

8.Insert()方法用於添加數據,各個字段的數據使用ContentValues進行存放。   

 

 

ContentValues  類似於MAP,相對於MAP,它提供瞭存取數據對應的put(String key, Xxx 

 

 

value)和  getAsXxx(String key)方法,  key為字段名稱,value為字段值,Xxx指的是各種

 

 

常用的數據類型,如:String、Integer等。

SQLiteDatabase db = databaseHelper.getWritableDatabase();

ContentValues values = new ContentValues();

values.put("name", "credream");

values.put("age", 4);

long rowid = db.insert(“person”, null, values);//返回新添記錄的行號,與主鍵id無

 

 

不管第三個參數是否包含數據,執行Insert()方法必然會添加一條記錄,如果第三個參數為

 

 

空,會添加一條除主鍵之外其他字段值為Null的記錄。Insert()方法內部實際上通過構造

 

 

insert SQL語句完成數據的添加,Insert()方法的第二個參數用於指定空值字段的名稱,相

 

 

信大傢對該參數會感到疑惑,該參數的作用是什麼?是這樣的:如果第三個參數values 為

 

 

Null或者元素個數為0, 由於Insert()方法要求必須添加一條除瞭主鍵之外其它字段為Null

 

 

值的記錄,為瞭滿足SQL語法的需要, insert語句必須給定一個字段名,如:insert into 

 

 

person(name) values(NULL),倘若不給定字段名 , insert語句就成瞭這樣: insert into 

 

 

person() values(),顯然這不滿足標準SQL的語法。對於字段名,建議使用主鍵之外的字段

 

 

,如果使用瞭INTEGER類型的主鍵字段,執行類似insert into person(personid) values

 

 

(NULL)的insert語句後,該主鍵字段值也不會為NULL。如果第三個參數values 不為Null並且

 

 

元素的個數大於0 ,可以把第二個參數設置為null。

————————————————————–

2.delete()方法的使用:

  SQLiteDatabase db = databaseHelper.getWritableDatabase();

  db.delete("person", "personid<?", new String[]{"2"});

  db.close();

  上面代碼用於從person表中刪除personid小於2的記錄。

——————————————————————–

3.update()方法的使用:

SQLiteDatabase db = databaseHelper.getWritableDatabase();

ContentValues values = new ContentValues();

values.put(“name”, “傳智播客”);//key為字段名,value為值

db.update("person", values, "personid=?", new String[]{"1"}); 

db.close();

上面代碼用於把person表中personid等於1的記錄的name字段的值改為“credream”。

————————————————————————–

4.query()方法實際上是把select語句拆分成瞭若幹個組成部分,然後作為方法的輸入參數:

SQLiteDatabase db = databaseHelper.getWritableDatabase();

Cursor cursor = db.query("person", new String[]{"personid,name,age"}, "name like 

 

 

?", new String[]{"%傳智%"}, null, null, "personid desc", "1,2");

while (cursor.moveToNext()) {

         int personid = cursor.getInt(0); //獲取第一列的值,第一列的索引從0開始

        String name = cursor.getString(1);//獲取第二列的值

        int age = cursor.getInt(2);//獲取第三列的值

}

cursor.close();

db.close(); 

上面代碼用於從person表中查找name字段含有“傳智”的記錄,匹配的記錄按personid降序

 

 

排序,對排序後的結果略過第一條記錄,隻獲取2條記錄。

query(table, columns, selection, selectionArgs, groupBy, having, orderBy, limit)

 

 

方法各參數的含義:

table:表名。相當於select語句from關鍵字後面的部分。如果是多表聯合查詢,可以用逗號

 

 

將兩個表名分開。

columns:要查詢出來的列名。相當於select語句select關鍵字後面的部分。

selection:查詢條件子句,相當於select語句where關鍵字後面的部分,在條件子句允許使

 

 

用占位符“?”

selectionArgs:對應於selection語句中占位符的值,值在數組中的位置與占位符在語句中

 

 

的位置必須一致,否則就會有異常。

groupBy:相當於select語句group by關鍵字後面的部分

having:相當於select語句having關鍵字後面的部分

orderBy:相當於select語句order by關鍵字後面的部分,如:personid desc, age asc;

limit:指定偏移量和獲取的記錄數,相當於select語句limit關鍵字後面的部分。

————————————————————————

1.利用sqlite提供的方法來實現添加,刪除,更新,查詢,和分頁,統計

——————————————–

/DBSQLIte/src/com/credream/service/OtherPersonService.java

package com.credream.service;

 

 

import java.util.ArrayList;

import java.util.List;

 

 

import android.content.ContentValues;

import android.content.Context;

import android.database.Cursor;

import android.database.sqlite.SQLiteDatabase;

import com.credream.entity.Person;

 

 

public class OtherPersonService

{

private DBOpenHelter dbOpenHelter;

public OtherPersonService(Context context){

this.dbOpenHelter=new DBOpenHelter(context);

}

/**

* 添加記錄

* @param person

*/

public void save (Person person){

SQLiteDatabase db=dbOpenHelter.getWritableDatabase();

//SQLiteDatabase db2=dbOpenHelter.getWritableDatabase();

//這裡獲得的數據庫實例和db這個數據庫實例是一樣的,因為數據庫有緩存

 

 

功能

//在源碼裡進行瞭判斷,如果得到的數據庫實例不為null,並且已經打開,並

 

 

且是隻讀的,那麼

//就直接返回這個實例

        //dbOpenHelter.getWritableDatabase().execSQL(sql);這裡和db.execSQL("作用

 

 

是一樣的

//db.execSQL("insert into person (name,phone) values

 

 

('"+person.getName()+"','"+person.getPhone()+"')");

   //上面這種寫法是錯誤的,因為當用戶輸入cre'dream的時候那麼sql語句就成瞭

//insert into person (name,phone) values

 

 

('cre'dream','15066659146')這樣會出現sql語法錯誤

//所以,應該用轉義字符

ContentValues values=new ContentValues();

values.put("name", person.getName());

values.put("phone", person.getPhone());

db.insert("person", null, values);

//這裡第二個字段,是空值字段,如果用戶傳過去的字段是空集合那麼就無

 

 

法組拼接sql

//比如:db.insert("person", "name",null );這時候,就是代表name可以

 

 

為null

//insert into person(name) values(NULL);

//所以當第三個參數不是null,的時候第二個參數是沒用的直接設置為

 

 

null就可以瞭

//db.insert("person", "personid",null );對應的sql:insert into 

 

 

person(personid) values(NULL);

//這時候主鍵為null,按理說是不正確的,但是sqlite做瞭處理,這個時候其

 

 

實取瞭主鍵自增值作為personid的值

 

//在源代碼裡,也是通過構造sql語句來完成,數據的添加的

//db.execSQL("insert into person (name,phone) values(?,?)",new 

 

 

Object[]{person.getName(),person.getPhone()});

//db.close();//數據庫也可以不關閉,因為這樣的話可以提升性能,因為不用頻繁的

 

 

開關數據庫

 

}

/**

* 刪除記錄

* @param person

*/

public void delete (Integer id){

SQLiteDatabase db=dbOpenHelter.getWritableDatabase();

db.delete("person", "personid=?", new String[]{id.toString()});

//這裡拼接的時候自動的給加瞭where不要重復加

//db.execSQL("delete from person  where personid=?",new Object[]

 

 

{id});

}

/**

* 更新記錄

* @param person

*/

public void update(Person person){

SQLiteDatabase db=dbOpenHelter.getWritableDatabase();

ContentValues values=new ContentValues();

values.put("name", person.getName());

values.put("phone", person.getPhone());

db.update("person", values,"personid=?",new String[]

 

 

{person.getId().toString()} );

//db.execSQL("update  person set name=?,phone=?   where 

 

 

personid=?",new Object[]{person.getName(),person.getPhone(),person.getId()});

 

}

/**

* 查找記錄

* @param id

* @return

*/

public Person find (Integer id){

SQLiteDatabase db=dbOpenHelter.getReadableDatabase();

//getReadableDatabase();這個方法裡面調用瞭getWritableDatabase();

 

 

方法,來取得數據庫操作實例,隻有調用

//失敗的時候就會發現異常,當數據磁盤滿瞭,會拋出異常,這時候會打開這

 

 

個實例的數據庫

//然後開始讀取,這樣當磁盤滿的時候,

//當數據庫磁盤空間沒有滿的時候,返回的數據庫操作實例是一樣的:可讀

 

 

可寫,當數據庫磁盤滿瞭,返回的數據庫

//操作實例是隻讀的

//Cursor cursor=db.query("person", new String[]{"personid","name","phone"}, 

 

 

"personid=?", new String[]{id.toString()}, null, null, null);

Cursor cursor=db.query("person", null, "personid=?", new String

 

 

[]{id.toString()}, null, null, null);

//Passing null will return all columns,第二個參數傳入null,將會獲

 

 

取所有的列 

//Cursor cursor=db.rawQuery("select * from person  where personid=?",new String

 

 

[]{id.toString()});

//遊標存放結果

if(cursor.moveToFirst()){

int personid=cursor.getInt(cursor.getColumnIndex("personid"));

String name=cursor.getString(cursor.getColumnIndex("name"));

String phone=cursor.getString(cursor.getColumnIndex("phone"));

return new Person(personid,name,phone);

 

}//當有數據會返回true,否則為false

cursor.close();

return null;

}

 

//處理分頁

/**

* 分頁獲取記錄

* offset:跳過前面幾條記錄

* maxlength:獲取幾條

*/

public List<Person> getScrollData(int offset,int MaxResult){

List<Person> persons=new ArrayList<Person>();

SQLiteDatabase db=dbOpenHelter.getReadableDatabase();

Cursor cursor=db.query("person", null, null, null, null,null, 

 

 

"personid asc", offset+","+MaxResult);

 

//Cursor cursor=db.rawQuery("select * from person order by 

 

 

personid asc limit ?,?",

//new String[]{String.valueOf(offset),String.valueOf

 

 

(MaxResult)});

while(cursor.moveToNext()){

int personid=cursor.getInt(cursor.getColumnIndex("personid"));

String name=cursor.getString(cursor.getColumnIndex("name"));

String phone=cursor.getString(cursor.getColumnIndex("phone"));

persons.add(new Person(personid,name,phone));

}

cursor.close();

return persons;

}

 

 

public long getCount(){

SQLiteDatabase db=dbOpenHelter.getReadableDatabase();

Cursor cursor=db.query("person", new String[]{"count(*)"}, null, 

 

 

null, null, null, null);

//Cursor cursor=db.rawQuery("select count(*) from person " 

 

 

,null);

//select count(*) from person註意這裡至少會獲得一條數據

cursor.moveToFirst();

long result=cursor.getLong(0);

return result;

}

 

 

 

}

—————————————————

/DBSQLIte/src/com/credream/test/OtherPersonServiceTest.java

package com.credream.test;

 

 

import java.util.List;

 

 

import com.credream.entity.Person;

import com.credream.service.DBOpenHelter;

import com.credream.service.OtherPersonService;

import com.credream.service.PersonService;

 

 

import android.test.AndroidTestCase;

import android.util.Log;

 

 

public class OtherPersonServiceTest extends AndroidTestCase

{

//PersonService service=new PersonService(this.getContext());

//不可以寫到這裡,因為這段代碼是在實例化過程中被調用的,如果剛剛開始的就直

 

 

接實例化這個對象

//這時候是取不到上下文對象的,隻有實例化過後才可以獲取上下文對象

//如果非要把這個單獨拿出來的話,可以寫到setUp()方法裡面,因為每個方法執行之

 

 

前都會首先執行這個方法

private static final String TAG="PersonServiceTest";

//創建數據庫,在<包>/database/

public void testCreateDB()throws Exception{

DBOpenHelter dbOpenHelter=new DBOpenHelter(getContext());

dbOpenHelter.getWritableDatabase();

}

public void testSave()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

//for(int i=0;i<20;i++){

//Person person=new Person("lidewei"+i,"15163245754"+i);

Person person=new Person("xiaoyue","15163245754");

service.save(person);

//}

}

public void testUpdate()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

Person person=service.find(1);

person.setName("mydream");

service.update(person);

 

}

 

 

public void testDelete()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

service.delete(22);

}

 

 

public void testFind()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

Person person=service.find(1);

Log.i(TAG,person.toString());

 

}

 

 

public void testScrollData()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

List<Person> persons=

service.getScrollData(0, 50);

for(Person person :persons){

Log.i(TAG,person.toString());

}

//翻到第2頁  

}

public void testCount()throws Exception{

OtherPersonService service=new OtherPersonService

 

 

(this.getContext());

long result=service.getCount();

Log.i(TAG, result+"");

 

}

//除瞭以上的數據庫操作為,還為我們提供瞭專門方法:

 

 

 

}

———————————————————

/DBSQLIte/src/com/credream/service/DBOpenHelter.java

package com.credream.service;

 

 

import android.content.Context;

import android.database.sqlite.SQLiteDatabase;

import android.database.sqlite.SQLiteOpenHelper;

import android.database.sqlite.SQLiteDatabase.CursorFactory;

 

 

public class DBOpenHelter extends SQLiteOpenHelper

{

//父類沒有默認構造器,需要顯示調用

public DBOpenHelter(Context context)

{

super(context, "credream.db", null, 2);

//數據庫創建完成後,默認會保存在<包>/database/文件夾下

//當修改版本號時候,會觸發:onUpgrade方法

//第二個:指定數據庫名稱,

//第三個:遊標工廠,用來迭代,查詢後的結果集,null代表使用系統默認的

 

 

遊標工廠

//版本號,大於0

 

}

/**

 * 這個方法是在數據庫第一次被創建的時候調用的

 */

@Override

public void onCreate(SQLiteDatabase db)

{

//SQLiteDatabase這個類,封裝瞭增刪改查操作,也叫做數據庫操作實例

db.execSQL("CREATE TABLE person (personid integer primary key 

 

 

autoincrement, name varchar(20))");

//這裡也可以不寫name的數據類型,因為sqlite是數據類型無關的,就是寫

 

 

瞭varchar(20),也可以寫入超過20的內容

 

 

}

/**

 * 當數據庫的版本號變更的時候被調用

 */

@Override

public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion)

{

db.execSQL("alter table person add phone varchar(12) null");

 

 

}

發佈留言

發佈留言必須填寫的電子郵件地址不會公開。 必填欄位標示為 *