Rename jooq-spring -> spring-jooq

2016-10-23 18:57:21 +02:00
parent 26fbeb98da
commit b1b4d4ff7f
13 changed files with 3 additions and 2 deletions
@@ -0,0 +1 @@
+/src/main/java/com/baeldung/jooq/introduction/db
@@ -0,0 +1,3 @@
+### Relevant Articles:
+- [Spring Boot Support for jOOQ](http://www.baeldung.com/spring-boot-support-for-jooq)
+- [Introduction to jOOQ with Spring](http://www.baeldung.com/jooq-with-spring)
@@ -0,0 +1,225 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<groupId>com.baeldung</groupId>
+	<artifactId>jooq-spring</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<!-- Import dependency management from Spring Boot -->
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-dependencies</artifactId>
+				<version>1.3.5.RELEASE</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+	<dependencies>
+		<!-- jOOQ -->
+		<dependency>
+			<groupId>org.jooq</groupId>
+			<artifactId>jooq</artifactId>
+			<version>${org.jooq.version}</version>
+		</dependency>
+
+		<!-- Database Access -->
+		<dependency>
+			<groupId>com.h2database</groupId>
+			<artifactId>h2</artifactId>
+			<version>${com.h2database.version}</version>
+		</dependency>
+
+		<!-- Spring -->
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-context</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-jdbc</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-jooq</artifactId>
+		</dependency>
+
+		<!-- Logging -->
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+		<dependency>
+			<groupId>ch.qos.logback</groupId>
+			<artifactId>logback-classic</artifactId>
+			<scope>runtime</scope>
+		</dependency>
+
+		<!-- Testing -->
+		<dependency>
+			<groupId>junit</groupId>
+			<artifactId>junit</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.codehaus.mojo</groupId>
+				<artifactId>properties-maven-plugin</artifactId>
+				<version>1.0.0</version>
+				<executions>
+					<execution>
+						<phase>initialize</phase>
+						<goals>
+							<goal>read-project-properties</goal>
+						</goals>
+						<configuration>
+							<files>
+								<file>src/main/resources/intro_config.properties</file>
+							</files>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+
+			<plugin>
+				<groupId>org.codehaus.mojo</groupId>
+				<artifactId>sql-maven-plugin</artifactId>
+				<version>1.5</version>
+				<executions>
+					<execution>
+						<phase>initialize</phase>
+						<goals>
+							<goal>execute</goal>
+						</goals>
+						<configuration>
+							<driver>${db.driver}</driver>
+							<url>${db.url}</url>
+							<username>${db.username}</username>
+							<password>${db.password}</password>
+							<srcFiles>
+								<srcFile>src/main/resources/intro_schema.sql</srcFile>
+							</srcFiles>
+						</configuration>
+					</execution>
+				</executions>
+				<dependencies>
+					<dependency>
+						<groupId>com.h2database</groupId>
+						<artifactId>h2</artifactId>
+						<version>${com.h2database.version}</version>
+					</dependency>
+				</dependencies>
+			</plugin>
+
+			<plugin>
+				<groupId>org.jooq</groupId>
+				<artifactId>jooq-codegen-maven</artifactId>
+				<version>${org.jooq.version}</version>
+				<executions>
+					<execution>
+						<phase>generate-sources</phase>
+						<goals>
+							<goal>generate</goal>
+						</goals>
+						<configuration>
+							<jdbc>
+								<driver>${db.driver}</driver>
+								<url>${db.url}</url>
+								<user>${db.username}</user>
+								<password>${db.password}</password>
+							</jdbc>
+							<generator>
+								<target>
+									<packageName>com.baeldung.jooq.introduction.db</packageName>
+									<directory>src/main/java</directory>
+								</target>
+							</generator>
+						</configuration>
+					</execution>
+				</executions>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-compiler-plugin</artifactId>
+				<version>${maven-compiler-plugin.version}</version>
+				<configuration>
+					<source>1.8</source>
+					<target>1.8</target>
+				</configuration>
+			</plugin>
+
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-surefire-plugin</artifactId>
+				<configuration>
+					<excludes>
+						<exclude>**/*IntegrationTest.java</exclude>
+						<exclude>**/*LiveTest.java</exclude>
+					</excludes>
+				</configuration>
+			</plugin>
+
+		</plugins>
+	</build>
+
+    <profiles>
+        <profile>
+            <id>integration</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.apache.maven.plugins</groupId>
+                        <artifactId>maven-surefire-plugin</artifactId>
+                        <executions>
+                            <execution>
+                                <phase>integration-test</phase>
+                                <goals>
+                                    <goal>test</goal>
+                                </goals>
+                                <configuration>
+                                    <excludes>
+                                        <exclude>**/*LiveTest.java</exclude>
+                                    </excludes>
+                                    <includes>
+                                        <include>**/*IntegrationTest.java</include>
+                                    </includes>
+                                </configuration>
+                            </execution>
+                        </executions>
+                        <configuration>
+                            <systemPropertyVariables>
+                                <test.mime>json</test.mime>
+                            </systemPropertyVariables>
+                        </configuration>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
+    
+	<properties>
+		<org.jooq.version>3.7.3</org.jooq.version>
+		<com.h2database.version>1.4.191</com.h2database.version>
+		<org.springframework.version>4.2.5.RELEASE</org.springframework.version>
+		<org.slf4j.version>1.7.18</org.slf4j.version>
+		<ch.qos.logback.version>1.1.3</ch.qos.logback.version>
+		<junit.version>4.12</junit.version>
+		
+		<maven-compiler-plugin.version>3.5.1</maven-compiler-plugin.version>
+        <maven-surefire-plugin.version>2.19.1</maven-surefire-plugin.version>		
+	</properties>
+
+</project>
@@ -0,0 +1,3 @@
+spring.datasource.url=jdbc:h2:~/jooq
+spring.datasource.username=sa
+spring.datasource.password=
@@ -0,0 +1,8 @@
+#Database Configuration
+db.driver=org.h2.Driver
+db.url=jdbc:h2:~/jooq
+db.username=sa
+db.password=
+
+#SQL Dialect
+jooq.sql.dialect=H2
@@ -0,0 +1,34 @@
+DROP TABLE IF EXISTS author_book, author, book;
+
+CREATE TABLE author (
+  id             INT          NOT NULL PRIMARY KEY,
+  first_name     VARCHAR(50),
+  last_name      VARCHAR(50)  NOT NULL
+);
+
+CREATE TABLE book (
+  id             INT          NOT NULL PRIMARY KEY,
+  title          VARCHAR(100) NOT NULL
+);
+
+CREATE TABLE author_book (
+  author_id      INT          NOT NULL,
+  book_id        INT          NOT NULL,
+  
+  PRIMARY KEY (author_id, book_id),
+  CONSTRAINT fk_ab_author     FOREIGN KEY (author_id)  REFERENCES author (id)  
+    ON UPDATE CASCADE ON DELETE CASCADE,
+  CONSTRAINT fk_ab_book       FOREIGN KEY (book_id)    REFERENCES book   (id)
+);
+
+INSERT INTO author VALUES 
+  (1, 'Kathy', 'Sierra'), 
+  (2, 'Bert', 'Bates'), 
+  (3, 'Bryan', 'Basham');
+
+INSERT INTO book VALUES 
+  (1, 'Head First Java'), 
+  (2, 'Head First Servlets and JSP'),
+  (3, 'OCA/OCP Java SE 7 Programmer');
+
+INSERT INTO author_book VALUES (1, 1), (1, 3), (2, 1);
@@ -0,0 +1,19 @@
+package com.baeldung.jooq.introduction;
+
+import org.jooq.ExecuteContext;
+import org.jooq.SQLDialect;
+import org.jooq.impl.DefaultExecuteListener;
+
+import org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator;
+import org.springframework.jdbc.support.SQLExceptionTranslator;
+
+public class ExceptionTranslator extends DefaultExecuteListener {
+
+    @Override
+    public void exception(ExecuteContext context) {
+        SQLDialect dialect = context.configuration().dialect();
+        SQLExceptionTranslator translator = new SQLErrorCodeSQLExceptionTranslator(dialect.name());
+
+        context.exception(translator.translate("Access database using jOOQ", context.sql(), context.sqlException()));
+    }
+}
@@ -0,0 +1,78 @@
+package com.baeldung.jooq.introduction;
+
+import org.h2.jdbcx.JdbcDataSource;
+import org.jooq.SQLDialect;
+import org.jooq.impl.DataSourceConnectionProvider;
+import org.jooq.impl.DefaultConfiguration;
+import org.jooq.impl.DefaultDSLContext;
+import org.jooq.impl.DefaultExecuteListenerProvider;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.PropertySource;
+import org.springframework.core.env.Environment;
+import org.springframework.jdbc.datasource.DataSourceTransactionManager;
+import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+import javax.sql.DataSource;
+
+@Configuration
+@ComponentScan({ "com.baeldung.jooq.introduction.db.public_.tables" })
+@EnableTransactionManagement
+@PropertySource("classpath:intro_config.properties")
+public class PersistenceContextIntegrationTest {
+
+    @Autowired
+    private Environment environment;
+
+    @Bean
+    public DataSource dataSource() {
+        JdbcDataSource dataSource = new JdbcDataSource();
+
+        dataSource.setUrl(environment.getRequiredProperty("db.url"));
+        dataSource.setUser(environment.getRequiredProperty("db.username"));
+        dataSource.setPassword(environment.getRequiredProperty("db.password"));
+
+        return dataSource;
+    }
+
+    @Bean
+    public TransactionAwareDataSourceProxy transactionAwareDataSource() {
+        return new TransactionAwareDataSourceProxy(dataSource());
+    }
+
+    @Bean
+    public DataSourceTransactionManager transactionManager() {
+        return new DataSourceTransactionManager(dataSource());
+    }
+
+    @Bean
+    public DataSourceConnectionProvider connectionProvider() {
+        return new DataSourceConnectionProvider(transactionAwareDataSource());
+    }
+
+    @Bean
+    public ExceptionTranslator exceptionTransformer() {
+        return new ExceptionTranslator();
+    }
+    
+    @Bean
+    public DefaultDSLContext dsl() {
+        return new DefaultDSLContext(configuration());
+    }
+
+    @Bean
+    public DefaultConfiguration configuration() {
+        DefaultConfiguration jooqConfiguration = new DefaultConfiguration();
+        jooqConfiguration.set(connectionProvider());
+        jooqConfiguration.set(new DefaultExecuteListenerProvider(exceptionTransformer()));
+
+        String sqlDialectName = environment.getRequiredProperty("jooq.sql.dialect");
+        SQLDialect dialect = SQLDialect.valueOf(sqlDialectName);
+        jooqConfiguration.set(dialect);
+
+        return jooqConfiguration;
+    }
+}
@@ -0,0 +1,122 @@
+package com.baeldung.jooq.introduction;
+
+import org.jooq.DSLContext;
+import org.jooq.Record3;
+import org.jooq.Result;
+import org.jooq.impl.DSL;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.dao.DataAccessException;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.transaction.annotation.Transactional;
+
+import static com.baeldung.jooq.introduction.db.public_.tables.Author.AUTHOR;
+import static com.baeldung.jooq.introduction.db.public_.tables.AuthorBook.AUTHOR_BOOK;
+import static com.baeldung.jooq.introduction.db.public_.tables.Book.BOOK;
+import static org.junit.Assert.assertEquals;
+
+@ContextConfiguration(classes = PersistenceContextIntegrationTest.class)
+@Transactional(transactionManager = "transactionManager")
+@RunWith(SpringJUnit4ClassRunner.class)
+public class QueryIntegrationTest {
+
+    @Autowired
+    private DSLContext dsl;
+
+    @Test
+    public void givenValidData_whenInserting_thenSucceed() {
+        dsl.insertInto(AUTHOR)
+                .set(AUTHOR.ID, 4)
+                .set(AUTHOR.FIRST_NAME, "Herbert")
+                .set(AUTHOR.LAST_NAME, "Schildt")
+                .execute();
+
+        dsl.insertInto(BOOK)
+                .set(BOOK.ID, 4)
+                .set(BOOK.TITLE, "A Beginner's Guide")
+                .execute();
+
+        dsl.insertInto(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 4)
+                .set(AUTHOR_BOOK.BOOK_ID, 4)
+                .execute();
+
+        final Result<Record3<Integer, String, Integer>> result = dsl.select(AUTHOR.ID, AUTHOR.LAST_NAME, DSL.count())
+                .from(AUTHOR)
+                .join(AUTHOR_BOOK).on(AUTHOR.ID.equal(AUTHOR_BOOK.AUTHOR_ID))
+                .join(BOOK).on(AUTHOR_BOOK.BOOK_ID.equal(BOOK.ID))
+                .groupBy(AUTHOR.LAST_NAME).fetch();
+
+        assertEquals(3, result.size());
+        assertEquals("Sierra", result.getValue(0, AUTHOR.LAST_NAME));
+        assertEquals(Integer.valueOf(2), result.getValue(0, DSL.count()));
+        assertEquals("Schildt", result.getValue(2, AUTHOR.LAST_NAME));
+        assertEquals(Integer.valueOf(1), result.getValue(2, DSL.count()));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenInserting_thenFail() {
+        dsl.insertInto(AUTHOR_BOOK).set(AUTHOR_BOOK.AUTHOR_ID, 4).set(AUTHOR_BOOK.BOOK_ID, 5).execute();
+    }
+
+    @Test
+    public void givenValidData_whenUpdating_thenSucceed() {
+        dsl.update(AUTHOR)
+                .set(AUTHOR.LAST_NAME, "Baeldung")
+                .where(AUTHOR.ID.equal(3))
+                .execute();
+
+        dsl.update(BOOK)
+                .set(BOOK.TITLE, "Building your REST API with Spring")
+                .where(BOOK.ID.equal(3)).execute();
+
+        dsl.insertInto(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 3)
+                .set(AUTHOR_BOOK.BOOK_ID, 3)
+                .execute();
+
+        final Result<Record3<Integer, String, String>> result = dsl.select(AUTHOR.ID, AUTHOR.LAST_NAME, BOOK.TITLE)
+                .from(AUTHOR)
+                .join(AUTHOR_BOOK).on(AUTHOR.ID.equal(AUTHOR_BOOK.AUTHOR_ID))
+                .join(BOOK).on(AUTHOR_BOOK.BOOK_ID.equal(BOOK.ID))
+                .where(AUTHOR.ID.equal(3))
+                .fetch();
+
+        assertEquals(1, result.size());
+        assertEquals(Integer.valueOf(3), result.getValue(0, AUTHOR.ID));
+        assertEquals("Baeldung", result.getValue(0, AUTHOR.LAST_NAME));
+        assertEquals("Building your REST API with Spring", result.getValue(0, BOOK.TITLE));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenUpdating_thenFail() {
+        dsl.update(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 4)
+                .set(AUTHOR_BOOK.BOOK_ID, 5)
+                .execute();
+    }
+
+    @Test
+    public void givenValidData_whenDeleting_thenSucceed() {
+        dsl.delete(AUTHOR)
+                .where(AUTHOR.ID.lt(3))
+                .execute();
+
+        final Result<Record3<Integer, String, String>> result = dsl.select(AUTHOR.ID, AUTHOR.FIRST_NAME, AUTHOR.LAST_NAME)
+                .from(AUTHOR)
+                .fetch();
+
+        assertEquals(1, result.size());
+        assertEquals("Bryan", result.getValue(0, AUTHOR.FIRST_NAME));
+        assertEquals("Basham", result.getValue(0, AUTHOR.LAST_NAME));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenDeleting_thenFail() {
+        dsl.delete(BOOK)
+                .where(BOOK.ID.equal(1))
+                .execute();
+    }
+}
@@ -0,0 +1,9 @@
+package com.baeldung.jooq.springboot;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.transaction.annotation.EnableTransactionManagement;
+
+@SpringBootApplication
+@EnableTransactionManagement
+public class Application {
+}
@@ -0,0 +1,39 @@
+package com.baeldung.jooq.springboot;
+
+import com.baeldung.jooq.introduction.ExceptionTranslator;
+import org.jooq.impl.DataSourceConnectionProvider;
+import org.jooq.impl.DefaultConfiguration;
+import org.jooq.impl.DefaultDSLContext;
+import org.jooq.impl.DefaultExecuteListenerProvider;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
+
+import javax.sql.DataSource;
+
+@Configuration
+public class InitialConfiguration {
+
+    @Autowired
+    private DataSource dataSource;
+
+    @Bean
+    public DataSourceConnectionProvider connectionProvider() {
+        return new DataSourceConnectionProvider(new TransactionAwareDataSourceProxy(dataSource));
+    }
+
+    @Bean
+    public DefaultDSLContext dsl() {
+        return new DefaultDSLContext(configuration());
+    }
+
+    public DefaultConfiguration configuration() {
+        DefaultConfiguration jooqConfiguration = new DefaultConfiguration();
+
+        jooqConfiguration.set(connectionProvider());
+        jooqConfiguration.set(new DefaultExecuteListenerProvider(new ExceptionTranslator()));
+
+        return jooqConfiguration;
+    }
+}
@@ -0,0 +1,124 @@
+package com.baeldung.jooq.springboot;
+
+import org.jooq.DSLContext;
+import org.jooq.Record3;
+import org.jooq.Result;
+import org.jooq.impl.DSL;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.SpringApplicationConfiguration;
+import org.springframework.dao.DataAccessException;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+import org.springframework.transaction.annotation.Transactional;
+
+import static com.baeldung.jooq.introduction.db.public_.tables.Author.AUTHOR;
+import static com.baeldung.jooq.introduction.db.public_.tables.AuthorBook.AUTHOR_BOOK;
+import static com.baeldung.jooq.introduction.db.public_.tables.Book.BOOK;
+import static org.junit.Assert.assertEquals;
+
+@SpringApplicationConfiguration(Application.class)
+@Transactional("transactionManager")
+@RunWith(SpringJUnit4ClassRunner.class)
+public class SpringBootIntegrationTest {
+
+    @Autowired
+    private DSLContext dsl;
+
+    @Test
+    public void givenValidData_whenInserting_thenSucceed() {
+        dsl.insertInto(AUTHOR)
+                .set(AUTHOR.ID, 4)
+                .set(AUTHOR.FIRST_NAME, "Herbert")
+                .set(AUTHOR.LAST_NAME, "Schildt")
+                .execute();
+
+        dsl.insertInto(BOOK)
+                .set(BOOK.ID, 4)
+                .set(BOOK.TITLE, "A Beginner's Guide")
+                .execute();
+
+        dsl.insertInto(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 4)
+                .set(AUTHOR_BOOK.BOOK_ID, 4)
+                .execute();
+
+        final Result<Record3<Integer, String, Integer>> result = dsl.select(AUTHOR.ID, AUTHOR.LAST_NAME, DSL.count())
+                .from(AUTHOR).join(AUTHOR_BOOK).on(AUTHOR.ID.equal(AUTHOR_BOOK.AUTHOR_ID))
+                .join(BOOK).on(AUTHOR_BOOK.BOOK_ID.equal(BOOK.ID))
+                .groupBy(AUTHOR.LAST_NAME)
+                .fetch();
+
+        assertEquals(3, result.size());
+        assertEquals("Sierra", result.getValue(0, AUTHOR.LAST_NAME));
+        assertEquals(Integer.valueOf(2), result.getValue(0, DSL.count()));
+        assertEquals("Schildt", result.getValue(2, AUTHOR.LAST_NAME));
+        assertEquals(Integer.valueOf(1), result.getValue(2, DSL.count()));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenInserting_thenFail() {
+        dsl.insertInto(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 4)
+                .set(AUTHOR_BOOK.BOOK_ID, 5)
+                .execute();
+    }
+
+    @Test
+    public void givenValidData_whenUpdating_thenSucceed() {
+        dsl.update(AUTHOR)
+                .set(AUTHOR.LAST_NAME, "Baeldung")
+                .where(AUTHOR.ID.equal(3))
+                .execute();
+
+        dsl.update(BOOK)
+                .set(BOOK.TITLE, "Building your REST API with Spring")
+                .where(BOOK.ID.equal(3))
+                .execute();
+
+        dsl.insertInto(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 3)
+                .set(AUTHOR_BOOK.BOOK_ID, 3)
+                .execute();
+
+        final Result<Record3<Integer, String, String>> result = dsl.select(AUTHOR.ID, AUTHOR.LAST_NAME, BOOK.TITLE)
+                .from(AUTHOR).join(AUTHOR_BOOK).on(AUTHOR.ID.equal(AUTHOR_BOOK.AUTHOR_ID))
+                .join(BOOK).on(AUTHOR_BOOK.BOOK_ID.equal(BOOK.ID))
+                .where(AUTHOR.ID.equal(3))
+                .fetch();
+
+        assertEquals(1, result.size());
+        assertEquals(Integer.valueOf(3), result.getValue(0, AUTHOR.ID));
+        assertEquals("Baeldung", result.getValue(0, AUTHOR.LAST_NAME));
+        assertEquals("Building your REST API with Spring", result.getValue(0, BOOK.TITLE));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenUpdating_thenFail() {
+        dsl.update(AUTHOR_BOOK)
+                .set(AUTHOR_BOOK.AUTHOR_ID, 4)
+                .set(AUTHOR_BOOK.BOOK_ID, 5)
+                .execute();
+    }
+
+    @Test
+    public void givenValidData_whenDeleting_thenSucceed() {
+        dsl.delete(AUTHOR)
+                .where(AUTHOR.ID.lt(3))
+                .execute();
+
+        final Result<Record3<Integer, String, String>> result = dsl.select(AUTHOR.ID, AUTHOR.FIRST_NAME, AUTHOR.LAST_NAME)
+                .from(AUTHOR).fetch();
+
+        assertEquals(1, result.size());
+        assertEquals("Bryan", result.getValue(0, AUTHOR.FIRST_NAME));
+        assertEquals("Basham", result.getValue(0, AUTHOR.LAST_NAME));
+    }
+
+    @Test(expected = DataAccessException.class)
+    public void givenInvalidData_whenDeleting_thenFail() {
+        dsl.delete(BOOK)
+                .where(BOOK.ID.equal(1))
+                .execute();
+    }
+}
				`@@ -0,0 +1 @@`
				`/src/main/java/com/baeldung/jooq/introduction/db`