2. 程式人生 > >BaseDAO增刪改查通用程式碼

BaseDAO增刪改查通用程式碼

阿新 • • 發佈：2018-11-25

實習已經兩三個月了，在這兩三個月中見到了很多以前沒有見到過的東西，也學到了很多的東西。其中，我覺得最神奇的地方就是我們公司的框架了，在學校的時候以為所有程式碼都是要手寫的，但是萬萬沒想到很多通用的程式碼竟然可以提取出來自動生成!!!

 

正好馬上要開始做畢業設計了，我準備自己也把通用程式碼提取出來，也實現自動生成。這樣一來能夠提高自己，二來也能少寫點程式碼。

 

下面就是我提取DAO層思路，公司裡的DAO層只提取了分頁，計數等通用功能。其增刪改查功能是通過自己寫maven外掛自動生成的，這樣的一個好處是對於具體的某一個JavaBean可以隨意的修改其增刪改查方法。其缺點也顯而易見，如果沒有對應的程式碼自動生成外掛，這是一個很大的工作量。

 

因此，針對以上的不足之處，我這次把增刪改查功能也單獨提取出來了。但是這樣的缺點也顯而易見的暴露出來了，無法很方便的修改具體的某一個JavaBean的增刪改查方法。而且在實現這些方法時，增刪改查中用到的主鍵都是自動獲取的，使用起來比較呆板，靈活性較差。因此這斷程式還需要進行修改，這裡暫時記錄下來。

下面貼出我的程式碼

package com.msw.framework.base;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

import com.msw.framework.entity.Entity;
import com.msw.framework.entity.JdbcExecute;
import com.msw.framework.utils.FrameWorkUtils;

/**
 * DAO操作基礎類
 * <p>
 * 自動處理增刪改查操作，其中對時間日期格式未處理，如果實體類中有時間日期格式資料請重寫方法進行操作
 * </p>
 * 
 * @author mashengwei
 * @date 2018年11月17日
 * @version 0.0.1
 * @param <T>
 */
@Repository
@SuppressWarnings("all")
public abstract class BaseDAO<T extends Entity> {
	Logger logger = LoggerFactory.getLogger(BaseDAO.class);
	@Autowired
	protected JdbcTemplate jdbcTemplate;

