自定義持久層框架

来源:https://www.cnblogs.com/wangshaoyun/archive/2022/04/29/16205105.html
-Advertisement-
Play Games

Spring Boot 1 Spring Boot入門 1.1 Spring Boot特性： 能夠快速創建基於 Spring 的應用程式 能夠直接使用 java main 方法啟動內嵌的 Tomcat 伺服器運行 Spring Boot 程式，不需 要部署 war 包文件 提供約定的 starter ...



自定義持久層框架

下圖是JDBC引起的一系列問題以及解決辦法：

 

 

自定義持久層框架設計思路：

使用端（項目）：引入自定義持久層框架jar包。

提供兩部分配置信息：1，資料庫配置信息；2，sql配置信息--（sql語句、參數類型、返回值類型）
解決辦法：使用配置文件來提供兩部分配置信息：
<1>sqlMapConfig.xml：放資料庫配置信息；在sqlMapConfig.xml中，其實也可以存放mapper.xml的全路徑，方法getResourceAsSteam()可以一次性全部讀取；
<2>mapper.xml：存放sql配置信息；

自定義持久層框架本身(工程)：本質上就是對JDBC代碼進行了封裝。

(1)載入配置文件,根據配置文件的路徑，載入配置文件成位元組輸入流，存儲在記憶體中；
    創建Resource類 
        方法：getResourceAsSteam(String path)返回 InputSteam；
(2)創建兩個javaBean（容器對象）：存放的就是對配置文件解析出來的內容，如下：
    Configruation核心配置類：存放sqlMapConfig.xml解析出來的內容；
    MappedStatement映射配置類:存放mapper.xml解析出來的內容；    
(3)解析配置文件,可以採用dom4j對配置文件進行解析；
    創建類：SqlSessionFactoryBuilder，方法：build（InputSteam is）
        <1>使用dom4j解析配置文件，將解析出來的內容封裝到容器對象中；
        <2>創建SqlSessionFactory對象；主要作用就是利用工廠模式生產sqlSession（會話對象）
(4)基於開閉原則創建SqlSessionFactory介面及實現類DefaultSqlSessionFactory
    <1>生產sqlSession【openSqlSession()】
(5)創建SqlSession介面及實現類DefaultSession
 定義對資料庫的crud操作：selectList()selectOne()update()delete()
(6)創建Exeutor介面及實現類SimpleExeutor實現類，執行的就是JDBC代碼；
    query(Configruation，MappedStatement，Object ... params);

 

創建兩個maven工程IPersistence和IPersistence_test

--IPersistence_test引入IPersistence依賴--
​
     <groupId>com.yun</groupId>
    <artifactId>IPersistence_test</artifactId>
    <version>1.0-SNAPSHOT</version>
​
    <!--引入自定義持久層框架依賴-->
    <dependencies>
        <dependency>
            <groupId>com.yun</groupId>
            <artifactId>IPersistence</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
--IPersistence_test-->sqlMapConfig.xml--
<configuration>
    <!--資料庫配置信息-->
    <dataSource>
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://xxx.xxx.xx.xxx:xxxx/xxxx"></property>
        <property name="username" value="xxxx"></property>
        <property name="password" value="xxxx"></property>
    </dataSource>

    <!--存放mapper.xml的全路徑-->
    <mapper resource="userMapper.xml"></mapper>

</configuration>
--IPersistence_test-->userMapper.xml--
<mapper namespace="user">

    <!--sql的唯一標識應該是由 namespace.id來組成（statementId）-->
    <select id="selectList" resultType="com.yun.pojo.User">
        select * from user
    </select>

    <!--利用反射獲取到user對象的參數-->
    <select id="selectOne" resultType="com.yun.pojo.User" paramterType="com.yum.pojo.User">
        select * from user where id = #{id} and username = #{username}
    </select>

</mapper>
--IPersistence--
@Data
public class MappedStatement {

    //id
    private Integer id;

    //返回值類型
    private String resultType;

    //參數值類型
    private String paramterType;

    //sql語句
    private String sql;
}
--IPersistence--
@Data
public class Configuration {

    private DataSource dataSource;

    /**
     * k:statementId
     * v:封裝好的MappedStatement對象
     */
    Map<String,MappedStatement> map = new HashMap<>();
}

按照設計思路編寫代碼

