Android利用泛型和反射來實現對資料庫的操作--SqlHelper

阿新 • • 發佈：2019-02-13

利用泛型和反射來實現對資料庫的操作

1.對資料庫操作的介面類

package com.dou361.dal;

import java.util.List;


/**
 * @author jjdxm
 * http://www.dou361.com
 * http://blog.csdn.net/jiujiedexiaoming
 * 通過反射來對資料庫操作
 *
 * @param <T>
 */
public interface SqlHelper<T> {
	/**
	 * 新增
	 * @param table 新增對應的表
	 * @param t 表對應的物件
	 * @return 插入的位置索引
	 */
	long insert(String table,T t);
	/**
	 * 刪除
	 * @param table 刪除對應的表
	 * @param columname 通過的欄位
	 * @param vaule 欄位對應的值
	 * @return 刪除影響的行數
	 */
	int delete(String table,String columname,String vaule);
	/**
	 * 修改
	 * @param table 修改對應的表
	 * @param t 修改的表對應的物件
	 * @return 修改影響的行數
	 */
	int update(String table,T t);
	/**
	 * 查詢一個
	 * @param table 需要查詢的表
	 * @param columname 需要查詢的欄位名
	 * @param vaule 需要查詢的欄位對應的值
	 * @return 表對應的物件
	 */
	List<T> query(String table,String columname,String vaule);
	
	/**
	 * 查詢一頁
	 * @param table 需要查詢的表
	 * @param startIndex 查詢的起始索引
	 * @param pageSize 查詢的頁面條數
	 * @return page資料
	 */
	List<T> queryPage(String table,int startIndex,int pageSize);
	
	/**
	 * @param table 需要查詢的表
	 * @return 所有資料
	 */
	List<T> queryAll(String table);
}

2.對資料操作的實現類

package com.dou361.dal;

import java.lang.reflect.Field;
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.dou361.db.DBOpenHelper;

/**
 * @author jjdxm 
 * http://www.dou361.com
 * http://blog.csdn.net/jiujiedexiaoming
 * 通過反射來對資料庫操作
 * @param <T>
 */
public class SqlHelperImpl<T> implements SqlHelper<T> {

	/**
	 * 反射得到位元組碼檔案
	 */
	private Class clazz;

	/**
	 * 對應表的對映欄位（操作表的所有屬性）
	 */
	private String[] sqlcolumns;

	/**
	 * 建立資料庫的幫助物件
	 */
	private DBOpenHelper dbOpenHelper;

	/**
	 * 建構函式，初始化工作
	 * 
	 * @param context
	 *            上下文
	 * @param clazz
	 *            表對應bean物件的位元組碼檔案
	 * @param dbName
	 *            資料庫名稱
	 * @param sql
	 *            建立表語句
	 * @param sqlcolumns
	 *            對應表的對映欄位（操作表的所有屬性）
	 */
	public SqlHelperImpl(Context context, Class clazz, String dbName,
			String sql, String[] sqlcolumns) {
		this.clazz = clazz;
		this.sqlcolumns = sqlcolumns;
		dbOpenHelper = new DBOpenHelper(context, dbName, sql);
	}

