通用增刪改查

阿新 • • 發佈：2017-11-27

entity use manager final resultset obi array ace code

鏈接數據庫接口

package com.db;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;

public interface DBConn {

    Connection getConn();
    
    public void close(Connection con);
    public void close(PreparedStatement pstmt);
    public 
 void close(ResultSet rs);
    public void close(Statement stmt);
    public void closeAll(ResultSet rs,PreparedStatement pstmt,Connection con);
}

鏈接數據庫

package com.db.impl;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import 
 java.sql.Statement;

import com.db.DBConn;


public class DBConnJdbc implements DBConn{
    
    private String driver="com.mysql.jdbc.Driver";
    private String url="jdbc:mysql://localhost:3306/ebook?useUnicode=true&characterEncoding=utf-8";
    private String user = "root";
    private String password = "11111";
    
     
public Connection getConn(){
        Connection con = null;
        try{
            Class.forName(driver);
            con=DriverManager.getConnection(url,user,password);            
        }catch(Exception e){
            e.printStackTrace();
        }
        return con;
    }
    
    public void close(Connection con){
        try{
            if(con != null){
                con.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    public void close(PreparedStatement pstmt){
        try{
            if(pstmt != null){
                pstmt.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    public void close(ResultSet rs){
        try{
            if(rs != null){
                rs.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    public void close(Statement stmt){
        try{
            if(stmt != null){
                stmt.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }

    
    public void closeAll(ResultSet rs,PreparedStatement pstmt,Connection con) {
        try {
            if(rs != null) {
                rs.close();
                rs = null;
            }
            if(pstmt != null) {
                pstmt.close();
                pstmt = null;
            }
            if(con != null) {
                con.close();
                con = null;
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
}

View Code

package com.db.impl;

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Properties;

import com.db.DBConn;

public class DBConnJdbcProp implements DBConn{

    private static Properties prop = new Properties();
    

    static{
        InputStream in = null;
        Class c = DBConnJdbcProp.class;
        ClassLoader loader = c.getClassLoader();
        in = loader.getResourceAsStream("jdbc.properties");
        try {
            prop.load(in);
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            try {
                if(in != null){            
                in.close();
                }
            } catch (IOException e) {
                e.printStackTrace();            
            }
        }    
    }
    
    @Override
    public Connection getConn(){
        String driver = prop.getProperty("driver");
        String url = prop.getProperty("url");
        String user = prop.getProperty("user");
        String password = prop.getProperty("password");        
        Connection con = null;
        try{
            Class.forName(driver);
            con=DriverManager.getConnection(url,user,password);            
        }catch(Exception e){
            e.printStackTrace();
        }
        return con;
    }

    @Override
    public void close(Connection con){
        try{
            if(con != null){
                con.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void close(PreparedStatement pstmt){
        try{
            if(pstmt != null){
                pstmt.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void close(ResultSet rs){
        try{
            if(rs != null){
                rs.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }
    
    @Override
    public void close(Statement stmt){
        try{
            if(stmt != null){
                stmt.close();
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
    }

    @Override
    public void closeAll(ResultSet rs, PreparedStatement pstmt, Connection con) {
        try {
            if(rs != null) {
                rs.close();
                rs = null;
            }
            if(pstmt != null) {
                pstmt.close();
                pstmt = null;
            }
            if(con != null) {
                con.close();
                con = null;
            }
        }catch(Exception e) {
            e.printStackTrace();
        }
        
    }    
}

View Code

BaseDao

package com.dao;

import java.util.List;

public interface BaseDao<Entity> {
    
    public int add(Entity obj) throws Exception;
    public int delete(int id) throws Exception;
    public int update(Entity obj) throws Exception;
    public Entity get(int id) throws Exception;
    public List<Entity> getList() throws Exception;
    
}

View Code

package com.dao.impl;

import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import com.dao.BaseDao;
import com.db.DBConn;
import com.db.impl.DBConnJdbc;

public class BaseDaoImpl<Entity> implements BaseDao<Entity>{

    DBConn db = new DBConnJdbc();
    int r=0;
    private Class clazz;
    
    public BaseDaoImpl(){
        clazz = this.getClass();
        Type t = clazz.getGenericSuperclass();
        ParameterizedType pe = (ParameterizedType) t;
        clazz = (Class) pe.getActualTypeArguments()[0];
        System.out.println(clazz);
    }
    
    //添加
    @Override
    public int add(Entity obj) throws Exception {
        
        Connection con = db.getConn();
        String tables = clazz.getSimpleName();
        Field[] fields = clazz.getDeclaredFields();

        String sql = "insert into " + tables + " values(null";
        for (int i = 1; i < fields.length; i++) {
            sql += ",?";
        }
        sql = sql + ")";

        System.out.println(sql);
        PreparedStatement pstmt = null;
        pstmt = con.prepareStatement(sql);

        for (int i = 1; i < fields.length; i++) {
            String name= "get"+Character.toUpperCase(fields[i].getName().charAt(0));
            name = name + fields[i].getName().substring(1);
            Method m =clazz.getMethod(name);
            Object value= m.invoke(obj);        
            pstmt.setObject(i, value);
        }
        r=pstmt.executeUpdate();
        db.close(pstmt);
        db.close(con);
        return r;
        
    }

    //刪除
    @Override
    public int delete(int id) throws Exception {
        Connection con = db.getConn();
        String tables = clazz.getSimpleName();
        Field[] fields = clazz.getDeclaredFields();
        
        String idName = fields[0].getName();
        
        String sql = "delete  from " + tables + " where "+idName+" ="+id;
        System.out.println(sql);
        PreparedStatement pstmt = null;
        pstmt = con.prepareStatement(sql);
        r=pstmt.executeUpdate();
        db.close(pstmt);
        db.close(con);
        return r;
        
    }

    //更新
    @Override
    public int update(Entity obj) throws Exception {
        Connection con = db.getConn();
        String tables = clazz.getSimpleName();
        String sql = "update "+tables+" set ";
        Field[] fields = clazz.getDeclaredFields();
        
        String idName = fields[0].getName();
        
        for(int i=1;i<fields.length;i++){
            sql += fields[i].getName() + "=?,";
        }
        sql = sql.substring(0,sql.length()-1)+" where "+idName+" = ?";
        System.out.println(sql);
        PreparedStatement pstmt = null;
        pstmt = con.prepareStatement(sql);
        for(int i =1;i<fields.length;i++){
            String methodName = "get"+Character.toUpperCase(fields[i].getName().charAt(0))+fields[i].getName().substring(1);
            Method m = clazz.getMethod(methodName);
            pstmt.setObject(i,m.invoke(obj));
        }
        
        String FiledFirstName = "get"+Character.toUpperCase(fields[0].getName().charAt(0))+fields[0].getName().substring(1);
        Method m2 = clazz.getMethod(FiledFirstName);
        pstmt.setInt(fields.length, (Integer)m2.invoke(obj));
        r=pstmt.executeUpdate();
        db.close(pstmt);
        return r;        
    }

    //根據id查詢
    @Override
    public Entity get(int id) throws Exception {
        Connection con = db.getConn();
        
        Field[] fields = clazz.getDeclaredFields();
        String idName = fields[0].getName();
        
        String sql = "select * from "+clazz.getSimpleName() + " where "+idName+" =" +id;
        System.out.println(sql);
        PreparedStatement pstmt = null;
        pstmt = con.prepareStatement(sql);
        ResultSet rs = pstmt.executeQuery();
        Entity entity =(Entity) clazz.newInstance();
        if(rs.next()){
            //Field[] fields = clazz.getDeclaredFields();
            for(int i=0;i<fields.length;i++){
                String methodName = "set" +Character.toUpperCase(fields[i].getName().charAt(0))+fields[i].getName().substring(1);
                Method m = clazz.getDeclaredMethod(methodName, fields[i].getType());
                Object value = rs.getObject(fields[i].getName());
                System.out.println(methodName + "=========" + value);
                m.invoke(entity, value);
            }
        }
        db.closeAll(rs, pstmt, con);
        return entity;
    }

    //全查
    @Override
    public List<Entity> getList() throws Exception {
        Connection con = db.getConn();
        String sql = "select * from "+clazz.getSimpleName();
        PreparedStatement pstmt = null;
        pstmt = con.prepareStatement(sql);
        List<Entity> list = new ArrayList<Entity>();
        ResultSet rs = pstmt.executeQuery();
        while(rs.next()){
            Entity entrty = (Entity)clazz.newInstance();
            Field[] fields = clazz.getDeclaredFields();
            for(int i=0;i<fields.length;i++){
                String methodName = "set"+Character.toUpperCase(fields[i].getName().charAt(0))+fields[i].getName().substring(1);
                Method m = clazz.getMethod(methodName, fields[i].getType());
                m.invoke(entrty, rs.getObject(fields[i].getName()));
            }
            list.add(entrty);
        }
        System.out.println(sql);
        db.closeAll(rs, pstmt, con);
        return list;
    }

}

View Code

登錄

package com.dao;

import com.entity.Person_info;

public interface Person_infoDao extends BaseDao<Person_info>{

    public boolean login(Person_info obj);
    public Person_info getLogin(String login_name);
}

View Code

package com.dao.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import com.dao.Person_infoDao;
import com.db.DBConn;
import com.db.impl.DBConnJdbcProp;
import com.entity.Person_info;


public class Person_infoDaoImpl extends BaseDaoImpl<Person_info> implements Person_infoDao{
    
    //用戶登錄
    @Override
    public boolean login(Person_info obj) {
        
        boolean blean = false;
        String sql ="select *from person_info where login_name =? and password=?";
        DBConn db = new DBConnJdbcProp();
        Connection con = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try{
            con=db.getConn();
            pstmt=con.prepareStatement(sql);
            pstmt.setString(1,obj.getLogin_name());
            pstmt.setString(2,obj.getPassword());
            rs = pstmt.executeQuery();
            
            while(rs.next()){
                int user_id = rs.getInt("user_id");
                obj.setUser_id(user_id);;
                if(user_id>0){
                    blean = true;
                }        
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            db.close(con);
            db.close(pstmt);
            db.close(rs);
        }                
        return blean;
    }

    @Override
    public Person_info getLogin(String login_name) {
        
        String sql ="select *from person_info where login_name =‘"+login_name+"‘";
        DBConn db = new DBConnJdbcProp();
        Connection con = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        
        Person_info pi = new Person_info();
        try {
            con = db.getConn();
            pstmt = con.prepareStatement(sql);
            rs = pstmt.executeQuery();
            while(rs.next()){
                pi.setUser_id(rs.getInt("user_id"));
                pi.setLogin_name(rs.getString("login_name"));
                pi.setPassword(rs.getString("password"));
                pi.setPost_id(rs.getInt("post_id"));
                pi.setOther(rs.getString("other"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            db.closeAll(rs, pstmt, con);
        }
        return pi;
        
        
    }

}

View Code

登錄Biz

package com.biz;

import java.util.List;

import com.entity.Person_info;

public interface Person_infoBiz {

    Person_info login(Person_info obj);
    int add(Person_info obj);
    int update(Person_info obj);
    Person_info getLogin(String login_name);
    
    Person_info get(int id);
    List<Person_info> getList();
    
}

View Code

package com.biz.impl;

import java.util.List;

import com.biz.Person_infoBiz;
import com.dao.Person_infoDao;
import com.dao.impl.Person_infoDaoImpl;
import com.entity.Person_info;

public class Person_infoBizImpl implements Person_infoBiz{

    Person_infoDao dao = new Person_infoDaoImpl();
    
    @Override
    public Person_info login(Person_info obj) {
        dao.login(obj);
        return obj;
    }

    @Override
    public int add(Person_info obj) {
        int rs = 0;
        try{
            rs=dao.add(obj);
        }catch(Exception e){
            rs = 0;
            e.printStackTrace();            
        }
        return rs;
    }

    @Override
    public int update(Person_info obj) {
        int rs = 0;
        try {
            rs=dao.update(obj);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return rs;    
    }

    @Override
    public Person_info getLogin(String login_name) {
        
        return dao.getLogin(login_name);
    }

    @Override
    public Person_info get(int id) {
        
        Person_info pi = null;
        try {
            pi = dao.get(id);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return pi;
    }

    @Override
    public List<Person_info> getList() {
        List<Person_info> list = null;
        try {
            list = dao.getList();
        } catch (Exception e) {
            e.printStackTrace();
        }
        return list;
    }
}

View Code

通用增刪改查

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

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

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

【PHP學習筆記】原生PHP操作MySQL（附錄通用增刪改查函式封裝）

PHP的全域性函式簡直好用的不要不要的（怪不得PHP是最好的語言沒有之一）

Sql通用增刪改查帶引數方法

引子：由於現在資料庫安全的關注越來越多，sql注入幾乎是絕對忽略的一環，sql語句帶引數就相對安全一些，但是平常的一些查詢語句帶引數，寫的較為繁瑣，於是就想如何能夠節省工作量，便做了一個通用中間庫，希望能有所幫助(盜版了我同事的程式碼)。原理：利用T entity的反射拼

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

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

BaseDAO增刪改查通用程式碼

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

Java Maven專案：spring boot + Mybatis連線MySQL，通用mapper的增刪改查，對映實現多表查詢

1. MySQL自帶庫test新增表user、role 角色表role 使用者表user 2. 新增依賴，配置屬性相關依賴：百度即可，此處略 application.properties spring.application.name=clean-exe

通用DAO之MyBatis封裝，封裝通用的增刪改查（三）

曾將釋出過倆篇關於Mybatis封裝的文章，當時曾曾承諾過當測試沒有問題後阿海會整理一下然後將原始碼釋出出來。那麼今天正好朋友找我要一份那套mybatis封裝的原始碼，我便整理了一份，想想這麼長時間了並沒有發現什麼明顯的bug，於是決定將它發出來。關

Java中增刪改查通用方法。

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

通用DAO之MyBatis封裝，封裝通用的增刪改查（一）

曾經用過同事的一個基於Hibernate的通用增刪改查框架，當時我的感覺相方便，簡直是開發小型專案的不二選擇，並且那個‘框架’也做為了當時公司裡的標準。膜拜歸膜拜，勤於鑽研善學善用是鞭長一族的傳統美德！作為鞭長創始人阿海，我認為膜拜的同時更有必要將其技術學為己用。還好Eclipse中帶有一個反編譯的外

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

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

自己編寫的 entity framwork 6 通用 dal 類增刪改查多分類欄位

public class BaseDAL<T> where T : class,new() { string strConn = ""; public BaseDAL(string connString)

SSM 整合開發+通用的增刪改查實現

前一段時間開發java web專案都是採用的SSH框架，開發中發現在使用Hibernate做持久層開發的時候用法不夠靈活，過於笨重，因此，改用MyBaties，結合Spring、SpringMvc框架，現將配置過程梳理如下：一、專案結構

TP5學習基礎一：增刪改查小demo

表單 arr 處理 php req 學習 model類浪費新手 ①TP5--增刪改查簡單的demo 我先吐槽一下：因為工作需要研究tp5，去官網看了一下哎呦，資源挺多挺全啊！然後下載唯一免費的官方教程，我曹pdf打開533頁。講的很細但是開發能等看完才做嗎？看到精簡版快

Python 3 Mysql 增刪改查

data log utf8 upd lba create pytho int 參數 import pymysql import datainfo import time #獲取參數 host = datainfo.host username = datainf

MongoDB增刪改查操作詳解

添加多個負數指定 cal lib 定位也會 pan str 一、插入 MongoDB的插入操作很簡單，使用insert方法，這裏演示從創建數據庫、創建集合到插入文檔、查詢文檔。集合創建方法參數說明： size：集合最大空間 max：集合最多文檔數量（超出si

JqueryEasyUI實現CRUD增刪改查操作

per queryall call .get field string cal upd wid 1.代碼介紹：前端界面由jsp,JqueryEasyUI制作，後臺代碼由Servlet實現邏輯操作註：JqueryEasyUI的庫文件和其他自己jar包自己導入。Jquery

yii2 框架的 AR 和 DAO 增刪改查

寫法 mod sar 增刪改查 title isn function rec 自己自己做個總結方便以後查找使用 /** * yii 的增刪改查 */ //增 public function add1($data) {

（六）Hibernate的增刪改查操作（2）

rac result jlist static 面向原生 comm public set 一、在Hibernate中使用原生SQL語句 sql語句面向的是數據庫，所以sql語句中對應的不再是bean了，比如sql="select * from user" 在hql中

go語言筆記——切片函數常見操作，增刪改查和搜索、排序

通過學習 strings 完整官方文檔二分 func fun 必須 7.6.6 搜索及排序切片和數組標準庫提供了 sort 包來實現常見的搜索和排序操作。您可以使用 sort 包中的函數 func Ints(a []int) 來實現對 int 類型的切片排序。例如

通用增刪改查

相關推薦