【jOOQ中文】2. jOOQ與Spring和Druid整合

pingink 發布于2019-08-15 11:08 / 3340人閱讀

摘要：在這個例子中，我們將整合但您也可以使用其他連接池，如，，等。作為構建和執行。

jOOQ和Spring很容易整合。在這個例子中，我們將整合：

Alibaba Druid（但您也可以使用其他連接池，如BoneCP，C3P0，DBCP等）。

Spring TX作為事物管理library。

jOOQ作為SQL構建和執行library。

一、準備數據庫

DROP TABLE IF EXISTS `author`;
CREATE TABLE `author` (
  `id` int(11) NOT NULL,
  `first_name` varchar(50) DEFAULT NULL,
  `last_name` varchar(50) NOT NULL,
  `date_of_birth` date DEFAULT NULL,
  `year_of_birth` int(11) DEFAULT NULL,
  `distinguished` int(1) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

DROP TABLE IF EXISTS `book`;
CREATE TABLE `book` (
  `id` int(11) NOT NULL,
  `author_id` int(11) NOT NULL,
  `title` varchar(400) NOT NULL,
  `published_in` int(11) NOT NULL,
  `language_id` int(11) NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

DROP TABLE IF EXISTS `book_store`;
CREATE TABLE `book_store` (
  `name` varchar(400) NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

DROP TABLE IF EXISTS `book_to_book_store`;
CREATE TABLE `book_to_book_store` (
  `name` varchar(400) NOT NULL,
  `book_id` int(11) NOT NULL,
  `stock` int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

DROP TABLE IF EXISTS `language`;
CREATE TABLE `language` (
  `id` int(11) NOT NULL,
  `cd` char(2) NOT NULL,
  `description` varchar(50) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1;


ALTER TABLE `author`
  ADD PRIMARY KEY (`id`);

ALTER TABLE `book`
  ADD PRIMARY KEY (`id`),
  ADD KEY `fk_book_author` (`author_id`),
  ADD KEY `fk_book_language` (`language_id`);

ALTER TABLE `book_store`
  ADD UNIQUE KEY `name` (`name`);

ALTER TABLE `book_to_book_store`
  ADD PRIMARY KEY (`name`,`book_id`),
  ADD KEY `fk_b2bs_book` (`book_id`);

ALTER TABLE `language`
  ADD PRIMARY KEY (`id`);

二、添加所需的Maven依賴項

在這個例子中，我們將創建以下Maven依賴項：



    4.0.0
    com.jsyso
      jooq-tutorials-2
      jar
    jooq-tutorials-2
    1.0.0
    
    
        
        4.1.9.RELEASE
        

        
        1.8
        UTF-8
        true
        1.7.7
        
        
        
        5.1.30
        1.0.18
        
        
        
        3.9.5
        
        
    
    
    
        
            aliyun-repos
            Aliyun Repository
            http://maven.aliyun.com/nexus/content/groups/public
        
    

     
        
            aliyun-repos
            Aliyun Repository
            http://maven.aliyun.com/nexus/content/groups/public
        
    
    
    
        
            mysql
            mysql-connector-java
            ${mysql.driver.version}
        
        
        
            junit
            junit
            4.11
            test
        
        
        
          org.jooq
          jooq
          ${jooq.version}
        
        
          org.jooq
          jooq-meta
          ${jooq.version}
        
        
          org.jooq
          jooq-codegen
          ${jooq.version}
        

        
            com.alibaba
            druid
            ${druid.version}
        

        
        
            org.springframework
            spring-core
            ${spring.version}
            
                
                    commons-logging
                    commons-logging
                
            
        
        
            org.springframework
            spring-beans
            ${spring.version}
        
        
            org.springframework
            spring-context
            ${spring.version}
        
        
            org.springframework
            spring-context-support
            ${spring.version}
        
        
            org.springframework
            spring-aop
            ${spring.version}
            
                
                    commons-logging
                    commons-logging
                
            
        
        
            org.springframework
            spring-tx
            ${spring.version}
        
        
            org.springframework
            spring-orm
            ${spring.version}
        
        
            org.springframework
            spring-jdbc
            ${spring.version}
        

        
        
            junit
            junit
            4.11
            test
        
        
            org.springframework
            spring-test
            ${spring.version}
            test
        
        

        
        
            org.slf4j
            slf4j-api
            ${slf4j.version}
        
        
            org.slf4j
            slf4j-log4j12
            ${slf4j.version}
        
        
        
            org.slf4j
            jcl-over-slf4j
            ${slf4j.version}
        
        
        
            org.slf4j
            jul-to-slf4j
            ${slf4j.version}
        
        

    
    
    
        
            
            
                org.apache.maven.plugins
                maven-compiler-plugin
                3.5.1
                
                    ${jdk.version}
                    ${jdk.version}
                    true
                
            
            
            
            
                org.apache.maven.plugins
                maven-jar-plugin
                2.4
            

            
            
                org.apache.maven.plugins
                maven-resources-plugin
                2.7
            
            
            
            
                org.apache.maven.plugins
                maven-install-plugin
                2.5.2
            
            
            
            
                org.apache.maven.plugins
                maven-clean-plugin
                2.6.1
            
            
            
            
                org.apache.maven.plugins
                maven-dependency-plugin
                2.10
            
            
            
            
                org.apache.maven.plugins
                maven-surefire-plugin
                2.5
                
                    true
                
            
        
    
    
      
        
            com.jsyso
            Jan
            xujian_jason@163.com
            +8

三、Spring配置文件



    Spring Configuration

    
    

    
    
        
        

        
        
        
        

        
        
        
        

        
        

        
        

        
        

        
        
        
        

        
        
    

    
    
        
    
    
    
    
    
        
    
    
        
    
    
    

    
        MYSQL

四、Spring Test + JUnit集成測試

查詢測試：

package test.generated.service;

import static java.util.Arrays.asList;
import static org.jooq.impl.DSL.countDistinct;
import static org.junit.Assert.assertEquals;
import static test.generated.Tables.*;

import org.jooq.DSLContext;
import org.jooq.Record3;
import org.jooq.Result;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import test.generated.tables.Author;
import test.generated.tables.Book;
import test.generated.tables.BookStore;
import test.generated.tables.BookToBookStore;
import test.generated.tables.records.BookRecord;

/**
 * @author Lukas Eder
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"/jooq-spring.xml"})
public class QueryTest {
    @Autowired
    DSLContext create;

    @Test
    public void testJoin() throws Exception {
        // All of these tables were generated by jOOQ"s Maven plugin
        Book b = BOOK.as("b");
        Author a = AUTHOR.as("a");
        BookStore s = BOOK_STORE.as("s");
        BookToBookStore t = BOOK_TO_BOOK_STORE.as("t");

        Result> result =
                create.select(a.FIRST_NAME, a.LAST_NAME, countDistinct(s.NAME))
                        .from(a)
                        .join(b).on(b.AUTHOR_ID.eq(a.ID))
                        .join(t).on(t.BOOK_ID.eq(b.ID))
                        .join(s).on(t.NAME.eq(s.NAME))
                        .groupBy(a.FIRST_NAME, a.LAST_NAME)
                        .orderBy(countDistinct(s.NAME).desc())
                        .fetch();

        assertEquals(2, result.size());
        assertEquals("Paulo", result.getValue(0, a.FIRST_NAME));
        assertEquals("George", result.getValue(1, a.FIRST_NAME));

        assertEquals("Coelho", result.getValue(0, a.LAST_NAME));
        assertEquals("Orwell", result.getValue(1, a.LAST_NAME));

        assertEquals(Integer.valueOf(3), result.getValue(0, countDistinct(s.NAME)));
        assertEquals(Integer.valueOf(2), result.getValue(1, countDistinct(s.NAME)));
    }

}

數據插入，使用Spring的TransactionManager來顯式處理事務：

package test.generated.service;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static test.generated.Tables.BOOK;

import java.util.concurrent.atomic.AtomicBoolean;

import org.jooq.DSLContext;

import org.junit.After;
import org.junit.Assert;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.test.context.transaction.TransactionConfiguration;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;

/**
 * @author Petri Kainulainen
 * @author Lukas Eder
 *
 * @see http://www.petrikainulainen.net/programming/jooq/using-jooq-with-spring-configuration/
 */
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = {"/jooq-spring.xml"})
@TransactionConfiguration(transactionManager="transactionManager")
public class TransactionTest {

    @Autowired DSLContext                   dsl;
    @Autowired DataSourceTransactionManager txMgr;

    @Test
    public void testDelBooks() {

        // Delete all books that were created in any test
        dsl.delete(BOOK).where(BOOK.ID.gt(4)).execute();
    }

    @Test
    public void testAddBooks() {
        TransactionStatus tx = txMgr.getTransaction(new DefaultTransactionDefinition());
        for (int i = 1; i <= 6; i++)
            dsl.insertInto(BOOK)
                    .set(BOOK.ID, i)
                    .set(BOOK.PUBLISHED_IN, 1)
                    .set(BOOK.LANGUAGE_ID, 1)
                    .set(BOOK.AUTHOR_ID, 1)
                    .set(BOOK.TITLE, "Book " + i)
                    .execute();
        txMgr.commit(tx);
    }

    @Test
    public void testExplicitTransactions() {
        boolean rollback = false;

        TransactionStatus tx = txMgr.getTransaction(new DefaultTransactionDefinition());
        try {

            // This is a "bug". The same book is created twice, resulting in a
            // constraint violation exception
            for (int i = 7; i <=9; i++)
                dsl.insertInto(BOOK)
                        .set(BOOK.ID, i)
                        .set(BOOK.AUTHOR_ID, 1)
                        .set(BOOK.TITLE, "Book " + i)
                        .execute();

            Assert.fail();
        }

        // Upon the constraint violation, we explicitly roll back the transaction.
        catch (DataAccessException e) {
            txMgr.rollback(tx);
            rollback = true;
        }

        assertEquals(4, dsl.fetchCount(BOOK));
        assertTrue(rollback);
    }
}

【jOOQ中文】教程代碼都會放在碼云，希望多多宣傳給Star(^_?)☆。

https://gitee.com/xujian_jaso...

云服務器 GPU云服務器 JOOQ druid-spring-事務-連接池 spring整合mongodb webrtc與OA整合

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/67559.html

ORM “殺器”之 JOOQ

摘要：摘要介紹簡單實用，以及相對于傳統框架的不同點。最令人滿意的就是在實際使用過程中解決問題的靈活性。當前在數據服務組擔任開發工程師，主要負責服務器開發。摘要介紹JOOQ簡單實用，以及相對于傳統ORM框架的不同點。 showImg(https://segmentfault.com/img/remote/1460000006763840); （圖片來自http://www.jooq.org...

Andrman 2019-06-25 18:22 評論0 收藏0
ORM “殺器”之 JOOQ

摘要：摘要介紹簡單實用，以及相對于傳統框架的不同點。最令人滿意的就是在實際使用過程中解決問題的靈活性。當前在數據服務組擔任開發工程師，主要負責服務器開發。摘要介紹JOOQ簡單實用，以及相對于傳統ORM框架的不同點。 showImg(https://segmentfault.com/img/remote/1460000006763840); （圖片來自http://www.jooq.org...

elarity 2019-06-24 17:49 評論0 收藏0
ORM “殺器”之 JOOQ

摘要：摘要介紹簡單實用，以及相對于傳統框架的不同點。最令人滿意的就是在實際使用過程中解決問題的靈活性。當前在數據服務組擔任開發工程師，主要負責服務器開發。摘要介紹JOOQ簡單實用，以及相對于傳統ORM框架的不同點。 showImg(/img/remote/1460000006763840); （圖片來自http://www.jooq.org/）正文 JOOQ是啥？ JOOQ 是基于Ja...

yeooo 2019-08-14 14:33 評論0 收藏0
【jOOQ中文】3. 數據庫版本管理工具Flyway

摘要：一簡介什么是是獨立于數據庫的應用管理跟蹤數據庫變更的數據庫版本管理工具。當升級完成時，數據庫表結構及數據應當與升級后的產品版本保持一致。在執行數據庫遷移時，我們推薦使用jOOQ與Flyway - 數據庫遷移輕松。在本章中，我們將簡單的來使用這兩個框架。一、Flyway簡介 showImg(https://segmentfault.com/img/bVSjro?w=400&h=31...

AprilJ 2019-08-15 11:09 評論0 收藏0

發表評論

登陸后可評論

0條評論

pingink

男|高級講師

我要關注我要私信

TA的文章

知道了螞蟻森林這個“秘密”，我坐不住了??！

閱讀 2253·2021-09-26 09:55
字節跳動上線Pixsoul，主打特效變臉

閱讀 3584·2021-09-23 11:22
前端每日實戰：78# 視頻演示如何用純 CSS 創作 Windows 啟動界面

閱讀 2151·2019-08-30 15:54
CSS學習筆記(九) 界面組件之導航菜單

閱讀 1894·2019-08-28 18:03
Node.js 指南（Node.js事件循環、定時器和process.nextTick()）

閱讀 2591·2019-08-26 12:22
總結下var、let 和 const 的區別

閱讀 3426·2019-08-26 12:20
理解ECMAScript中所有的參數傳遞的都是值，不可能通過引用傳遞參數

閱讀 1723·2019-08-26 11:56
vue--為什么data屬性必須是一個函數

閱讀 2245·2019-08-23 15:30

国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！

【jOOQ中文】2. jOOQ與Spring和Druid整合

相關文章

ORM “殺器”之 JOOQ

ORM “殺器”之 JOOQ

ORM “殺器”之 JOOQ

**【jOOQ中文】3. 數據庫版本管理工具Flyway**

發表評論

0條評論

pingink

男|高級講師

TA的文章

知道了螞蟻森林這個“秘密”，我坐不住了??！

字節跳動上線Pixsoul，主打特效變臉

前端每日實戰：78# 視頻演示如何用純 CSS 創作 Windows 啟動界面

CSS學習筆記(九) 界面組件之導航菜單

Node.js 指南（Node.js事件循環、定時器和process.nextTick()）

總結下var、let 和 const 的區別

理解ECMAScript中所有的參數傳遞的都是值，不可能通過引用傳遞參數

vue--為什么data屬性必須是一個函數

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！

【jOOQ中文】2. jOOQ與Spring和Druid整合

相關文章

發表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務器低至59元/年，更有多臺、長期優惠，快來選購！