	/**
	 * 資料庫新增操作
	 * 
	 * @param bean 新增實體類物件
	 * @return
	 */
	public int insert(T bean) throws Exception {
		Class<T> beanClass = (Class<T>) bean.getClass();
		Map<String, Object> map = FrameWorkUtils.entityToMap(bean);
		StringBuffer sql = new StringBuffer();
		List<Object> parameter = new ArrayList<Object>();
		String tableName = FrameWorkUtils.camelToUnderline(bean.getClass().getSimpleName());
		System.err.println("資料庫的表名為：" + tableName);
		sql.append("INSERT INTO " + tableName + "(");
		Set<Entry<String, Object>> entrySet = map.entrySet();
		for (Entry<String, Object> entry : entrySet) {
			sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + ",");
		}
		sql.deleteCharAt(sql.length() - 1);
		sql.append(") VALUES(");
		for (Entry<String, Object> entry : entrySet) {
			sql.append("?,");
			parameter.add(entry.getValue());
		}
		sql.deleteCharAt(sql.length() - 1);
		sql.append(")");
		logger.info("新增操作SQL【" + sql.toString() + "】");
		logger.info("新增操作引數【" + parameter + "】");
		return jdbcTemplate.update(sql.toString(), parameter.toArray());
	}

	/**
	 * 
	 * 資料庫刪除操作
	 * 
	 * @param bean 刪除實體類物件
	 * @return
	 */
	public int delete(T bean) {
		Class<T> beanClass = (Class<T>) bean.getClass();
		Map<String, Object> map = FrameWorkUtils.entityToMap(bean);
		StringBuffer sql = new StringBuffer();
		List<Object> parameter = new ArrayList<Object>();
		String tableName = beanClass.getSimpleName();
		tableName = FrameWorkUtils.camelToUnderline(tableName);
		sql.append("DELETE FROM " + tableName);
		sql.append(" WHERE 1=0 OR ");
		Set<Entry<String, Object>> entrySet = map.entrySet();
		for (Entry<String, Object> entry : entrySet) {
			if (entry.getValue() != null) {
				sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + "=? AND");
				parameter.add(entry.getValue());
			}
		}
		sql.delete(sql.length() - 3, sql.length());
		logger.info("刪除操作SQL【" + sql.toString() + "】");
		logger.info("刪除操作引數【" + parameter + "】");
		return jdbcTemplate.update(sql.toString(), parameter.toArray());
	}

	/**
	 * 
	 * 資料庫修改操作
	 * 
	 * @param bean 更新實體類物件
	 * @return
	 * @throws Exception
	 */
	public int update(T bean) throws Exception {
		Class<T> beanClass = (Class<T>) bean.getClass();
		Map<String, Object> map = FrameWorkUtils.entityToMap(bean);
		StringBuffer sql = new StringBuffer();
		List<Object> parameter = new ArrayList<Object>();
		String tableName = FrameWorkUtils.camelToUnderline(beanClass.getSimpleName());
		String primaryKey = FrameWorkUtils.getPrimKeyByNameTableName(jdbcTemplate.getDataSource().getConnection(),
				tableName).toUpperCase();
		sql.append("UPDATE " + tableName + " SET ");
		Set<Entry<String, Object>> entrySet = map.entrySet();
		for (Entry<String, Object> entry : entrySet) {
			if (primaryKey.equals(FrameWorkUtils.camelToUnderline(entry.getKey()))) {
				continue;
			} else if (entry.getValue() != null) {
				sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + "=?,");
				parameter.add(entry.getValue());
			}
		}
		sql.deleteCharAt(sql.length() - 1);
		sql.append(" where " + primaryKey + "=? ");
		parameter.add(map.get(FrameWorkUtils.underlineToCamel(primaryKey)));
		logger.info("修改操作SQL【" + sql.toString() + "】");
		logger.info("修改操作引數【" + parameter + "】");
		return jdbcTemplate.update(sql.toString(), parameter.toArray());
	}

	/**
	 * 
	 * 資料庫查詢多個物件操作
	 * 
	 * @param bean 查詢實體類物件
	 * @return
	 * @throws Exception
	 */
	public List<T> queryList(T bean) throws Exception {
		Class<T> beanClass = (Class<T>) bean.getClass();
		Map<String, Object> map = FrameWorkUtils.entityToMap(bean);
		StringBuffer sql = new StringBuffer();
		List<Object> parameter = new ArrayList<Object>();
		String tableName = bean.getClass().getSimpleName();
		tableName = FrameWorkUtils.camelToUnderline(tableName);
		sql.append("SELECT ");
		Set<Entry<String, Object>> entrySet = map.entrySet();
		for (Entry<String, Object> entry : entrySet) {
			sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + ",");
		}
		sql.deleteCharAt(sql.length() - 1);
		sql.append(" FROM " + tableName);
		sql.append(" WHERE 1=1 AND ");
		for (Entry<String, Object> entry : entrySet) {
			if (entry.getValue() != null) {
				if (entry.getValue().getClass() == String.class) {
					//String型別全部模糊查詢處理
					sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + " LIKE ? AND ");
					parameter.add("%" + entry.getValue() + "%");
				} else{
					//其餘型別暫不處理
					sql.append(FrameWorkUtils.camelToUnderline(entry.getKey()) + "=? AND ");
					parameter.add(entry.getValue());
				}
			}
		}
		sql.delete(sql.length() - 4, sql.length());
		logger.info("查詢操作SQL【" + sql.toString() + "】");
		logger.info("查詢操作引數【" + parameter + "】");
		return jdbcTemplate.query(sql.toString(), parameter.toArray(), new BeanPropertyRowMapper<T>(beanClass));
	}
	/**
	 * 萬能的SQL執行平臺
	 * @param bean	實體類物件
	 * @param execute	執行物件
	 * @return
	 */
	public Object execute(T bean,JdbcExecute execute){
		return execute.execute(jdbcTemplate, bean);
	}
}

 
package com.msw.framework.utils;

