Dépôt officiel du code source de l'ERP OpenConcerto

/*

/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

 * 

 * 

 * 

 * 

 * The contents of this file are subject to the terms of the GNU General Public License Version 3

 * The contents of this file are subject to the terms of the GNU General Public License Version 3

 * only ("GPL"). You may not use this file except in compliance with the License. You can obtain a

 * only ("GPL"). You may not use this file except in compliance with the License. You can obtain a

 * copy of the License at http://www.gnu.org/licenses/gpl-3.0.html See the License for the specific

 * copy of the License at http://www.gnu.org/licenses/gpl-3.0.html See the License for the specific

 * language governing permissions and limitations under the License.

 * language governing permissions and limitations under the License.

import org.openconcerto.sql.model.SQLSystem;

import org.openconcerto.sql.model.SQLSystem;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.sql.model.graph.TablesMap;

import org.openconcerto.sql.model.graph.TablesMap;

import org.openconcerto.sql.utils.CSVHandler;

import org.openconcerto.sql.utils.CSVHandler;

import org.openconcerto.sql.utils.ChangeTable;

import org.openconcerto.sql.utils.ChangeTable;

import org.openconcerto.sql.utils.SQLCreateMoveableTable;

import org.openconcerto.sql.utils.SQLCreateMoveableTable;

import org.openconcerto.sql.utils.SQLCreateRoot;

import org.openconcerto.sql.utils.SQLCreateRoot;

import org.openconcerto.sql.utils.SQLCreateTableBase;

import org.openconcerto.sql.utils.SQLCreateTableBase;

import org.openconcerto.sql.utils.SQLUtils;

import org.openconcerto.sql.utils.SQLUtils;

import org.openconcerto.utils.FileUtils;

import org.openconcerto.utils.FileUtils;

import org.openconcerto.utils.RTInterruptedException;

import org.openconcerto.utils.RTInterruptedException;

import org.openconcerto.utils.ThreadFactory;

import org.openconcerto.utils.ThreadFactory;

import org.openconcerto.utils.cc.IClosure;

import org.openconcerto.utils.cc.IClosure;

import java.sql.SQLException;

import java.sql.SQLException;

import java.util.ArrayList;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.HashMap;

import java.util.List;

import java.util.List;

import java.util.Map;

import java.util.Map;

import java.util.Map.Entry;

import java.util.Map.Entry;

import java.util.concurrent.Callable;

import java.util.concurrent.Callable;

import java.util.concurrent.CancellationException;

import java.util.concurrent.CancellationException;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.Executors;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

import java.util.concurrent.Future;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.ScheduledFuture;

import java.util.concurrent.ScheduledFuture;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.TimeUnit;

import java.util.concurrent.atomic.AtomicInteger;

import java.util.concurrent.atomic.AtomicInteger;

import net.jcip.annotations.GuardedBy;

import net.jcip.annotations.GuardedBy;

import net.jcip.annotations.ThreadSafe;

import net.jcip.annotations.ThreadSafe;

/**

/**

 * Allow to replicate some tables in memory.

 * Allow to replicate some tables in memory.

 * 

 * 

 * @author Sylvain

 * @author Sylvain

 */

 */

                throw new IllegalStateException();

                throw new IllegalStateException();

        } else {

        } else {

            this.singleRootName = null;

            this.singleRootName = null;

        }

        }

        // private in-memory database

        // private in-memory database

            @Override

            @Override

            public void executeChecked(DBSystemRoot input) {

            public void executeChecked(DBSystemRoot input) {

                input.setRootsToMap(tables.keySet());

                input.setRootsToMap(tables.keySet());

                // don't waste time on cache for transient data

                // don't waste time on cache for transient data

                input.initUseCache(false);

                input.initUseCache(false);