Hai pada pembahasan kali ini kita akan mempelajari tentang transactional di JDBC. seperti yang kita tau klo untuk mengaktifkan transaksi dengan cara sebagai berikut:

begin;

-- sql in transaction

commit;

Jika menggunakan JDBC disarankan untuk tidak menggunakan begin dan commmit dalam query yang di execute. tetapi menggunakan method statement.setAutoCommit(false) dan statement.commit() seperti berikut contoh implementasinya:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

package com.maryanto.dimas.bootcamp;

import com.maryanto.dimas.bootcamp.config.DatasourceConfig;
import com.maryanto.dimas.bootcamp.dao.ExampleTableDao;
import com.maryanto.dimas.bootcamp.entity.ExampleTable;
import junit.framework.TestCase;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;

import javax.sql.*;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.*;

@Slf4j
public class TestIntegrationExampleTable extends TestCase {

    private DataSource dataSource;

    private ExampleTableDao dao;

    @Override
    protected void setUp() throws Exception {
        this.dataSource = new DatasourceConfig().getDataSource();
    }

    @Test
    public void testSavingDataWithTransactional() {
        Connection connection = null;
        try {
            connection = this.dataSource.getConnection();
            connection.setAutoCommit(false);
            this.dao = new ExampleTableDao(connection);

            ExampleTable muhamadPurwadi = new ExampleTable(
                    null,
                    "Muhamad Purwadi",
                    Date.valueOf(LocalDate.now()),
                    Timestamp.valueOf(LocalDateTime.now()),
                    true,
                    0l, 
                    new BigDecimal(100000),
                    "test data",
                    0f);
            ExampleTable save1 = this.dao.save(muhamadPurwadi);

            assertNotNull("employee id not null", save1.getId());
            log.info("employee: {}", save1);

            List<ExampleTable> list = this.dao.findAll();
            assertEquals("jumlah data example table", list.size(), 6);

            this.dao.removeById(save1.getId());

            muhamadPurwadi.setCurrency(null);
            ExampleTable save2 = this.dao.save(muhamadPurwadi);

            list = this.dao.findAll();
            assertEquals("jumlah data example table", list.size(), 6);

            log.info("employee: {}", save2);
            this.dao.removeById(save2.getId());

            list = this.dao.findAll();
            assertEquals("jumlah data example table", list.size(), 5);
            connection.commit();
        } catch (SQLException ex) {
            if (connection != null) {
                try {
                    connection.rollback();
                } catch (SQLException throwables) {
                    log.error("can't rollback");
                }
            }
            log.error("can't fetch data", ex);
        }
    }
}