import java.lang.reflect.Field;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.commons.lang3.StringUtils;

public class FrameWorkUtils {
	/**
	 * 駝峰轉下劃線
	 * 
	 * @return
	 */
	public static String camelToUnderline(String line) {
		if (StringUtils.isBlank(line)) {
			return "";
		} else {
			line = String.valueOf(line.charAt(0)).toUpperCase().concat(line.substring(1));
			StringBuffer sb = new StringBuffer();
			Pattern pattern = Pattern.compile("[A-Z]([a-z\\d]+)?");
			Matcher matcher = pattern.matcher(line);
			while (matcher.find()) {
				String word = matcher.group();
				sb.append(word.toLowerCase());
				sb.append(matcher.end() == line.length() ? "" : "_");
			}
			return sb.toString().toUpperCase();
		}
	}
	/**
	 * 下劃線轉駝峰
	 * 
	 * @return
	 */
	public static String underlineToCamel(String line) {
		if (StringUtils.isBlank(line)) {
			return "";
		} else {
			StringBuffer sb = new StringBuffer();
			String[] words = line.split("_");
			for (String word:words) {
				word = word.toLowerCase();
				word = String.valueOf(word.charAt(0)).toUpperCase().concat(word.substring(1));
				sb.append(word);
			}
			return sb.replace(0, 1, String.valueOf(sb.charAt(0)).toLowerCase()).toString();
		}
	}

	/**
	 * javaBean轉Map
	 * 
	 * @param bean
	 * @return
	 */
	public static Map<String, Object> entityToMap(Object entity) {
		Map<String, Object> map = new LinkedHashMap<String, Object>();
		Field[] fields = entity.getClass().getDeclaredFields();
		for (Field field : fields) {
			field.setAccessible(true);
			Object object = null;
			try {
				object = field.get(entity);
			} catch (Exception e) {
				e.printStackTrace();
			}
			map.put(field.getName(), object);
		}
		return map;
	}
	/**
	 * 根據資料庫表名獲取主鍵名稱
	 * @param connection 資料庫連線控制代碼
	 * @param tableName	表名
	 * @return
	 */
	public static String getPrimKeyByNameTableName(Connection connection,String tableName) {
		String primkey = null;
		try {
			ResultSet rs = connection.getMetaData().getPrimaryKeys(connection.getCatalog(), null, tableName.toUpperCase());
			while (rs.next()) {
				primkey = rs.getString("COLUMN_NAME");
			}
		} catch (SQLException e1) {
			try {
				connection.close();
			} catch (SQLException e) {
			}
		}
		return primkey;
	}
}

 

相關推薦

BaseDAO增刪改查通用程式碼

實習已經兩三個月了，在這兩三個月中見到了很多以前沒有見到過的東西，也學到了很多的東西。其中，我覺得最神奇的地方就是我們公司的框架了，在學校的時候以為所有程式碼都是要手寫的，但是萬萬沒想到很多通用的程式碼竟然可以提取出來自動生成!!!   正好馬上要開始做畢業設計了，我準備自己也把通

使用JDBC連線MySQL資料庫並且完成增刪改查完整程式碼

完整路徑截圖： **//BaseDao.java檔案** package cn.utils; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement

JDBC增刪改查示例程式碼

