SQLite数据库操作详细示例

Sqlite 前端之家
前端之家收集整理的这篇文章主要介绍了SQLite数据库操作详细示例，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。


MainActivity如下:

package cc.testdb;

import java.util.List;
import cc.database.DBUtils;
import cc.domain.Person;
import android.os.Bundle;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.Window;
import android.view.WindowManager;
import android.widget.Button;
import android.app.Activity;
import android.content.Context;
/**
 * Demo描述:
 * sqlite数据操作
 * 
 * 参考资料:
 * http://blog.csdn.net/lfdfhl/article/details/8195378
 * 
 */
public class MainActivity extends Activity {
    private Button mAddButton;
    private Button mQueryButton;
    private Button mUpdateButton;
    private Button mDeleteButton;
    private Button mCountButton;
    private Button mPageButton;
    private Button mTransactionButton;
    private Context mContext;
	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		requestWindowFeature(Window.FEATURE_NO_TITLE);
		getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,WindowManager.LayoutParams.FLAG_FULLSCREEN);
		setContentView(R.layout.main);
		init();
	}
	
	private void init(){
		mContext=this;
		mAddButton=(Button) findViewById(R.id.addButton);
		mAddButton.setOnClickListener(new ClickListenerImpl());
		
		mQueryButton=(Button) findViewById(R.id.queryButton);
		mQueryButton.setOnClickListener(new ClickListenerImpl());
		
		mUpdateButton=(Button) findViewById(R.id.updateButton);
		mUpdateButton.setOnClickListener(new ClickListenerImpl());
		
		mDeleteButton=(Button) findViewById(R.id.deleteButton);
		mDeleteButton.setOnClickListener(new ClickListenerImpl());
		
		mCountButton=(Button) findViewById(R.id.countButton);
		mCountButton.setOnClickListener(new ClickListenerImpl());
		
		mPageButton=(Button) findViewById(R.id.pageButton);
		mPageButton.setOnClickListener(new ClickListenerImpl());
		
		mTransactionButton=(Button) findViewById(R.id.transactionButton);
		mTransactionButton.setOnClickListener(new ClickListenerImpl());
		
	}
	
	
	private class ClickListenerImpl implements OnClickListener {
		Person person=null;
		@Override
		public void onClick(View v) {
			switch (v.getId()) {
			case R.id.addButton:
				for (int i = 0; i < 15; i++) {
					person=new Person("xiaoming"+i,"9527"+i);
					DBUtils.add(mContext,person);
				}
				break;
			case R.id.queryButton:
				person=DBUtils.query(mContext,5);
				System.out.println(person);
				break;
			case R.id.updateButton:
				person=DBUtils.query(mContext,1);
				System.out.println("修改前:"+person);
				person=new Person(1,"xx","1234");
				DBUtils.update(mContext,person);
				person=DBUtils.query(mContext,1);
				System.out.println("修改后:"+person);
				break;
			case R.id.deleteButton:
				DBUtils.delete(mContext,2);
				break;
			case R.id.countButton:
				int count=DBUtils.count(mContext);
				System.out.println("数据总量为:"+count);
				break;
			case R.id.pageButton:
				List<Person> list=DBUtils.page(mContext,4,9);
				for (int i = 0; i < list.size(); i++) {
					 person=list.get(i);
					 System.out.println("分页的数据:"+person);
				}
				break;
			case R.id.transactionButton:
				person=new Person(1,"ccc","8888");
				DBUtils.transaction(mContext,1);
				System.out.println("事务操作后:"+person);
				break;
			default:
				break;
			}
		}

	}
}

DataBaSEOpenHelper如下: 
package cc.database;

import android.content.Context;
import android.database.sqlite.sqliteDatabase;
import android.database.sqlite.sqliteOpenHelper;

