鸟语天空

创建和使用数据库

作者：追风剑情 发布于：2015-8-22 18:52 分类：Android

Android使用的是SQLite数据库系统。为一人应用程序所创建的数据库只能被此应用程序访问，其他应用程序将不能访问它。以编程方式创建的SQLite数据库总是存储在/data/data/<package_name>/databases文件夹下。

一、创建数据库辅助类

package com.example.androidtest;

import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.SQLException;
import android.database.sqlite.SQLiteDatabase;
import android.database.sqlite.SQLiteOpenHelper;
import android.util.Log;

/**
 * 访问数据库的辅助类
 * 封装了访问数据的所有复杂性。
 * 为一个应用程序所创建的数据库只能被此应用程序访问，其他应用程序将不能访问它。
 * 数据库文件存储在/data/data/<package_name>/databases文件夹下。
 * @author Administrator
 *
 */
public class DBAdapter {
	static final String KEY_ROWID = "_id";
	static final String KEY_NAME = "name";
	static final String KEY_EMAIL = "email";
	static final String TAG = "DBAdapter";
	
	static final String DATABASE_NAME = "MyDB";
	static final String DATABASE_TABLE = "contacts";
	static final int DATABASE_VERSION = 1;
	
	//定义创建表的sql语句常量
	static final String DATABASE_CREATE =
			"create table contacts (_id integer primary key autoincrement, "
			+ "name text not null, email text not null);";
	
	final Context context;
	
	DatabaseHelper DBHelper;
	SQLiteDatabase db;
	
	public DBAdapter(Context ctx)
	{
		this.context = ctx;
		DBHelper = new DatabaseHelper(context);
	}
	
	private static class DatabaseHelper extends SQLiteOpenHelper
	{
		DatabaseHelper (Context context)
		{
			super(context, DATABASE_NAME, null, DATABASE_VERSION);
		}

		@Override
		public void onCreate(SQLiteDatabase db) {
			try {
				db.execSQL(DATABASE_CREATE);
			} catch (SQLException e){
				e.printStackTrace();
			}
		}

		@Override
		public void onUpgrade(SQLiteDatabase db, int oldVersion, int newVersion) {
			Log.w(TAG, "Upgrading database from version "+oldVersion + "to "
					+newVersion+", which will destroy all old data");
			//为了简单起见，直接删除现有的表并创建一个新表，在实际中，通常需要备份现在的表，
			//然后将其内容复制到新表中。
			db.execSQL("DROP TABLE IF EXISTS contacts");
			onCreate(db);
		}
	}
	
	/**
	 * 创建or打开数据库
	 * @return
	 * @throws SQLException
	 */
	public DBAdapter open() throws SQLException
	{
		db = DBHelper.getWritableDatabase();
		return this;
	}
	
	/**
	 * 关闭数据库
	 */
	public void close()
	{
		DBHelper.close();
	}
	
	/**
	 * 插入数据
	 * @param name
	 * @param email
	 * @return ID
	 */
	public long insertContact(String name, String email)
	{
		ContentValues initialValues = new ContentValues();
		initialValues.put(KEY_NAME, name);
		initialValues.put(KEY_EMAIL, email);
		return db.insert(DATABASE_TABLE, null, initialValues);
	}
	
	/**
	 * 删除数据
	 * @param rowId
	 * @return	true:删除成功
	 */
	public boolean deleteContact(long rowId)
	{
		return db.delete(DATABASE_TABLE, KEY_ROWID+"="+rowId, null) > 0;
	}
	
	/**
	 * 查询所有数据
	 * @return Cursor	游标(可看成指向结果集的指针)
	 */
	public Cursor getAllContacts()
	{
		String[] columns = new String[] {KEY_ROWID, KEY_NAME, KEY_EMAIL};
		return db.query(DATABASE_TABLE, columns, null, null, null, null, null);
	}
	
	/**
	 * 查询指定数据
	 * @param rowId
	 * @return	Cursor	游标(可看成指向结果集的指针)
	 * @throws SQLException
	 */
	public Cursor getContact(long rowId) throws SQLException
	{
		String[] columns = new String[] {KEY_ROWID, KEY_NAME, KEY_EMAIL};
		Cursor mCursor = db.query(true, DATABASE_TABLE, columns, KEY_ROWID+"="+rowId, null, null, null, null, null);
		if(mCursor != null) {
			mCursor.moveToFirst();
		}
		return mCursor;
	}
	