--解析配置文件返迴流
public class Resources {

    /**
     * 根據配置文件的路徑，將配置文件載入成位元組輸入流，存儲在記憶體中
     * @param path
     * @return
     */
    public static InputStream getResourcesAsSteam(String path){
        InputStream resourceAsStream = Resources.class.getClassLoader().getResourceAsStream(path);
        return resourceAsStream;
    }

}
@Data
public class Configuration {

    private DataSource dataSource;

    /**
     * k:statementId
     * v:封裝好的MappedStatement對象
     */
    Map<String,MappedStatement> map = new HashMap<>();

}
@Data
public class MappedStatement {

    //id
    private String id;

    //返回值類型
    private String resultType;

    //參數值類型
    private String paramterType;

    //sql語句
    private String sql;
}
--將解析的流封裝到SqlSessionFactoryBuilder中
public class SqlSessionFactoryBuilder {

    public SqlSessionFactory build(InputStream is) throws Exception {
        //1，使用dom4j解析配置文件，將解析出來的內容封裝到Configuration中
        XmlConfigBuilder xmlConfigBuilder = new XmlConfigBuilder();
        Configuration configuration = xmlConfigBuilder.parseConfig(is);

        //2，創建sqlSessionFactory對象,工廠類:生產sqlSession繪畫對象
        DefaultSqlSessionFactory defaultSqlSessionFactory = new DefaultSqlSessionFactory(configuration);

        return defaultSqlSessionFactory;
    }
}
--將sqlMapConfig.xml和userMapper.xml流放入configuration中
public class XmlConfigBuilder {

    private Configuration configuration;

    public XmlConfigBuilder() {
        this.configuration = new Configuration();
    }

    /**
     * 該方法就是使用dom4j將配置文件解析，封裝Configuration
     * @param is
     * @return
     */
    public Configuration parseConfig(InputStream is) throws Exception {

        Document document = new SAXReader().read(is);
        //獲取Configuration根對象<Configuration>
        Element rootElement = document.getRootElement();
        //獲取sqlMapConfig.xml裡面的配置信息並且遍歷
        List<Element> list = rootElement.selectNodes("//property");
        Properties properties = new Properties();
        for (Element element : list) {
            String name = element.attributeValue("name");
            String value = element.attributeValue("value");
            properties.setProperty(name,value);
        }

        //創建 c3p0 連接池
        ComboPooledDataSource comboPooledDataSource = new ComboPooledDataSource();
        comboPooledDataSource.setDriverClass(properties.getProperty("driverClass"));
        comboPooledDataSource.setJdbcUrl(properties.getProperty("jdbcUrl"));
        comboPooledDataSource.setUser(properties.getProperty("username"));
        comboPooledDataSource.setUser(properties.getProperty("password"));

        configuration.setDataSource(comboPooledDataSource);

        //mapper.xml解析 步驟：拿到路徑-->載入成位元組輸入流-->dom4j進行解析
        List<Element> mapperList = rootElement.selectNodes("//mapper");

        for (Element element : mapperList) {
            String mapperPath = element.attributeValue("resource");
            InputStream resourcesAsSteam = Resources.getResourcesAsSteam(mapperPath);
            XmlMApperBuilder xmlMApperBuilder = new XmlMApperBuilder(configuration);
            xmlMApperBuilder.prase(resourcesAsSteam);
        }

        return configuration;
    }
}

public class XmlMApperBuilder {

    private Configuration configuration;

    public XmlMApperBuilder(Configuration configuration) {
        this.configuration = configuration;
    }

    public void prase(InputStream is) throws Exception {
        Document document = new SAXReader().read(is);
        Element rootElement = document.getRootElement();
        String namespace = rootElement.attributeValue("namespace");

        List<Element> list = rootElement.selectNodes("//select");
        for (Element element : list) {
            String id = element.attributeValue("id");
            String resultType = element.attributeValue("resultType");
            String paramterType = element.attributeValue("paramterType");
            String sqlText = element.getTextTrim();

            MappedStatement mappedStatement = new MappedStatement();
            mappedStatement.setId(id);
            mappedStatement.setResultType(resultType);
            mappedStatement.setParamterType(paramterType);
            mappedStatement.setSql(sqlText);

            //key值是由 namespace.id來組成
            String key = namespace +"."+id;
            configuration.getMap().put(key,mappedStatement);
        }
    }
}
--利用工廠模式生產sqlSession
public class DefaultSqlSessionFactory implements SqlSessionFactory{