public class DataBaSEOpenHelper extends sqliteOpenHelper {
    private final static String DATABASE_NAME="test.db";
    private static DataBaSEOpenHelper mDataBaSEOpenHelper;
    //super(context,DATABASE_NAME,null,1)方法:
    //若不存在DATABASE_NAME数据,则执行onCreate(sqliteDatabase db)方法
    //若已经存在则不再新建数据库
    //方法中第三个参数为:version 版本号
    //当version变大时会自动调用
    //onUpgrade(sqliteDatabase db,int oldVersion,int newVersion)方法
	public DataBaSEOpenHelper(Context context) {
		super(context,1);
	}

	
	//注意:
	//将DataBaSEOpenHelper写成单例的.
	//否则当在一个for循环中频繁调用openHelper.getWritableDatabase()时
	//会报错,提示数据库没有执行关闭操作
	static synchronized DataBaSEOpenHelper getDBInstance(Context context) {
		if (mDataBaSEOpenHelper == null) {
			mDataBaSEOpenHelper = new DataBaSEOpenHelper(context);
		}
		return mDataBaSEOpenHelper;
	} 
	
	@Override
	public void onCreate(sqliteDatabase db) {
		db.execsql("create table person(personid integer primary key autoincrement,name varchar(20),phone VARCHAR(12))");
	}

	//为person增加一个address字段,默认值为null
	@Override
	public void onUpgrade(sqliteDatabase db,int newVersion) {
		db.execsql("ALTER TABLE person ADD address VARCHAR(12) NULL");
	}

}

DBUtils如下: 
package cc.database;
import java.util.ArrayList;
import java.util.List;
import cc.domain.Person;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.sqliteDatabase;

public class DBUtils {
	public static DataBaSEOpenHelper openHelper;
	public static sqliteDatabase db;
	
	public static void add(Context context,Person person){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
        db.execsql("insert into person (name,phone) values(?,?)",new Object[]{person.getName(),person.getPhone()});
		
	}
	
	//注意:
	// 1 rawQuery()方法查询后返回的结果是一个Cursor类的对象
    // 2 最后要关闭cursor即cursor.close();
	public  static Person query(Context context,int id){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
		Cursor cursor=db.rawQuery("select * from person where personid=?",new String[]{String.valueOf(id)});
		while(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);
		}
		cursor.close();
		return null;
	}
	
	
	//因为name和phone的类型都是String,但是id是整型的
	//所以这里的数组写成了Object类型的
	public  static void update(Context context,Person person){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
		db.execsql("update person set name=?,phone=? where personid=?",person.getPhone(),person.getId()});
	}
	
	
	public  static void delete(Context context,int id){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
        db.execsql("delete from person where personid=?",new Object[]{String.valueOf(id)});
	}
	
	//在while循环里要注意终止循环,否则是个死循环
	//因为如果cursor不为空那么
	//cursor.moveToFirst()总是返回true
	public  static int count(Context context){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getReadableDatabase(); 
		Cursor cursor=db.rawQuery("select count(*) from person",null);
		int i=0;
		while(cursor.moveToFirst()){
		     i=cursor.getInt(0);
		     break;
		}
		return i;
	}
	
	public  static List<Person> page(Context context,int offset,int resuletNumber){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
		ArrayList<Person> persons=new ArrayList<Person>();	
		Person person=null;
		Cursor  cursor=db.rawQuery("select * from person limit ?,?",new String []{String.valueOf(offset),String.valueOf(resuletNumber)});
		while(cursor.moveToNext()){
			int personid=cursor.getInt(cursor.getColumnIndex("personid"));
			String name=cursor.getString(cursor.getColumnIndex("name"));
			String phone=cursor.getString(cursor.getColumnIndex("phone"));
			person=new Person(personid,phone);
			persons.add(person);
		}
		return persons;
	  }
	
	/**
	 * 结束事务有两种:提交事务和回滚事务.
	 * 默认情况是回滚事务!!!!
	 * 事务是否提交是由事务的标志来决定:
	 * 如果事务的标志位失败(false),就回滚事务;否则(true)提交事务。
	 * 所以默认情况下事务的标志为失败(false)即回滚事务.
	 */
	public  static void transaction(Context context,Person person){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
        db = openHelper.getWritableDatabase();
		//开启事务
		db.beginTransaction();
		try{
			db.execsql("update person set name=? where personid=?",person.getId()});
			db.execsql("update person set phone=? where personid=?",new Object[]{person.getPhone(),person.getId()});
			//设置事务的标志为成功
			db.setTransactionSuccessful();
		}finally{
			//结束事务,默认情况下是回滚事务
			db.endTransaction();
		}
	}
	
}


