|
HSQLDB example source code file (TransferTable.java)
The HSQLDB TransferTable.java source code/* * For work developed by the HSQL Development Group: * * Copyright (c) 2001-2010, The HSQL Development Group * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, this * list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * * Neither the name of the HSQL Development Group nor the names of its * contributors may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL HSQL DEVELOPMENT GROUP, HSQLDB.ORG, * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * * * * For work originally developed by the Hypersonic SQL Group: * * Copyright (c) 1995-2000, The Hypersonic SQL Group. * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, this * list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * * Neither the name of the Hypersonic SQL Group nor the names of its * contributors may be used to endorse or promote products derived from this * software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE HYPERSONIC SQL GROUP, * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * * This software consists of voluntary contributions made by many individuals * on behalf of the Hypersonic SQL Group. */ package org.hsqldb.util; import java.io.Serializable; import java.sql.SQLException; import java.util.Hashtable; // fredt@users 20011220 - patch 481239 by xponsard@users - enhancements // enhancements to support saving and loading of transfer settings, // transfer of blobs, and catalog and schema names in source db // changes by fredt to allow saving and loading of transfer settings // fredt@users 20020215 - patch 516309 by Nicolas Bazin - enhancements // sqlbob@users 20020325 - patch 1.7.0 - reengineering // fredt@users 20040508 - patch 1.7.2 - bug fixes /** * Transfers data from one database to another * * @author Thomas Mueller (Hypersonic SQL Group) * @version 1.7.2 * @since Hypersonic SQL */ class TransferTable implements Serializable { Hashtable hTypes; DataAccessPoint sourceDb; DataAccessPoint destDb; SQLStatements Stmts = null; Traceable tracer; TransferTable(DataAccessPoint src, String name, String schema, String type, Traceable t) { Stmts = new SQLStatements(); sourceDb = src; Stmts.sSchema = ""; if (schema != null && schema.length() > 0) { Stmts.sSchema = schema; } Stmts.sType = type; Stmts.sDatabaseToConvert = src.databaseToConvert; Stmts.sSourceTable = Stmts.sDestTable = name; tracer = t; if (Stmts.sType.compareTo("TABLE") == 0) { Stmts.sSourceSelect = "SELECT * FROM " + src.helper.formatName(Stmts.sSourceTable); } else if (Stmts.sType.compareTo("VIEW") == 0) { Stmts.sSourceSelect = ""; } } void setDest(String _Schema, DataAccessPoint dest) throws Exception { destDb = dest; dest.helper.setSchema(_Schema); } /** * extractTableStructure * * @param Source * @param Destination * @throws Exception */ void extractTableStructure(DataAccessPoint Source, DataAccessPoint Destination) throws Exception { initTypes(); Source.getTableStructure(this, Destination); } /** * @throws SQLException */ void transferStructure() throws Exception { String Statement = new String(""); if (destDb.helper.needTransferTransaction()) { try { destDb.setAutoCommit(false); } catch (Exception e) {} } if (Stmts.bTransfer == false) { tracer.trace("Table " + Stmts.sSourceTable + " not transfered"); return; } tracer.trace("Table " + Stmts.sSourceTable + ": start transfer"); try { if (Stmts.bDropIndex) { if (Stmts.sDestDropIndex.charAt(Stmts.sDestDropIndex.length() - 1) != ';') { Stmts.sDestDropIndex += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestDropIndex.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestDropIndex.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } try { tracer.trace("Executing " + Statement); destDb.execute(Statement); } catch (Exception e) { tracer.trace("Ignoring error " + e.getMessage()); } lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestDropIndex.substring( lastsemicolon).indexOf(';'); } } if (Stmts.bDelete) { if (Stmts.sDestDelete.charAt(Stmts.sDestDelete.length() - 1) != ';') { Stmts.sDestDelete += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestDelete.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestDelete.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } try { tracer.trace("Executing " + Statement); destDb.execute(Statement); } catch (Exception e) { tracer.trace("Ignoring error " + e.getMessage()); } lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestDelete.substring( lastsemicolon).indexOf(';'); } } if (Stmts.bDrop) { if (Stmts.sDestDrop.charAt(Stmts.sDestDrop.length() - 1) != ';') { Stmts.sDestDrop += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestDrop.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestDrop.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } try { tracer.trace("Executing " + Statement); destDb.execute(Statement); } catch (Exception e) { tracer.trace("Ignoring error " + e.getMessage()); } lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestDrop.substring( lastsemicolon).indexOf(';'); } } if (Stmts.bCreate) { if (Stmts.sDestCreate.charAt(Stmts.sDestCreate.length() - 1) != ';') { Stmts.sDestCreate += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestCreate.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestCreate.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } tracer.trace("Executing " + Statement); destDb.execute(Statement); lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestCreate.substring( lastsemicolon).indexOf(';'); } } } catch (Exception e) { try { if (!destDb.getAutoCommit()) { destDb.rollback(); } } catch (Exception e1) {} throw (e); } if (!destDb.getAutoCommit()) { destDb.commit(); try { destDb.setAutoCommit(true); } catch (Exception e) {} } } void transferData(int iMaxRows) throws Exception, SQLException { if (destDb.helper.needTransferTransaction()) { try { destDb.setAutoCommit(false); } catch (Exception e) {} } try { if (Stmts.bInsert) { if (destDb.helper.needTransferTransaction()) { try { destDb.setAutoCommit(false); } catch (Exception e) {} } tracer.trace("Executing " + Stmts.sSourceSelect); TransferResultSet r = sourceDb.getData(Stmts.sSourceSelect); tracer.trace("Start transfering data..."); destDb.beginDataTransfer(); tracer.trace("Executing " + Stmts.sDestInsert); destDb.putData(Stmts.sDestInsert, r, iMaxRows); destDb.endDataTransfer(); tracer.trace("Finished"); if (!destDb.getAutoCommit()) { destDb.commit(); try { destDb.setAutoCommit(true); } catch (Exception e) {} } } } catch (Exception e) { try { if (!destDb.getAutoCommit()) { destDb.rollback(); } } catch (Exception e1) {} throw (e); } if (!destDb.getAutoCommit()) { destDb.commit(); try { destDb.setAutoCommit(true); } catch (Exception e) {} } } void transferAlter() throws Exception { String Statement = new String(""); if (destDb.helper.needTransferTransaction()) { try { destDb.setAutoCommit(false); } catch (Exception e) {} } if (Stmts.bTransfer == false) { tracer.trace("Table " + Stmts.sSourceTable + " not transfered"); return; } tracer.trace("Table " + Stmts.sSourceTable + ": start alter"); try { if (Stmts.bCreateIndex) { if (Stmts.sDestCreateIndex.charAt( Stmts.sDestCreateIndex.length() - 1) != ';') { Stmts.sDestCreateIndex += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestCreateIndex.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestCreateIndex.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } try { tracer.trace("Executing " + Stmts.sDestCreateIndex); destDb.execute(Statement); } catch (Exception e) { tracer.trace("Ignoring error " + e.getMessage()); } lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestCreateIndex.substring( lastsemicolon).indexOf(';'); } } if (Stmts.bAlter) { if (Stmts.sDestAlter.charAt(Stmts.sDestAlter.length() - 1) != ';') { Stmts.sDestAlter += ";"; } int lastsemicolon = 0; int nextsemicolon = Stmts.sDestAlter.indexOf(';'); while (nextsemicolon > lastsemicolon) { Statement = Stmts.sDestAlter.substring(lastsemicolon, nextsemicolon); while (Statement.charAt(Statement.length() - 1) == ';') { Statement = Statement.substring(0, Statement.length() - 1); } try { tracer.trace("Executing " + Statement); destDb.execute(Statement); } catch (Exception e) { tracer.trace("Ignoring error " + e.getMessage()); } lastsemicolon = nextsemicolon + 1; nextsemicolon = lastsemicolon + Stmts.sDestAlter.substring( lastsemicolon).indexOf(';'); } } } catch (Exception e) { try { if (!destDb.getAutoCommit()) { destDb.rollback(); } } catch (Exception e1) {} throw (e); } if (!destDb.getAutoCommit()) { destDb.commit(); try { destDb.setAutoCommit(true); } catch (Exception e) {} } } private void initTypes() throws SQLException { if (hTypes != null) { return; } hTypes = destDb.helper.getSupportedTypes(); } } Other HSQLDB examples (source code examples)Here is a short list of links related to this HSQLDB TransferTable.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2024 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.