    private Configuration configuration;

    public DefaultSqlSessionFactory(Configuration configuration) {
        this.configuration = configuration;
    }

    @Override
    public SqlSession openSession() {
        return new DefaultSqlSession(configuration);
    }
}
@AllArgsConstructor
public class DefaultSqlSession implements SqlSession {

    private Configuration configuration;

    @Override
    public <E> List<E> selectList(String statementId, Object... params) throws Exception {

        //將要去完成對 SimpleExecutor 里的query方法的調用
        SimpleExecutor simpleExecutor = new SimpleExecutor();
        MappedStatement mappedStatement = configuration.getMap().get(statementId);
        List<Object> list = simpleExecutor.query(configuration, mappedStatement, params);

        return (List<E>) list;
    }

    @Override
    public <T> T selectOne(String statementId, Object... params) throws Exception {
        List<Object> objects = selectList(statementId, params);
        if (objects.size() == 1) {
            return (T) objects.get(0);
        } else {
            throw new RuntimeException("查詢結果為空或者返回結果過多");
        }
    }
}
--註冊驅動，查詢數據信息 並且封裝返回
public class SimpleExecutor implements Executor {
    @Override                                                                                 //user
    public <E> List<E> query(Configuration configuration, MappedStatement mappedStatement, Object... params) throws Exception{
        //1,註冊驅動，獲取連接
        Connection connection = configuration.getDataSource().getConnection();

        //2,獲取sql    select * from user where id = #{id} and username = #{username}
          //轉換sql    select * from user where id = ? and username = ?,轉換過程中，還需要對#{}裡面的值進行存儲解析
        String sql = mappedStatement.getSql();

        BoundSql boundSql = getBoundSql(sql);

        //3,獲取預處理對象
        PreparedStatement preparedStatement = connection.prepareStatement(boundSql.getSqlText());

        //4,設置參數
        //獲取到參數的全路徑
        String paramterType = mappedStatement.getParamterType();
        Class<?> paramterTypeClass =  getClassType(paramterType);

        List<ParameterMapping> parameterMappingList = boundSql.getParameterMappingList();
        for (int i = 0; i < parameterMappingList.size(); i++) {
            ParameterMapping parameterMapping = parameterMappingList.get(i);
            String content = parameterMapping.getContent();

            //反射根據content獲取到實體對象中的屬性值，再根據屬性值獲取到當前傳過來的參數對象
            Field declaredField = paramterTypeClass.getDeclaredField(content);
            //暴力訪問
            declaredField.setAccessible(true);
            Object o = declaredField.get(params[0]);

            preparedStatement.setObject(i+1,o);
        }

        //5,執行sql
        ResultSet resultSet = preparedStatement.executeQuery();
        //獲取實體對象
        String resultType = mappedStatement.getResultType();
        Class<?> resultTypeClass = getClassType(resultType);
        //獲取實體對象的具體實現
        Object instance = resultTypeClass.newInstance();

        List<Object> objects = new ArrayList<>();

        //6,封裝返回結果集
        while (resultSet.next()) {
            //1,取出元數據
            ResultSetMetaData metaData = resultSet.getMetaData();
            for (int i = 1; i <= metaData.getColumnCount(); i++) {
                //獲取欄位名
                String columnName = metaData.getColumnName(i);
                //獲取欄位值
                Object value = resultSet.getObject(columnName);
                //使用反射或者內省根據資料庫表和實體的對應關係，完成封裝
                PropertyDescriptor propertyDescriptor = new PropertyDescriptor(columnName, resultTypeClass);
                Method writeMethod = propertyDescriptor.getWriteMethod();
                writeMethod.invoke(instance,value);
            }
            objects.add(instance);
        }

        return (List<E>) objects;
    }

    /**
     * 反射獲取實體
     * @param paramterType
     * @return
     * @throws Exception
     */
    private Class<?> getClassType(String paramterType) throws Exception {
        if (StringUtils.isNullOrEmpty(paramterType)) {
            Class<?> aClass = Class.forName(paramterType);
            return aClass;
        }
        return null;
    }

