package org.tests.update;

import io.ebean.BaseTestCase;
import io.ebean.DB;
import io.ebean.SqlRow;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.tests.model.basic.Customer;
import org.tests.model.basic.ResetBasicData;

import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertEquals;

public class TestUpdatePartial extends BaseTestCase {

  @BeforeAll
  static void before() {
    ResetBasicData.reset();
  }

  @Test
  public void test() {

    Customer c = new Customer();
    c.setName("TestUpdateMe");
    c.setStatus(Customer.Status.ACTIVE);
    c.setSmallnote("a note");

    DB.save(c);
    checkDbStatusValue(c.getId(), "A");

    Customer c2 = DB.find(Customer.class)
      .setUseCache(false)
      .select("status, smallnote")
      .setId(c.getId())
      .findOne();

    c2.setStatus(Customer.Status.INACTIVE);
    c2.setSmallnote("2nd note");

    DB.save(c2);
    checkDbStatusValue(c.getId(), "I");

    Customer c3 = DB.find(Customer.class)
      .setUseCache(false)
      .select("status")
      .setId(c.getId())
      .findOne();

    c3.setStatus(Customer.Status.NEW);
    c3.setSmallnote("3rd note");

    DB.save(c3);
    checkDbStatusValue(c.getId(), "N");

    // cleanup
    DB.delete(Customer.class, c.getId());
  }

  private void checkDbStatusValue(Integer custId, String dbStatus) {
    SqlRow sqlRow = DB.sqlQuery("select id, status from o_customer where id = ?")
      .setParameter(custId)
      .findOne();
    String status = sqlRow.getString("status");
    assertEquals(dbStatus, status);
  }

  /**
   * If we have no changes detected, don't execute an Update and don't update the Version column.
   */
  @Test
  public void testWithoutChangesAndVersionColumn() {

    Customer customer = new Customer();
    customer.setName("something");

    DB.save(customer);

    Customer customerWithoutChanges = DB.find(Customer.class, customer.getId());
    DB.save(customerWithoutChanges);

    assertThat(customerWithoutChanges.getUpdtime()).isEqualToIgnoringMillis(customer.getUpdtime());

    // cleanup
    DB.delete(customerWithoutChanges);

  }
}