+
−/*
+
− * SPDX-License-Identifier: MPL-2.0
+
− *
+
− * This Source Code Form is subject to the terms of the Mozilla Public
+
− * License, v. 2.0.  If a copy of the MPL was not distributed with this
+
− * file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
− *
+
− * Copyright 2024, 2025 MonetDB Foundation;
+
− * Copyright August 2008 - 2023 MonetDB B.V.;
+
− * Copyright 1997 - July 2008 CWI.
+
− */
+
−
+
−package org.monetdb.util;
+
−
+
−import org.monetdb.jdbc.MonetWrapper;	// for dq() and sq()
+
−
+
−import java.io.PrintWriter;
+
−import java.sql.ResultSet;
+
−import java.sql.SQLException;
+
−
+
−public abstract class Exporter {
+
−	protected PrintWriter out;
+
−	protected boolean useSchema;
+
−
+
−	protected Exporter(final PrintWriter out) {
+
−		this.out = out;
+
−	}
+
−
+
−	public abstract void dumpSchema(
+
−			final java.sql.DatabaseMetaData dbmd,
+
−			final String type,
+
−			final String schema,
+
−			final String name) throws SQLException;
+
−
+
−	public abstract void dumpResultSet(final ResultSet rs) throws SQLException;
+
−
+
−	public abstract void setProperty(final int type, final int value) throws Exception;
+
−	public abstract int getProperty(final int type) throws Exception;
+
−
+
−
+
−	//=== shared utilities
+
−
+
−	public final void useSchemas(final boolean use) {
+
−		useSchema = use;
+
−	}
+
−
+
−	/**
+
−	 * Convenience function to call the general utility function MonetWrapper.dq()
+
−	 * to add double quotes around an SQL Identifier such as column or
+
−	 * table or schema name in SQL queries.
+
−	 * It also adds escapes for special characters: double quotes and the escape character
+
−	 *
+
−	 * FYI: it is made public as it is also called from client/JdbcClient.java
+
−	 *
+
−	 * @param in the string to quote
+
−	 * @return the quoted string
+
−	 */
+
−	public static final String dq(final String in) {
+
−		return MonetWrapper.dq(in);
+
−	}
+
−
+
−	/**
+
−	 * Convenience function to call the general utility function MonetWrapper.sq()
+
−	 * to add single quotes around string literals in SQL queries.
+
−	 * It also adds escapes for special characters: single quotes and the escape character
+
−	 *
+
−	 * @param in the string to quote
+
−	 * @return the quoted string
+
−	 */
+
−	protected static final String sq(final String in) {
+
−		return MonetWrapper.sq(in);
+
−	}
+
−
+
−	/**
+
−	 * Simple helper function to repeat a given character a number of times.
+
−	 *
+
−	 * @param chr the character to repeat
+
−	 * @param cnt the number of times to repeat chr
+
−	 * @return a String holding cnt times chr
+
−	 */
+
−	protected static final String repeat(final char chr, final int cnt) {
+
−		final char[] buf = new char[cnt];
+
−		java.util.Arrays.fill(buf, chr);
+
−		return new String(buf);
+
−	}
+
−
+
−	/**
+
−	 * Utility method to fetch the "query" column value from sys.tables for a specific view or table in a specific schema
+
−	 * The "query" column value contains the original SQL view creation text or the ON clause text when it is a REMOTE TABLE
+
−	 *
+
−	 * @param con the JDBC connection, may not be null
+
−	 * @param schema the schema name, may not be null or empty
+
−	 * @param name the view or table name, may not be null or empty
+
−	 * @return the value of the "query" field for the specified view/table name and schema. It can return null.
+
−	 */
+
−	protected static final String fetchSysTablesQueryValue(
+
−		final java.sql.Connection con,
+
−		final String schema,
+
−		final String name)
+
−	{
+
−		java.sql.Statement stmt = null;
+
−		ResultSet rs = null;
+
−		String val = null;
+
−		try {
+
−			stmt = con.createStatement();
+
−			final String cmd = "SELECT query FROM sys.tables WHERE name = " + sq(name)
+
−				+ " and schema_id IN (SELECT id FROM sys.schemas WHERE name = " + sq(schema) + ")";
+
−			rs = stmt.executeQuery(cmd);
+
−			if (rs != null) {
+
−				if (rs.next()) {
+
−					val = rs.getString(1);
+
−				}
+
−			}
+
−		} catch (SQLException se) {
+
−			/* ignore */
+
−		} finally {
+
−			// free resources
+
−			if (rs != null) {
+
−				try { rs.close(); } catch (SQLException se) { /* ignore */ }
+
−			}
+
−			if (stmt != null) {
+
−				try { stmt.close(); } catch (SQLException se) { /* ignore */ }
+
−			}
+
−		}
+
−		return val;
+
−	}
+
−}