    /**
     * 完成對#{}的解析工作：1，將#{}使用?進行代替；2，解析出#{}裡面的值進行存儲
     * @param sql
     * @return
     */
    private BoundSql getBoundSql(String sql) {
        //標記處理類：配置標記解析器來完成對占位符的解析處理工作
        ParameterMappingTokenHandler tokenHandler = new ParameterMappingTokenHandler();
        //標記解析器，對占位符的轉換
        GenericTokenParser tokenParser = new GenericTokenParser("#{", "}", tokenHandler);
        //解析出來的sql
        String parseSql = tokenParser.parse(sql);
        //#{}裡面的解析出來的參數名稱
        List<ParameterMapping> parameterMappings = tokenHandler.getParameterMappings();

        BoundSql boundSql = new BoundSql(parseSql,parameterMappings);

        return boundSql;

    }
}

開始測試

public class IPersistenceTest {

    @Test
    public void test() throws Exception {
        //獲取配置文件流
        InputStream resourcesAsSteam = Resources.getResourcesAsSteam("sqlMapConfig.xml");
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourcesAsSteam);
        SqlSession sqlSession = sqlSessionFactory.openSession();

        //調用
        User user = new User();
        user.setId(1);
        user.setUsername("張三");
        User user2 = sqlSession.selectOne("user.selectOne", user);
        System.out.println(user2);
    }
}