	@Override
	public long insert(String table, T t) {
		try {
			SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
			if (sqlcolumns != null && sqlcolumns.length > 0) {
				ContentValues values = new ContentValues();
				for (int i = 1; i < sqlcolumns.length; i++) {
					try {
						Field field = t.getClass().getDeclaredField(
								sqlcolumns[i]);
						field.setAccessible(true);
						Object objVaule = field.get(t);
						if (objVaule != null) {
							values.put(sqlcolumns[i], (String) objVaule);
						}
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
				long insertIndex = database.insert(table, null, values);
				database.close();
				return insertIndex;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return -1;
	}

	@Override
	public int delete(String table, String columname, String value) {
		SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
		int rows = database.delete(table, columname + "=?",
				new String[] { value });
		database.close();
		return rows;
	}

	@Override
	public int update(String table, T t) {
		try {
			SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
			String whereValue = null;
			if (sqlcolumns != null && sqlcolumns.length > 0) {
				ContentValues values = new ContentValues();
				for (int i = 0; i < sqlcolumns.length; i++) {
					try {
						Field field = t.getClass().getDeclaredField(
								sqlcolumns[i]);
						field.setAccessible(true);
						Object objVaule = field.get(t);
						if (objVaule != null) {
							if (i == 0) {
								whereValue = objVaule.toString();
							} else {
								values.put(sqlcolumns[i], (String) objVaule);
							}
						}
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
				int rows = database.update(table, values, sqlcolumns[0] + "=?",
						new String[] { whereValue });
				database.close();
				return rows;
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
		return -1;
	}

	@Override
	public List<T> query(String table, String columname, String value) {
		SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
		Cursor cursor = database.query(table, sqlcolumns, columname + "=?",
				new String[] { value }, null, null, null);
		List<T> list = new ArrayList<T>();
		while (cursor.moveToNext()) {
			try {
				Object obj = clazz.newInstance();
				for (int i = 0; i < sqlcolumns.length; i++) {
					try {
						Field field = clazz.getDeclaredField(sqlcolumns[i]);
						field.setAccessible(true);

						int type = cursor.getType(i);
						Object objValue = null;
						switch (type) {
						case Cursor.FIELD_TYPE_STRING:
							objValue = cursor.getString(i);
							break;
						case Cursor.FIELD_TYPE_INTEGER:
							objValue = cursor.getInt(i);
							break;
						case Cursor.FIELD_TYPE_FLOAT:
							objValue = cursor.getFloat(i);
							break;
						case Cursor.FIELD_TYPE_BLOB:
							objValue = cursor.getBlob(i);
							break;

						default:
							break;
						}

						field.set(obj, objValue);
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
				T t = (T) obj;
				list.add(t);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		cursor.close();
		database.close();
		return list;
	}

	@Override
	public List<T> queryPage(String table, int startIndex, int pageSize) {
		SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
		Cursor cursor = database.query(table, sqlcolumns, null, null, null,
				null, sqlcolumns[0] + " desc", startIndex + "," + pageSize);
		List<T> list = new ArrayList<T>();
		while (cursor.moveToNext()) {
			try {
				Object obj = clazz.newInstance();
				for (int i = 0; i < sqlcolumns.length; i++) {
					try {
						Field field = clazz.getDeclaredField(sqlcolumns[i]);
						field.setAccessible(true);

						int type = cursor.getType(i);
						Object objValue = null;
						switch (type) {
						case Cursor.FIELD_TYPE_STRING:
							objValue = cursor.getString(i);
							break;
						case Cursor.FIELD_TYPE_INTEGER:
							objValue = cursor.getInt(i);
							break;
						case Cursor.FIELD_TYPE_FLOAT:
							objValue = cursor.getFloat(i);
							break;
						case Cursor.FIELD_TYPE_BLOB:
							objValue = cursor.getBlob(i);
							break;

						default:
							break;
						}

						field.set(obj, objValue);
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
				T t = (T) obj;
				list.add(t);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		cursor.close();
		database.close();
		return list;
	}

	@Override
	public List<T> queryAll(String table) {
		SQLiteDatabase database = dbOpenHelper.getWritableDatabase();
		Cursor cursor = database.query(table, sqlcolumns, null, null, null,
				null, null, null);
		List<T> list = new ArrayList<T>();
		while (cursor.moveToNext()) {
			try {
				Object obj = clazz.newInstance();
				for (int i = 0; i < sqlcolumns.length; i++) {
					try {
						Field field = clazz.getDeclaredField(sqlcolumns[i]);
						field.setAccessible(true);
						int type = cursor.getType(i);
						Object objValue = null;
						switch (type) {
						case Cursor.FIELD_TYPE_STRING:
							objValue = cursor.getString(i);
							break;
						case Cursor.FIELD_TYPE_INTEGER:
							objValue = cursor.getInt(i);
							break;
						case Cursor.FIELD_TYPE_FLOAT:
							objValue = cursor.getFloat(i);
							break;
						case Cursor.FIELD_TYPE_BLOB:
							objValue = cursor.getBlob(i);
							break;

						default:
							break;
						}
						field.set(obj, objValue);
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
				T t = (T) obj;
				list.add(t);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
		cursor.close();
		database.close();
		return list;
	}

}

3.通過以上的幫助類，可以開速的編寫對資料庫的操作類

如一個新聞的實體類和其對應的表

package com.dou361.domain;

import java.io.Serializable;

public class Acount implements Serializable {

	private static final long serialVersionUID = 1L;

	private Integer _id;
	private String acountName;

	public Integer get_id() {
		return _id;
	}

	public void set_id(Integer _id) {
		this._id = _id;
	}

	public String getAcountName() {
		return acountName;
	}

	public void setAcountName(String acountName) {
		this.acountName = acountName;
	}

}

4.具體的資料庫操作類

<pre name="code" class="java">package com.dou361.dao.impl;

import java.util.List;

import android.content.Context;

import com.dou361.dal.SqlHelperImpl;
import com.dou361.domain.Acount;

public class AcountDaoImpl extends SqlHelperImpl<Acount> {

	private String table = "T_Acounts";
	static String sql = "create table T_Acounts (_id Integer primary key autoincrement,acountName varchar(30))";
	static String[] sqlcolumns = new String[] { "_id", "acountName" };

	public AcountDaoImpl(Context context) {
		super(context, "mobilesafe.db", sql, Acount.class, sqlcolumns);
	}

	@Override
	public long add(Acount acount) {
		return super.insert(table, acount);
	}

	@Override
	public int deleteByValue(String columname, String value) {
		return super.delete(table, columname, value);
	}

	@Override
	public int update(Acount acount) {
		return super.update(table, acount);
	}

	@Override
	public List<Acount> getByValue(String columname, String value) {
		return super.query(table, columname, value);
	}

	@Override
	public List<Acount> getAll() {
		return super.queryAll(table);
	}

}

5.為了方便起見，還可以進一步優化

package com.dou361.bussiness.impl;

import java.util.List;

import android.content.Context;

import com.dou361.bussiness.AcountBusinessServer;
import com.dou361.dao.impl.AcountDaoImpl;
import com.dou361.domain.Acount;

public class AcountBusinessServerImpl implements AcountBusinessServer {

	private AcountDaoImpl<span style="font-family: Arial, Helvetica, sans-serif;"> </span>acountDao;

	public AcountBusinessServerImpl(Context context) {
		acountDao = new AcountDaoImpl(context);
	}
<span style="white-space:pre">	/**
<span style="white-space:pre">	</span> * 新增
<span style="white-space:pre">	</span> * 
<span style="white-space:pre">	</span> * @param Acount
<span style="white-space:pre">	</span> *            新增的Acount物件
<span style="white-space:pre">	</span> * @return 返回狀態
<span style="white-space:pre">	</span> */</span>
	@Override
	public boolean add(Acount acount) {
		return acountDao.add(acount) > 0;
	}
<span style="white-space:pre">	

<span style="white-space:pre">	</span>/**
<span style="white-space:pre">	</span> * 刪除
<span style="white-space:pre">	</span> * 
<span style="white-space:pre">	</span> * @param id
<span style="white-space:pre">	</span> *            通過id刪除一個BlackNumber物件
<span style="white-space:pre">	</span> * @return 返回狀態
<span style="white-space:pre">	</span> */</span>
	@Override
	public boolean deleteById(String id) {
		return acountDao.deleteByValue("_id", id) > 0;
	}
<span style="white-space:pre">	

<span style="white-space:pre">	</span>/**
<span style="white-space:pre">	</span> * 修改
<span style="white-space:pre">	</span> * 
<span style="white-space:pre">	</span> * @param Acount
<span style="white-space:pre">	</span> *            修改的acount物件
<span style="white-space:pre">	</span> * @return 返回狀態
<span style="white-space:pre">	</span> */</span>
	@Override
	public boolean update(Acount acount) {
		return acountDao.update(acount) > 0;
	}
<span style="white-space:pre">	

<span style="white-space:pre">	</span>/**
<span style="white-space:pre">	</span> * 查詢一個Acount物件
<span style="white-space:pre">	</span> * 
<span style="white-space:pre">	</span> * @param id
<span style="white-space:pre">	</span> *            通過id查詢
<span style="white-space:pre">	</span> * @return 返回Acount
<span style="white-space:pre">	</span> */</span>
	@Override
	public List<Acount> getById(String id) {
		return acountDao.getByValue("_id", id);
	}
	

<span style="white-space:pre">	</span>/**
<span style="white-space:pre">	</span> * 查詢一個Acount物件
<span style="white-space:pre">	</span> * 
<span style="white-space:pre">	</span> * @param acountName
<span style="white-space:pre">	</span> *            通過acountName查詢
<span style="white-space:pre">	</span> * @return 返回Acount
<span style="white-space:pre">	</span> */
	@Override
	public List<Acount> getByAcountName(String acountName) {
		return acountDao.getByValue("acountName", acountName);
	}
<span style="white-space:pre">	

<span style="white-space:pre">	</span>/**
<span style="white-space:pre">	</span> * @return 返回所有
<span style="white-space:pre">	</span> */</span>
	@Override
	public List<Acount> getAll() {
		return acountDao.getAll();
	}

}

6.接下來就是使用了，在這裡只需要建立最後一個類的例項即可方便的使用了。

Android利用泛型和反射來實現對資料庫的操作--SqlHelper

利用泛型和反射來實現對資料庫的操作 1.對資料庫操作的介面類 package com.dou361.dal; import java.util.List; /** * @author jjdxm * http://www.dou361.com * http:/

C# 利用泛型和反射靈活接收資料

private void button1_Click(object sender, EventArgs e) { //dic是獲取到的資料列表，這裡假設成有這三種 Dictionary<string, object> dic = new Dictionary

7、利用泛型和反射,讓public static T findById(Class clazz, int id)方法,更具一般性

1、前面講到的findById(int id),只是一個僅僅針對user表的操作,為了使得查詢方法更具有一般性,引入了泛型和反射 2、利用泛型和反射,讓public static <T> T findById(Class<T> clazz, int

java異常、泛型和反射

（1）異常異常的概念：所謂異常是指程式在執行過程中發生的一些不正常事件。（如：除0溢位，陣列下標越界，所讀取的檔案不存在）異常導致的結果：java程式的執行過程中如出現異常事件，可以生成一個異常類物件。該異常物件封裝了異常事件的資訊，並將其提交給java執行時系統，這個過程成為丟擲異

通過泛型和反射構建一個簡單的集合操作工具類

平時在操作集合物件的時候（比如List）；我想一次新增大於一個數據的時候，往往需要通過一個集合物件呼叫兩次add方法，比如： List<Person> personList=new ArrayList<>(); Person p1=n

C#綜合揭祕——利用泛型與反射更新實體（ADO.NET Entity Framework）

自從ADO.NET Entity Framework面世以來，受到大家的熱捧，它封裝了大量程式碼生成的工具，使用者只需要建立好實體之間的關係，系統就是會為使用者自動成功了Add、Delete、CreateObject、Attach、ToList......等等方法，這些方法

java中的泛型和反射的一些總結

什麼叫反射？反射是框架設計的靈魂（使用的前提條件：必須先得到代表的位元組碼的Class，Class類用於表示.class檔案（位元組碼））一、反射的概述 JAVA反射機制是在執行狀態中，對於任意一個類，都能夠知道這個類的所有屬性和方法；對於任意一個物件，都能夠呼

getSuperclass和getGenericSuperclass區別(java泛型和反射綜合應用)

1.官方API對這兩個方法的介紹 . getSuperclass : 返回表示此 Class 所表示的實體（類、介面、基本型別或 void）的超類的 Class。如果此 Class 表示 Object 類、一個介面、一個基本型別或 void，則返回 nu

利用泛型、反射讀取資料庫資料

//基類 public abstract class BaseDAL { public BaseDAL() { // //TODO: 在此處新增建構函式邏輯 // } protected List<T> GetTabList<T

java的泛型和反射，多執行緒

1： java的泛型 2：java的super()在子類中使用時，必須放在第一行，還有對無參函式的呼叫問題。 3： java的反射機制(詳情請參考eclipse的例子) getConstr

編寫高質量程式碼:改善Java程式的151個建議(第7章:泛型和反射___建議93~97)

我們最大的弱點在於放棄。成功的必然之路就是不斷的重來一次。 --達爾文建議93：Java的泛型是可以擦除的建議94

編寫高質量程式碼:改善Java程式的151個建議(第7章:泛型和反射___建議101~109)

我命由我不由天 --哪吒建議101：注意Class類的特殊性建議102：適時選擇getDeclaredXXX和ge

使用sort和awk來實現對檔案塊進行排序

professor.db中每個檔案塊記錄了一位教授的資訊,由三行組成:第1行是姓名,第2行是學校名,第3行是學校所處的城市和國家.如果需要根據姓名對檔案塊進行排序,僅使用sort命令是難以實現的,我們通過結合使用sort和awk來實現這一功能: cat professor.

利用過濾器Filter和特性Attribute實現對Web API返回結果的封裝和統一異常處理

在我們開發Web API應用的時候，我們可以借鑑ABP框架的過濾器Filter和特性Attribute的應用，實現對Web API返回結果的封裝和統一異常處理，本篇隨筆介紹利用AuthorizeAttribute實現Web API身份認證，利用ActionFilterAttribute實現對常規Web API

利用springmvc和jdbcTemplate搭建一個對資料庫操作的小例子

在接觸到struts2+hibernate+spring三大框架搭建的專案時覺得對於比較簡單的專案會顯得很繁重，特別是struts現在使用的也不是很廣泛，所以我通過網上的部分資料以及對spring的一些瞭解，在maven下搭建一個springmvc的小程式，僅僅是對資料庫的

使用sql標籤來實現對資料庫當中記錄增刪改查操作

1：實現向資料庫當中進行資料的插入操作 <%@ page language="java" contentType="text/html; charset=utf-8" pageEncod

利用支援ODBC的CRecordset類實現對資料庫的操作

1.MFC中的ODBC類主要有CDatabase、CRecordset、CRecordview、CDBException、CFieldExchange。這些類封裝了ODBC SDK函式，可以很方便的操作支援ODBC的資料庫。 (1)CDatabase類：封裝應用程式與需

Spring使用JdbcTemplate實現對資料庫操作 (內部類定義RowMapper)

http://blog.csdn.net/wyc_cs/article/details/37766221 Spring對資料庫的操作使用JdbcTemplate來封裝JDBC，結合Spring的注入特性可以很方便的實現對資料庫的訪問操作。使用JdbcTemplate可以

Java反射、泛型和註解實戰之Spring核心注入IOC的實現

一.前言通過前兩篇文章的學習，我們已經對Java中這三個模組的知識有了初步的瞭解。為了將鞏固之前的知識，今天我們將綜合運用這三個模組的知識，來實現一個類似Spring中注入的案例。二.專案結構簡單的描繪了一下專案流程圖，

C#利用反射來判斷對象是否包含某個屬性的實現方法

是否 npr nbsp pro bsp str return ram ret 本文實例展示了C#利用反射來判斷對象是否包含某個屬性的實現方法，對於C#程序設計人員來說有一定的學習借鑒價值。具體實現代碼如下： 1 /// <summary> 2 /// 利

Android利用泛型和反射來實現對資料庫的操作--SqlHelper

相關推薦