首先使用如下SQL語句生成一個users表 create table users( id int primary key auto_increment, name varchar(40), password varchar(40), email va

mysql資料庫的連線以及增刪改查Java程式碼實現（Statement版）

資料庫： create table t1(id int primary key not null auto_increment,name varchar(32),password varchar(32)); insert into t1(name,password) va

mysql資料庫的連線以及增刪改查Java程式碼實現（PreparedStatement版）

資料庫： create table t1(id int primary key not null auto_increment,name varchar(32),password varchar(32)); insert into t1(name,password) v

QT5下SQLite的增刪改查示例程式碼

Author: Kagula Date: 2016-8-10 Envrionment: Qt 5.6 Introduction:    從專案中抽出來的如何操作sqlite的程式碼，這裡記下，免得時間久忘記了。 測試示例程式碼 void MainWindow::OnAd

Laravel增刪改查例項程式碼講解

1、表單提交(增) (1)配置路由web.php Route::post('/projects', '[email protected]')->name('project.store'); (2)html模板檔案裡這樣寫，提交到name=projects.update的路由 {{

Java中增刪改查通用方法。

public class BaseDAO { private static final String DRIVER = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; private static final String URL = "jdbc:sqlserv

EF6 簡單增刪改查示例程式碼

private DbContext _dbContext; public DbContext CurrentContext { get { if (_dbContext ==

php增刪改查示例程式碼

增刪改查是對資料庫最基本的操作，如何連線資料庫以及增刪改查等等相關知識。 1.連結資料庫通用方法：conn.php <?php //第一步：連結資料庫 [email protected]_connect("localhost:3306","root","

利用JDBC連線MySQL資料庫並實現增刪改查的程式碼示例

一、實現增刪改： 比較簡單： import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement;

C#連線資料庫增刪改查程式碼 SQL SERVER/ACCESS 通用類

using System.Data.OleDb; using System.Data; public static class DataTools { private static OleDbConnection oleCo

通用增刪改查

entity use manager final resultset obi array ace code 鏈接數據庫接口 package com.db; import java.sql.Connection; import java.sql.PreparedSta

通用mapper的增刪改查方法 留存 備忘

you 匹配 trac depend 復雜 字符串類 camel param oda Mybatis通用Mapper介紹與使用 前言 使用Mybatis的開發者，大多數都會遇到一個問題，就是要寫大量的SQL在xml文件中，除了特殊的業務邏輯SQL之外，還

PHP程式碼之增刪改查

新增資料（重點） 用PDO類中的exec方法來執行insert語句，成功返回受影響的行數，失敗返回false。 exec是單詞execute的簡寫。執行的意思。 刪除和修改資料（重點） 仍然使用的是PDO類中的exec方法。成功返回受影響的行數，失敗返回false。

EF學習筆記——通用增刪改查方案

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

java DMO及增刪改查程式碼的自動生成

之前我考慮過多種自動生成程式碼的提供方式，比如web的方式，通過在頁面文字框裡面輸入各種引數，比如模板檔案地址，生成檔案地址，資料庫名，資料庫使用者名稱和密碼等，點選生成按鈕就可以生成原始碼檔案。但這樣需要部署啟動這個web程式。使用java的圖形使用者介面，但我對java圖形的相關API並不瞭解，

告別編寫基礎的增刪改查程式碼

  　　告別編寫基礎的增刪改查程式碼    一、 說明 　　1.本文基本幫你實現不用編寫基礎的增刪改查程式碼 注意是“基礎”的，你只需要寫一個實體類，其他都可以自動生成包括 mapper、dao、service、controller、建表sql。   &nbs

Java Web--增刪改查之二介面後臺java程式碼（轉載參考）

/**  *   */ /**  * @author Administrator  *  */ package dao; import java.sql.*; public

spring data jpa之資料增刪改查程式碼優化

Spring data jpa為減少查詢資料庫次數,先將符合條件的資料查出來，返回的是一個list集合，遍歷集合將資料裝入map中，根據需要設定key,value,然後判斷map是否包含某個key或者value以此判斷資料是否在資料庫中已經存在。這樣減少了訪問資料庫的次數，減小了伺服器壓力，將大部分