結果：

 

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 陰影進階，實現更加的立體的陰影效果！
    CSS 陰影的存在，讓物體看上去更加有型立體。 然而，在最簡單的陰影使用之上，我們可以實現更多有意思且更加立體的陰影效果。 本文將帶大家看看如何使用 CSS 實現幾類比普通陰影更加立體的陰影效果。 CSS 陰影基礎 CSS 中，明面上可以實現陰影的有三個屬性： box-shadow - 盒陰影 te ...
  • JavaScript知識總結 閉包篇
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 1. 對閉包的理解 閉包是指有權訪問另一個函數作用域中變數的函數，創建閉包的最常見的方式就是在一個函數內創建另一個函數，創建的函數可以訪問到當前函數的局部變數。 閉包有兩個常用的用途； 閉包的第一個用途是使我們在函數外部能夠訪問到函數內部 ...
  • JavaScript知識總結 原型篇
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 1. 對原型、原型鏈的理解 在JavaScript中是使用構造函數來新建一個對象的，每一個構造函數的內部都有一個 prototype 屬性，它的屬性值是一個對象，這個對象包含了可以由該構造函數的所有實例共用的屬性和方法。當使用構造函數新建 ...
  • axios口味芝士
    一、一體化運營平臺前端請求部分 1.介面封裝 一體化運營平臺採用的是封裝axios的方式來簡化請求介面的使用，在添加新介面時只要調用封裝好的方法就可以發出請求並直接得到解析後的數據 2.整個過程解析 (1)請求方法調用request方法並傳需要的參數 sync_collect_diff_data(d ...
  • 說一說CSS中的變數
    大家好，我是半夏👴，一個剛剛開始寫文的沙雕程式員.如果喜歡我的文章，可以關註➕ 點贊 👍 加我微信：frontendpicker，一起學習交流前端，成為更優秀的工程師～關註公眾號：搞前端的半夏,瞭解更多前端知識! 點我探索新世界！ 原文鏈接 ==>http://sylblog.xin/archi ...
  • 主流工作流引擎 flowable 三種方式部署流程
    微服務概覽 微服務是圍繞業務領域建模可獨立發佈的服務。服務封裝了對應功能並可以通過網路被其他服務訪問。 從外部來看，單個微服務被視為一個黑盒子。它使用最合適的協議在一個或多個網路端點(例如，隊列或REST API)上承載業務功能。消費者，無論他們是其他微服務還是其他類型的程式，都通過這些聯網的端點來 ...
  • Java 18為什麼要指定UTF-8為預設字元集
    在Java 18中，將UTF-8指定為標準Java API的預設字元集。有了這一更改，依賴於預設字元集的API將在所有實現、操作系統、區域設置和配置中保持一致。 做這一更改的主要目標： 當Java程式的代碼依賴於預設字元集時，使其更具可預測性和可移植性。 闡明標準Java API在哪裡使用預設字元集 ...
  • python-變數、運算符、數據類型
    python 學習筆記 變數、運算符與數據類型 變數 在使用變數前，需要現對其賦值 變數名可以包括字母、數字、下劃線，但不能以字母開頭 python 變數名大小寫是敏感的 first = 2 second = 3 third = first + second print(third) # 5 運算符 ...
一周排行
    -Advertisement-
    Play Games
  • .NET 6 Entity Framework Core Db First（1） 創建模型
    .Net8.0 Blazor Hybird 桌面端 (WPF/Winform) 實測可以完整運行在 win7sp1/win10/win11. 如果用其他工具打包,還可以運行在mac/linux下, 傳送門BlazorHybrid 發佈為無依賴包方式 安裝 WebView2Runtime 1.57 M ...
  • 資料庫升級PostgreSql+Garnet
    目錄前言PostgreSql安裝測試額外Nuget安裝Person.cs模擬運行Navicate連postgresql解決方案Garnet為什麼要選擇Garnet而不是RedisRedis不再開源Windows版的Redis是由微軟維護的Windows Redis版本老舊，後續可能不再更新Garne ...
  • 如何基於surging架設流媒體視頻推流（視頻講解）
    C#TMS系統代碼-聯表報表學習 領導被裁了之後很快就有人上任了，幾乎是無縫銜接，很難讓我不想到這早就決定好了。我的職責沒有任何變化。感受下來這個系統封裝程度很高，我只要會調用方法就行。這個系統交付之後不會有太多問題，更多應該是做小需求，有大的開發任務應該也是第二期的事，嗯？怎麼感覺我變成運維了？而 ...
  • EAV模型（實體-屬性-值）的設計和低代碼的處理方案（2）--數據的查詢處理
    我在隨筆《EAV模型（實體-屬性-值）的設計和低代碼的處理方案（1）》中介紹了一些基本的EAV模型設計知識和基於Winform場景下低代碼（或者說無代碼）的一些實現思路，在本篇隨筆中，我們來分析一下這種針對通用業務，且只需定義就能構建業務模塊存儲和界面的解決方案，其中的數據查詢處理的操作。 ...
  • C# 程式集、模塊和類型概念及關係
    對某個遠程伺服器啟用和設置NTP服務(Windows系統) 打開註冊表 HKEY_LOCAL_MACHINE\SYSTEM\CurrentControlSet\Services\W32Time\TimeProviders\NtpServer 將 Enabled 的值設置為 1，這將啟用NTP伺服器功 ...
  • Django信號與擴展：深入理解與實踐
    title: Django信號與擴展：深入理解與實踐 date: 2024/5/15 22:40:52 updated: 2024/5/15 22:40:52 categories: 後端開發 tags: Django 信號 松耦合 觀察者 擴展 安全 性能 第一部分：Django信號基礎 Djan ...
  • Django3.2安裝源碼xadmin2步驟以及遇到的問題
    使用xadmin2遇到的問題&解決 環境配置： 使用的模塊版本： 關聯的包 Django 3.2.15 mysqlclient 2.2.4 xadmin 2.0.1 django-crispy-forms >= 1.6.0 django-import-export >= 0.5.1 django-r ...
  • 原創->CommonsCollections1-DefaultMap鏈
    今天我打算整點兒不一樣的內容，通過之前學習的TransformerMap和LazyMap鏈，想搞點不一樣的，所以我關註了另外一條鏈DefaultedMap鏈，主要調用鏈為： 調用鏈詳細描述： ObjectInputStream.readObject() DefaultedMap.readObject ...
  • 05-應用級開發者 AI 時代破局點
    後端應用級開發者該如何擁抱 AI GC？就是在這樣的一個大的浪潮下，我們的傳統的應用級開發者。我們該如何選擇職業或者是如何去快速轉型，跟上這樣的一個行業的一個浪潮? 0 AI金字塔模型 越往上它的整個難度就是職業機會也好，或者說是整個的這個運作也好,它的難度會越大,然後越往下機會就會越多,所以這是一 ...
  • Java面試題：讓依賴註入變得簡單，面對@Autowired和@Resource，該如何選擇？
    @Autowired是Spring框架提供的註解，@Resource是Java EE 5規範提供的註解。 @Autowired預設按照類型自動裝配，而@Resource預設按照名稱自動裝配。 @Autowired支持@Qualifier註解來指定裝配哪一個具有相同類型的bean，而@Resourc... ...
所有分類