-[option tmpDirectory]

-description = observe.config.defaultTmpDirectory.description

-observe.config.defaultTmpDirectory.description

-public class ClientConfig extends GeneratedClientConfig implements NavigationTreeConfig {

-import org.apache.commons.io.FileUtils;

-import static fr.ird.observe.client.configuration.ClientConfigOption.TMP_DIRECTORY;

-        resourceManager.createDirectory(config, TMP_DIRECTORY);

-

-        // suppression du contenu du répertoire temporaire

-        FileUtils.cleanDirectory(config.getTmpDirectory());

-

-

-

-        File tmpDirectory = config.getTmpDirectory();

-        File tmpDirectory = config.getTmpDirectory();

-        helper.addOption(ClientConfigOption.TMP_DIRECTORY);

-observe.config.defaultTmpDirectory.description=Default temporary directory used by application and clean at each launch.

-observe.config.defaultTmpDirectory.description=Directorio temporal por defecto

-observe.config.defaultTmpDirectory.description=Le répertoire temporaire par défaut

-package fr.ird.observe.persistence;

-

-/*

- * #%L

- * ObServe :: Persistence

- * %%

- * Copyright (C) 2008 - 2020 IRD, Code Lutin, Ultreia.io

- * %%

- * This program is free software: you can redistribute it and/or modify

- * it under the terms of the GNU General Public License as

- * published by the Free Software Foundation, either version 3 of the

- * License, or (at your option) any later version.

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public

- * License along with this program.  If not, see

- * <http://www.gnu.org/licenses/gpl-3.0.html>.

- * #L%

- */

-

-import fr.ird.observe.entities.ObserveEntity;

-import org.nuiton.topia.persistence.internal.AbstractTopiaDao;

-import org.nuiton.topia.persistence.support.TopiaSqlQuery;

-

-import java.sql.Connection;

-import java.sql.PreparedStatement;

-import java.sql.ResultSet;

-import java.sql.SQLException;

-import java.sql.Timestamp;

-import java.util.Date;

-import java.util.List;

-import java.util.Map;

-

-public abstract class AbstractObserveTopiaDao<E extends ObserveEntity> extends AbstractTopiaDao<E> {

-

-    private final GetLastupdateDateSqlQuery getLastUpdateDateSqlQuery;

-

-    protected AbstractObserveTopiaDao() {

-        String schemaName = getTopiaEntityEnum().dbSchemaName();

-        String tableName = getTopiaEntityEnum().dbTableName();

-        getLastUpdateDateSqlQuery = new GetLastupdateDateSqlQuery(schemaName, tableName);

-    }

-

-    public Date getLastUpdateDate() {

-        return topiaSqlSupport.findSingleResult(getLastUpdateDateSqlQuery);

-    }

-

-    public <O> List<O> findAllFromHql(String hql, Map<String, Object> hqlParameters) {

-        return findAll(hql, hqlParameters);

-    }

-

-    private static class GetLastupdateDateSqlQuery extends TopiaSqlQuery<Timestamp> {

-

-        protected final String sql;

-

-        private GetLastupdateDateSqlQuery(String schemaName, String tableName) {

-            this.sql = "SELECT max(" + ObserveEntity.PROPERTY_LAST_UPDATE_DATE + ") FROM " + schemaName + "." + tableName;

-        }

-

-        @Override

-        public PreparedStatement prepareQuery(Connection connection) throws SQLException {

-            return connection.prepareStatement(sql);

-        }

-

-        @Override

-        public Timestamp prepareResult(ResultSet set) throws SQLException {

-            return set.getTimestamp(1);

-        }

-

-    }

-

-

-}

-package fr.ird.observe.persistence;

-

-/*

- * #%L

- * ObServe :: Persistence

- * %%

- * Copyright (C) 2008 - 2020 IRD, Code Lutin, Ultreia.io

- * %%

- * This program is free software: you can redistribute it and/or modify

- * it under the terms of the GNU General Public License as

- * published by the Free Software Foundation, either version 3 of the

- * License, or (at your option) any later version.

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public

- * License along with this program.  If not, see

- * <http://www.gnu.org/licenses/gpl-3.0.html>.

- * #L%

- */

-

-import org.nuiton.topia.persistence.BeanTopiaConfiguration;

-import org.nuiton.topia.persistence.HibernateAvailableSettings;

-import org.nuiton.topia.persistence.jdbc.JdbcConfiguration;

-

-import java.io.IOException;

-import java.io.InputStream;

-import java.util.Map;

-import java.util.Properties;

-import java.util.TreeMap;

-

-/**

- * Created on 23/08/15.

- *

- * @author Tony Chemit - dev@tchemit.fr

- */

-public class ObserveTopiaConfiguration extends BeanTopiaConfiguration {

-

-    private static final long serialVersionUID = 1L;

-

-    private final boolean h2Configuration;

-    protected final boolean showSql;

-    private static final Map<String, String> HIBERNATE_GLOBAL_PROPERTIES;

-

-    static {

-

-        Properties p = new Properties();

-        try (InputStream stream = ObserveTopiaPersistenceContext.class.getResourceAsStream("/hibernate.properties")) {

-            try {

-                p.load(stream);

-            } catch (IOException e) {

-                throw new IllegalStateException(e);

-            }

-        } catch (IOException e) {

-            throw new IllegalStateException(e);

-        }

-        HIBERNATE_GLOBAL_PROPERTIES = new TreeMap<>();

-        for (String s : p.stringPropertyNames()) {

-            HIBERNATE_GLOBAL_PROPERTIES.put(s, p.getProperty(s));

-        }

-

-    }

-

-    public ObserveTopiaConfiguration(JdbcConfiguration jdbcConfiguration, boolean h2Configuration, boolean showSql) {

-        super(jdbcConfiguration);

-        this.h2Configuration = h2Configuration;

-        this.showSql = showSql;

-        if (showSql) {

-            hibernateExtraConfiguration.put(HibernateAvailableSettings.SHOW_SQL, Boolean.TRUE.toString());

-        }

-        hibernateExtraConfiguration.putAll(HIBERNATE_GLOBAL_PROPERTIES);

-    }

-

-    public boolean isH2Configuration() {

-        return h2Configuration;

-    }

-

-    public boolean isShowSql() {

-        return showSql;

-    }

-}

-package fr.ird.observe.persistence;

-

-/*

- * #%L

- * ObServe :: Persistence

- * %%

- * Copyright (C) 2008 - 2020 IRD, Code Lutin, Ultreia.io

- * %%

- * This program is free software: you can redistribute it and/or modify

- * it under the terms of the GNU General Public License as

- * published by the Free Software Foundation, either version 3 of the

- * License, or (at your option) any later version.

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public

- * License along with this program.  If not, see

- * <http://www.gnu.org/licenses/gpl-3.0.html>.

- * #L%

- */

-

-import org.apache.logging.log4j.Logger;

-import org.apache.logging.log4j.LogManager;

-import org.nuiton.topia.persistence.jdbc.JdbcConfiguration;

-import org.nuiton.topia.persistence.jdbc.JdbcConfigurationBuilder;

-import org.nuiton.topia.service.migration.TopiaMigrationService;

-import org.nuiton.topia.service.script.TopiaSqlScriptGeneratorServiceImpl;

-

-import java.io.File;

-

-/**

- * Created on 23/08/15.

- *

- * @author Tony Chemit - dev@tchemit.fr

- */

-public class ObserveTopiaConfigurationFactory {

-

-    /** l'url d'acces a la base locale */

-    private static final String H2_LOCAL_URL =

-            "jdbc:h2:file:%s;" +

-                    // on peut aussi utiliser file, socket

-                    "FILE_LOCK=file;" +

-                    //1 or 2 is needed to restore avec crash

-                    // 0: logging is disabled (faster),

-                    // 1: logging of the data is enabled, but logging of the index

-                    // changes is disabled (default), 2: logging of both data and index

-                    // changes are enabled

-                    "LOG=0;" +

-                    // on peut aussi utiliser hsqldb, mysql ou postgresql

-                    "MODE=postgresql;" +

-                    //"MODE=hsqldb;" +

-                    // Sets the default lock timeout (in milliseconds) in this

-                    // database that is used for the new sessions.

-                    "DEFAULT_LOCK_TIMEOUT=100;" +

-                    // -1: the database is never closed until the close delay is set to

-                    // some other rev or SHUTDOWN is called., 0: no delay (default; the

-                    // database is closed if the last connection to it is closed)., n:

-                    // the database is left open for n second after the last connection

-                    // is closed.

-                    "DB_CLOSE_DELAY=0;" +

-                    // 0: no locking (should only be used for testing),

-                    // 1: table level locking (default),

-                    // 2: table level locking with garbage collection (if the

-                    // application does not close all connections).

-                    // LOCK_MODE 3 (READ_COMMITTED). Table level locking, but only when

-                    // writing (no read locks).

-                    "LOCK_MODE=3;" +

-                    // Levels: 0=off, 1=error, 2=info, 3=debug.

-                    "TRACE_LEVEL_FILE=0;" +

-                    // on system.out: 0=off, 1=error, 2=info, 3=debug.

-                    "TRACE_LEVEL_SYSTEM_OUT=0;" +

-                    // maximumn cache to improve performance...

-                    "CACHE_SIZE=65536;" +

-                    // avoid timeout on reading tables (see http://stackoverflow.com/questions/4162557/timeout-error-trying-to-lock-table-in-h2)

-                    "MVCC=true";

-

-    private static final JdbcConfigurationBuilder JDBC_CONFIGURATION_BUILDER = new JdbcConfigurationBuilder();

-    private static final Logger log = LogManager.getLogger(ObserveTopiaConfigurationFactory.class);

-

-    public static ObserveTopiaConfiguration forPostgresqlDatabase(String jdbcUrl,

-                                                                  String username,

-                                                                  String password,

-                                                                  boolean initSchema,

-                                                                  boolean traceSql) {

-

-        JdbcConfiguration jdbcConfiguration = JDBC_CONFIGURATION_BUILDER.forPostgresqlDatabase(jdbcUrl, username, password);

-

-        ObserveTopiaConfiguration topiaConfiguration = createTopiaConfiguration(jdbcConfiguration,

-                initSchema,

-                false,

-                traceSql);

-

-        log.debug("PG topia configuration: " + topiaConfiguration);

-        return topiaConfiguration;

-

-    }

-

-    public static ObserveTopiaConfiguration forH2Database(File dbDirectory,

-                                                          String dbName,

-                                                          String username,

-                                                          String password,

-                                                          boolean initSchema,

-                                                          boolean traceSql) {

-

-        String dbPath = new File(dbDirectory, dbName).getPath();

-        String jdbcUrl = String.format(H2_LOCAL_URL, dbPath);

-

-        JdbcConfiguration jdbcConfiguration = JDBC_CONFIGURATION_BUILDER.forH2Database(jdbcUrl, username, password);

-

-        ObserveTopiaConfiguration topiaConfiguration = createTopiaConfiguration(jdbcConfiguration,

-                initSchema,

-                true,

-                traceSql);

-

-        log.debug("H2 topia configuration: " + topiaConfiguration);

-        return topiaConfiguration;

-

-    }

-

-    private static ObserveTopiaConfiguration createTopiaConfiguration(JdbcConfiguration jdbcConfiguration,

-                                                                      boolean initSchema,

-                                                                      boolean h2Configuration,

-                                                                      boolean traceSql) {

-

-        ObserveTopiaConfiguration topiaConfiguration = new ObserveTopiaConfiguration(jdbcConfiguration, h2Configuration, traceSql);

-        topiaConfiguration.setTopiaIdFactoryClass(ObserveTopiaIdFactory.class);

-        topiaConfiguration.setInitSchema(initSchema);

-        topiaConfiguration.setValidateSchema(false);

-        topiaConfiguration.setUseHikariForJdbcConnectionPooling(true);

-

-        log.debug("jdbcUrl: " + topiaConfiguration.getJdbcConnectionUrl());

-

-        topiaConfiguration.addDeclaredService(ObserveTopiaApplicationContext.MIGRATION_SERVICE_NAME, TopiaMigrationService.class);

-        topiaConfiguration.addDeclaredService(ObserveTopiaApplicationContext.SQL_SCRIPT_GENERATOR_BATCH_SERVICE_NAME, TopiaSqlScriptGeneratorServiceImpl.class);

-

-        return topiaConfiguration;

-

-    }

-

-}

-package fr.ird.observe.persistence;

-

-/*

- * #%L

- * ObServe :: Persistence

- * %%

- * Copyright (C) 2008 - 2020 IRD, Code Lutin, Ultreia.io

- * %%

- * This program is free software: you can redistribute it and/or modify

- * it under the terms of the GNU General Public License as

- * published by the Free Software Foundation, either version 3 of the

- * License, or (at your option) any later version.

- *

- * This program is distributed in the hope that it will be useful,

- * but WITHOUT ANY WARRANTY; without even the implied warranty of

- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

- * GNU General Public License for more details.

- *

- * You should have received a copy of the GNU General Public

- * License along with this program.  If not, see

- * <http://www.gnu.org/licenses/gpl-3.0.html>.

- * #L%

- */

-

-import org.apache.commons.lang3.StringUtils;

-import org.apache.logging.log4j.LogManager;

-import org.apache.logging.log4j.Logger;

-import org.nuiton.topia.persistence.TopiaEntity;

-import org.nuiton.topia.persistence.internal.LegacyTopiaIdFactory;

-

-/**

- * Created on 21/08/15.

- *

- * @author Tony Chemit - dev@tchemit.fr

- */

-public class ObserveTopiaIdFactory extends LegacyTopiaIdFactory {

-

-    private static final Logger log = LogManager.getLogger(ObserveTopiaIdFactory.class);

-

-    private static final long serialVersionUID = 1L;

-

-    public <E extends TopiaEntity> String newTopiaId(Class<E> entityType) {

-

-        double random = Math.random();

-        while (Double.toString(random).contains("E-")) {

-            random = Math.random();

-        }

-        return newTopiaId(entityType, random + "");

-    }

-

-    public <E extends TopiaEntity> boolean isTopiaId(Class<E> entityClass, String str) {

-        boolean isTopiaId = false;

-        if (str != null && !str.endsWith(getSeparator())) {

-            String[] split = str.split(getSeparator());

-            if (split.length == 3) {

-                String className = split[0];

-                isTopiaId = entityClass.getName().equals(className);

-                for (int index = 1; index < split.length; index++) {

-                    isTopiaId &= StringUtils.isNumeric(split[index]);

-                }

-            }

-        }

-        return isTopiaId;

-    }

-

-    @Override

-    public boolean isTopiaId(String str) {

-        boolean isTopiaId = false;

-        if (str != null && !str.endsWith(getSeparator())) {

-            String[] split = str.split(getSeparator());

-            if (split.length == 3) {

-                String className = split[0];

-                try {

-                    Class.forName(className);

-                    isTopiaId = true;

-                    for (int index = 1; index < split.length; index++) {

-                        isTopiaId &= StringUtils.isNumeric(split[index]);

-                    }

-                } catch (ClassNotFoundException eee) {

-                    // nothing to do, just return false

-                    if (log.isDebugEnabled()) {

-                        log.debug(eee);

-                    }

-                }

-            }

-        }

-        return isTopiaId;

-    }

-

-}

-    <version>2020.15</version>

-    <observeToolkitVersion>3.7.27</observeToolkitVersion>

-    <lib.version.java4all.topia>1.1.16</lib.version.java4all.topia>

-public class ServerConfig extends GeneratedServerConfig {

-    public ObserveSecurityHelper(JdbcConfiguration jdbcConfiguration) {

-

-            scriptPath = Files.createTempFile("topia-sql-script-", ".sql");