修改后的DBUtils

package cc.database;
import java.util.ArrayList;
import java.util.List;
import cc.domain.Person;
import android.content.ContentValues;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.sqliteDatabase;
/**
 * 在原来基础上修改后的DBUtils
 *  
 * 主要的修改:
 * 原来采用了原生的sql语句进行增删改查
 * 现在改为利用Android自带的方法:
 * insert(String table,String nullColumnHack,ContentValues values)
 * delete(String table,String whereClause,String[] whereArgs)
 * update(String table,ContentValues values,String[] whereArgs)
 * query(table,columns,selection,selectionArgs,groupBy,having,orderBy,limit)
 * 来实现
 * 2014年12月14日16:53:08
 */
public class DBUtils {
	public final static String TABLE_NAME="person";
	public static DataBaSEOpenHelper openHelper;
	public static sqliteDatabase db;
	
	
	/**
	 * 
	 * 利用sqliteDatabase.insert(String table,ContentValues values)方法插入数据
	 * 注意该方法的第二个参数:
	 * 用于在未指定添加数据的情况下给某些可为空的列自动赋值为NULL.一般情况下不会这么做,所以传入NULL即可.
	 * 
	 * 该操作等同于:
	 * db.execsql("insert into person (name,person.getPhone()});
	 */
	public static void insertData(Context context,Person person){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
		ContentValues contentValues=new ContentValues();
		contentValues.put("name",person.getName());
		contentValues.put("phone",person.getPhone());
        db.insert(TABLE_NAME,contentValues);
	}
	
	
	/**
	 * 利用sqliteDatabase.query(table,limit)
	 * 方法查询数据
	 * 
	 * 该操作等同于:
	 * Cursor cursor=db.rawQuery("select * from person where personid=?",new String[]{String.valueOf(id)});
	 * 注意:
	 * 1 rawQuery()方法查询后返回的结果是一个Cursor类的对象
	 * 2 最后要关闭cursor即cursor.close();
	 */
	public  static Person queryData(Context context,int id){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
		Cursor cursor=db.query(TABLE_NAME,"personid=?",new String []{id+""},null);
		while(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,phone);
		}
		cursor.close();
		return null;
	}
	
	
	/**
	 * 利用sqliteDatabase.update(String table,String[] whereArgs)
	 * 更新数据.
	 * 第二个参数表示要更新的内容
	 * 第三和第四个参数表示了要更新的列及其对应的值
	 * 注意第三个参数中占位符的使用
	 * 
	 * 该操作等同于:
	 * db.execsql("update person set name=?,*    new Object[]{person.getName(),person.getId()});
	 * 因为name和phone的类型都是String,但是id是整型的
	 * 所以这里的数组写成了Object类型的
	 */
	public  static void updateData(Context context,person.getPhone());
        db.update(TABLE_NAME,contentValues,new String []{person.getId()+""});
	}
	
	
	/**
	 * 利用sqliteDatabase.delete(String table,String[] whereArgs)
	 * 删除数据
	 * 
	 * 该操作等同于:
	 * db.execsql("delete from person where personid=?",new Object[]{String.valueOf(id)});
	 */
	public  static void delete(Context context,int id){
		openHelper=DataBaSEOpenHelper.getDBInstance(context);
		db=openHelper.getWritableDatabase();
        db.delete(TABLE_NAME,new String []{id+""});
	}
	
	//在while循环里要注意终止循环,默认情况下是回滚事务
			db.endTransaction();
		}
	}
	
}




