Попробуйте, наконец, Celesta
в своём проекте!

На дворе 2023й год…​

Connectivity

RDBMS

Мигратор

ORM

Тестирование

Meet Celesta

Мигратор + Type-Safe code-generated ORM + testing helper Вдохновлен ERP-платформами Ответ на сложность разработки и тестирования систем с базами данных

Что такое Celesta?

Free open source Десятки малых и средних проектов. Стабильна! В документацию вложено много любви: courseorchestra.github.io/celesta Tooling: Spring Boot Starter JUnit 5 extension Maven plugin (usable from Gradle) IntelliJ IDEA plugin

Проблемы проекта Celesta

Раньше поддерживалась компанией, сейчас почти проект одного человека Никак не выйдет за пределы узкого круга моих знакомых и коллег Мало звёзд на гитхабе (если захотите, это легко исправить)!

Celesta

Comparison testing

CelestaSQL: "virtual" SQL dialect

Type mapping

FAQ: Как же мой супер-производительный запрос, использующий специфичную функциональность конкретной СУБД?

Внезапная выгода от database agnostic подхода

Проблемы с традиционными миграторами

<?xml version="1.0" encoding="UTF-8"?>
<databaseChangeLog>
    <changeSet>
        ....
    </changeSet>
    <changeSet>
        ....
    </changeSet>
    <changeSet>
        ....
    </changeSet>
</databaseChangeLog>

Это как если бы…​.

class Employee {
    ...
}

alter class Employee add variable String name;

alter class Employee drop method promote();

alter class add method doSomething(…) {
…
}

Не лучше ли

CONVERGE TABLE OrderHeader(
  id VARCHAR(30) NOT NULL,
  date DATETIME DEFAULT GETDATE(),
  customer_id VARCHAR(30),
  customer_name VARCHAR(100),
  CONSTRAINT Pk_OrderHeader PRIMARY KEY (id)
);

Как работает миграция Celesta

CREATE SCHEMA foo VERSION '1.0';

FAQ: Но ведь это работает не всегда?

Курсоры

Как работает курсор: чтение по первичному ключу

CallContext ctx = ...
ItemCursor item = new ItemCursor(ctx);
//Type safe API!
item.get(42);

select id, name, default_price from item where id = 42 limit 1;

Как работает курсор: чтение по первичному ключу

CallContext ctx = ...
ItemCursor item = new ItemCursor(ctx);
//Type safe API!
item.get(42);

select id, name, default_price from item where id = 42 limit 1;

Как работает курсор: модификация данных

//Type-safe, camelCase API
item.setDefaultPrice(14.9); //<---
item.update();

Как работает курсор: модификация данных

//Type-safe, camelCase API
item.setDefaultPrice(14.9);
item.update();              //<---

update item set default_price=14.9 where id = 42;

Как работает курсор: модификация данных

//Type-safe, camelCase API
item.setDefaultPrice(14.9);
item.update();

Как работает курсор: удаление

item.setId(43).delete();

delete from item where id = 43;

Как работает курсор: вставка с возвратом полей, вычисляемых базой данных

item.setName("cheese").insert();

Как работает курсор: вставка с возвратом полей, вычисляемых базой данных

item.insert();

Как работает курсор: чтение фильтрованной выборки

//Не происходит запроса к БД, просто конфигурируем курсор
cursor.setRange(cursor.COLUMNS.foo(), value)

//SELECT ... WHERE foo = value
for (MyCursor rec: cursor) {
    ....
}

Защита от потерянных обновлений

var rec = new ItemCursor(ctx);
rec.get(42);
rec.setName("cheese")
   .update();

var rec = new ItemCursor(ctx);
rec.get(42);
rec.setName("bread")
   .update();

"Проблема N+1"

OrderLineCursor line = new OrderLineCursor(ctx);
ItemCursor item = new ItemCursor(ctx);
for (var l: line) {
  item.get(l.getItemId());
/* достаем данные в каждой итерации :-( */
}

"Проблема N+1": чуть лучше

OrderLineCursor line = new OrderLineCursor(ctx);
ItemCursor item = new ItemCursor(ctx);
for (var l: line) {
  /* Objects.equals защищает от NPE */
  if (!Objects.equals(item.getId(), l.getItemId()))
  /* меньше обращений к базе */
    item.get(l.getItemId());
}

"Проблема N+1": оптимальный вариант

OrderLineCursor line = new OrderLineCursor(ctx);
ItemCursor item = new ItemCursor(ctx);
// Сортируем по join колонке
line.orderBy(line.COLUMNS.itemId());
for (var l: line) {
  /* Objects.equals защищает от NPE */
  if (!Objects.equals(item.getId(), l.getItemId()))
  /* меньше обращений к базе */
    item.get(l.getItemId());
}

Проблемы N+1 может и не быть :-)

create view item_view as
    select
      i.id as id,
      i.name as name,
      o.ordered_quantity as ordered_quantity,
      o.ordered_amount as ordered_amount
    from item as i left join item_orders as o on i.id = o.item_id;

Проблема чтения лишних полей

RecCursor rec = new RecCursor(context);
rec.get(42)

Проблема чтения лишних полей

RecCursor.Columns columns = new RecCursor.Columns(celesta);
RecCursor rec = new RecCursor(context, columns.f1(), columns.f3());
rec.get(42)

Как работает транзакция

@CelestaTransaction
public OrderDTO postOrder(CallContext ctx, OrderDTO orderDTO) {
    //каждому курсору нужен контекст
    OrderCursor orderCursor = new OrderCursor(ctx);
    //делаем что-то с базой
    ....

}

В это время снаружи транзакции…​

try {
    ctx.activate(celesta, ....);
    Object result = joinPoint.proceed(); //<--
    ctx.commit();
    return result;
} catch (Throwable e) {
    ctx.rollback();
    throw e;
} finally {
    ctx.close();
}

Пример: схема данных

Пример: Архитектура

Пример: Архитектура

Выводы

Спасибо за внимание!