	/**
	 * 更新指定数据
	 * @param rowId
	 * @param name
	 * @param email
	 * @return	true:更新成功
	 */
	public boolean updateContact(long rowId, String name, String email)
	{
		ContentValues args = new ContentValues();
		args.put(KEY_NAME, name);
		args.put(KEY_EMAIL, email);
		return db.update(DATABASE_TABLE, args, KEY_ROWID+"="+rowId, null) > 0;
	}
}

二、创建活动

视图

<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:orientation="vertical"
    tools:context="${relativePackage}.${activityClass}" >

    <Button
        android:id="@+id/btn_insert"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Insert"
        android:onClick="onClickInsert" />
    
    <Button
        android:id="@+id/btn_query_all"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Query all"
        android:onClick="onClickQueryAll" />
    
     <Button
        android:id="@+id/btn_query_id"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Query id"
        android:onClick="onClickQueryID" />
     
     <Button
        android:id="@+id/btn_update"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Update"
        android:onClick="onClickUpdate" />
     
     <Button
        android:id="@+id/btn_delete"
        android:layout_width="wrap_content"
        android:layout_height="wrap_content"
        android:text="Delete"
        android:onClick="onClickDelete" />

</LinearLayout>

代码

package com.example.androidtest;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

import android.app.Activity;
import android.database.Cursor;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Toast;

public class DatabasesActivity extends Activity {

	DBAdapter db;
	
	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_databases);
		
		db = new DBAdapter(this);
		db.open();
	}
	
	@Override
	protected void onDestroy()
	{
		super.onDestroy();
		db.close();
	}
	
	public void onClickInsert(View view)
	{
		Log.d("test", "db="+db);
		long id = db.insertContact("Wei-MengLee", "weimenglee@qq.com");
		id = db.insertContact("Mary Jackson", "mary@qq.com");
		
		Toast.makeText(this, "Insert successful", Toast.LENGTH_SHORT).show();
	}
	
	public void onClickQueryAll(View view)
	{
		Cursor c = db.getAllContacts();
		if(c.moveToFirst()){
			do {
				DisplayContact(c);
			} while (c.moveToNext());
		}
	}
	
	public void onClickQueryID(View view)
	{
		Cursor c = db.getContact(2);
		if(c.moveToFirst()){
			DisplayContact(c);
		}else{
			Toast.makeText(this, "No contact found", Toast.LENGTH_SHORT).show();
		}
	}
	
	public void onClickUpdate(View view)
	{
		if(db.updateContact(1, "Wei-Meng Lee", "weimenglee@gmail.com")){
			Toast.makeText(this, "Update successful", Toast.LENGTH_SHORT).show();
		}else{
			Toast.makeText(this, "Update failed", Toast.LENGTH_SHORT).show();
		}
	}
	
	public void onClickDelete(View view)
	{
		if(db.deleteContact(1)){
			Toast.makeText(this, "Delete successful", Toast.LENGTH_SHORT).show();
		}else{
			Toast.makeText(this, "Delete failed", Toast.LENGTH_SHORT).show();
		}
	}
	
	public void DisplayContact(Cursor c)
	{
		Toast.makeText(this, "id: "+c.getString(0) + "\n" +
				"Name: "+c.getString(1) + "\n" +
				"Email: " + c.getString(2),
				Toast.LENGTH_SHORT).show();
	}
	
	/**
	 * 把assets目录下的一个现成sqlite文件复制到目标文件夹。
	 * 注意: assets目录下的文件必须采用小写字母格式。
	 */
	public void CopyMyDB() {
		try {
			String destPath = "/data/data/"+getPackageName()+"/databases";
			File f = new File(destPath);
			Log.d("test", "db path="+f.getAbsolutePath());
			if (!f.exists()){
				f.mkdir();
				f.createNewFile();
				CopyDB(getBaseContext().getAssets().open("mydb"),
						new FileOutputStream(destPath+"/MyDB"));
			}
		} catch (FileNotFoundException e){
			e.printStackTrace();
		} catch (IOException e){
			e.printStackTrace();
		}
	}
	
	public void CopyDB(InputStream inputStream, OutputStream outputStream) throws IOException
	{
		byte[] buffer = new byte[1024];
		int length;
		while ((length = inputStream.read(buffer)) > 0) {
			outputStream.write(buffer, 0, length);
		}
		inputStream.close();
		outputStream.close();
	}
}

运行效果

标签: Android