Person如下:

package cc.domain;

public class Person {
	private Integer id;
	private String name;
	private String phone;
	
	public Person(String name,String phone) {
		this.name = name;
		this.phone = phone;
	}
	public Person(Integer id,String name,String phone) {
		this.id = id;
		this.name = name;
		this.phone = phone;
	}
	public Integer getId() {
		return id;
	}
	public void setId(Integer id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getPhone() {
		return phone;
	}
	public void setPhone(String phone) {
		this.phone = phone;
	}
	@Override
	public String toString() {
		return "Person [id=" + id + ",name=" + name + ",phone=" + phone + "]";
	}
	
}

main.xml如下: 
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    android:paddingLeft="20dip"
    android:paddingRight="20dip"
    android:orientation="vertical"
     >

    <Button
        android:id="@+id/tipButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="sqlite数据库测试"
        android:layout_marginTop="15dip"
        android:clickable="false"
        />
    
     <Button
        android:id="@+id/addButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="添加数据"
        android:layout_marginTop="15dip"
       />
     
      <Button
        android:id="@+id/queryButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="查找数据"
        android:layout_marginTop="15dip"
       />
      
        <Button
        android:id="@+id/updateButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="更新数据"
        android:layout_marginTop="15dip"
       />
        
        <Button
        android:id="@+id/deleteButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="删除数据"
        android:layout_marginTop="15dip"
       />
        
         <Button
        android:id="@+id/countButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="统计数据"
        android:layout_marginTop="15dip"
       />
       
         <Button
        android:id="@+id/pageButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="数据分页"
        android:layout_marginTop="15dip"
       />
         
         <Button
        android:id="@+id/transactionButton"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="事务操作"
        android:layout_marginTop="15dip"
       />

</LinearLayout>
原文链接：https://www.f2er.com/sqlite/200726.html

猜你在找的Sqlite相关文章

SQLite学习笔记
安装 在Windows上安装SQLite。 访问官网下载下Precompliled Binaries for Windows的两个压...
windows上如何安装Sqlite
一、安装 下载地址：http://www.sqlite.org/download.html 将Precompiled Binaries for Wi...
【Android数据存储】SQLite使用实例(附源码)
实例: 会员信息管理 功能：1.查看数据库 2.清空数据库 3.增加会员 4.删除会员 5.更新会员 ...
SQLite数据库管理
SQLite3常用命令
加密你的SQLite
关于SQLite SQLite是一个轻量的、跨平台的、开源的数据库引擎，它的在读写效率、消耗总量、...
SQLite这么娇小可爱，不多了解点都不行啊
在我眼里，MySQL和Oracle是这样的 而SQLite在是这样的 所以这么萌的数据库，我真的应该多了...
SQLite这么娇小可爱，不多了解点都不行啊
在我眼里，MySQL和Oracle是这样的 而SQLite在是这样的 所以这么萌的数据库，我真的应该多了...
SQLite 这么娇小可爱，不多了解点都不行啊
（点击上方蓝字，快速关注我们) 作者：空之境界 网址：http://supermao.cn/sqlitezhe-yao-...
SQLITE3 使用总结
SQLITE3 使用总结 投稿：hebedich 字体：[ 增加  减小] 类型：转载 时间：2014-08-19 Sql...
MySQLMsSQLOracleSqlitePostgre SQLMariadbMongoDBNoSQLHBaseJDBC
undo日志persistent-cmysql-error-postal-codesql-match-almysql-5.6mysql-8.0database-tri安装路径系统错误data_dir丢失文件主从同步sql_mode数据库目录匿名用户character_seID归零数据库位置查询表重复字段查询字段截断日志SUSPECT7391Remote ServeLinked Serve玄学问题登录不上开启远程访问