diff --git a/src/main/java/io/kamax/mxisd/storage/ormlite/OrmLiteSqlStorage.java b/src/main/java/io/kamax/mxisd/storage/ormlite/OrmLiteSqlStorage.java index c3a17c2..24457fa 100644 --- a/src/main/java/io/kamax/mxisd/storage/ormlite/OrmLiteSqlStorage.java +++ b/src/main/java/io/kamax/mxisd/storage/ormlite/OrmLiteSqlStorage.java @@ -47,6 +47,8 @@ import io.kamax.mxisd.storage.ormlite.dao.ThreePidInviteIO; import io.kamax.mxisd.storage.ormlite.dao.ThreePidSessionDao; import org.apache.commons.lang.StringUtils; import org.apache.commons.lang3.tuple.Pair; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.io.IOException; import java.sql.SQLException; @@ -61,6 +63,8 @@ import java.util.stream.Collectors; public class OrmLiteSqlStorage implements IStorage { + private static final Logger LOGGER = LoggerFactory.getLogger(OrmLiteSqlStorage.class); + @FunctionalInterface private interface Getter { @@ -124,11 +128,13 @@ public class OrmLiteSqlStorage implements IStorage { } private void fixAcceptedDao(ConnectionSource connPool) throws SQLException { + LOGGER.info("Migration: {}", Migrations.FIX_ACCEPTED_DAO); TableUtils.dropTable(acceptedDao, true); TableUtils.createTableIfNotExists(connPool, AcceptedDao.class); } private Dao createDaoAndTable(ConnectionSource connPool, Class c) throws SQLException { + LOGGER.info("Create the dao: {}", c.getSimpleName()); Dao dao = DaoManager.createDao(connPool, c); TableUtils.createTableIfNotExists(connPool, c); return dao; diff --git a/src/main/java/io/kamax/mxisd/storage/ormlite/dao/AcceptedDao.java b/src/main/java/io/kamax/mxisd/storage/ormlite/dao/AcceptedDao.java index f7a1a56..09ef83d 100644 --- a/src/main/java/io/kamax/mxisd/storage/ormlite/dao/AcceptedDao.java +++ b/src/main/java/io/kamax/mxisd/storage/ormlite/dao/AcceptedDao.java @@ -26,6 +26,9 @@ import com.j256.ormlite.table.DatabaseTable; @DatabaseTable(tableName = "accepted") public class AcceptedDao { + @DatabaseField(generatedId = true) + private Long id; + @DatabaseField(canBeNull = false) private String url; @@ -45,6 +48,14 @@ public class AcceptedDao { this.acceptedAt = acceptedAt; } + public Long getId() { + return id; + } + + public void setId(Long id) { + this.id = id; + } + public String getUrl() { return url; }