1 files changed, 145 insertions, 0 deletions
diff --git a/wizards/com/sun/star/wizards/db/RelationController.java b/wizards/com/sun/star/wizards/db/RelationController.java
new file mode 100644
index 000000000..0c77d92bb
--- /dev/null
+++ b/wizards/com/sun/star/wizards/db/RelationController.java
@@ -0,0 +1,145 @@
+/*
+ * This file is part of the LibreOffice project.
+ *
+ * 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/.
+ *
+ * This file incorporates work covered by the following license notice:
+ *
+ *   Licensed to the Apache Software Foundation (ASF) under one or more
+ *   contributor license agreements. See the NOTICE file distributed
+ *   with this work for additional information regarding copyright
+ *   ownership. The ASF licenses this file to you under the Apache
+ *   License, Version 2.0 (the "License"); you may not use this file
+ *   except in compliance with the License. You may obtain a copy of
+ *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
+ */
+package com.sun.star.wizards.db;
+
+import java.util.ArrayList;
+
+import com.sun.star.sdbc.SQLException;
+import com.sun.star.sdbc.XResultSet;
+import com.sun.star.sdbc.XRow;
+import com.sun.star.uno.UnoRuntime;
+import com.sun.star.wizards.common.JavaTools;
+import com.sun.star.wizards.common.PropertyNames;
+
+/**
+ * TODO To change the template for this generated type comment go to
+ * Window - Preferences - Java - Code Style - Code Templates
+ */
+public class RelationController extends CommandName
+{
+
+    private static final int PKTABLE_CAT = 1;
+    private static final int PKTABLE_SCHEM = 2;
+    private static final int PKTABLE_NAME = 3;
+    private static final int PKCOLUMN_NAME = 4;
+    private static final int FKTABLE_CAT = 5;
+    private static final int FKTABLE_SCHEM = 6;
+    private static final int FKTABLE_NAME = 7;
+    private static final int FKCOLUMN_NAME = 8;
+
+    public RelationController(CommandMetaData _CommandMetaData, String _DisplayName)
+    {
+        super(_CommandMetaData, _DisplayName);
+    }
+
+    public String[] getExportedKeys()
+    {
+        String[] sReferencedTableNames = new String[]
+        {
+        };
+        try
+        {
+            ArrayList<String> aReferencedTableVector = new ArrayList<String>();
+            XResultSet xResultSet = super.getCommandMetaData().xDBMetaData.getExportedKeys(getCatalogName(this), getSchemaName(), getTableName());
+            XRow xRow = UnoRuntime.queryInterface(XRow.class, xResultSet);
+            while (xResultSet.next())
+            {
+                String sForeignCatalog = xRow.getString(FKTABLE_CAT);
+                String sForeignScheme = xRow.getString(FKTABLE_SCHEM);
+                String sForeignTableName = xRow.getString(FKTABLE_NAME);
+                CommandName oCommandName = new CommandName(getCommandMetaData(), sForeignCatalog, sForeignScheme, sForeignTableName, false);
+                aReferencedTableVector.add(oCommandName.getComposedName());
+            }
+            sReferencedTableNames = new String[aReferencedTableVector.size()];
+            aReferencedTableVector.toArray(sReferencedTableNames);
+        }
+        catch (SQLException e)
+        {
+            e.printStackTrace(System.err);
+        }
+        return sReferencedTableNames;
+    }
+
+    private Object getCatalogName(CommandName _oCommandName)
+    {
+        String sLocCatalog = _oCommandName.getCatalogName();
+        if (sLocCatalog.equals(PropertyNames.EMPTY_STRING))
+        {
+            return null;
+        }
+        else
+        {
+            return sLocCatalog;
+        }
+    }
+
+    public String[][] getImportedKeyColumns(String _sreferencedtablename)
+    {
+        String[][] sKeyColumnNames = new String[][]
+        {
+        };
+        try
+        {
+            CommandName oLocCommandName = new CommandName(super.getCommandMetaData(), _sreferencedtablename);
+            XResultSet xResultSet = super.getCommandMetaData().xDBMetaData.getImportedKeys(getCatalogName(oLocCommandName), oLocCommandName.getSchemaName(), oLocCommandName.getTableName());
+            XRow xRow = UnoRuntime.queryInterface(XRow.class, xResultSet);
+            boolean bleaveLoop = false;
+            ArrayList<String> aMasterFieldNamesVector = new ArrayList<String>();
+            ArrayList<String> aSlaveFieldNamesVector = new ArrayList<String>();
+            while (xResultSet.next() && !bleaveLoop)
+            {
+                String sPrimaryCatalog = null;
+                String sPrimarySchema = null;
+                if (super.getCommandMetaData().xDBMetaData.supportsCatalogsInDataManipulation())
+                {
+                    sPrimaryCatalog = xRow.getString(PKTABLE_CAT);
+                }
+                if (super.getCommandMetaData().xDBMetaData.supportsSchemasInDataManipulation())
+                {
+                    sPrimarySchema = xRow.getString(PKTABLE_SCHEM);
+                }
+                String sPrimaryTableName = xRow.getString(PKTABLE_NAME);
+                String sPrimaryColumnName = xRow.getString(PKCOLUMN_NAME);
+                String sForeignColumnName = xRow.getString(FKCOLUMN_NAME);
+                if (JavaTools.isSame(getTableName(), sPrimaryTableName))
+                {
+                    if (sPrimarySchema == null || JavaTools.isSame(getSchemaName(), sPrimarySchema))
+                    {
+                        if (JavaTools.isSame(getCatalogName(), sPrimaryCatalog))
+                        {
+                            aSlaveFieldNamesVector.add(sForeignColumnName);
+                            aMasterFieldNamesVector.add(sPrimaryColumnName);
+                            bleaveLoop = true;                  //Only one relation may exist between two tables...
+                        }
+                    }
+
+                }
+            }
+            sKeyColumnNames = new String[2][aMasterFieldNamesVector.size()];
+            sKeyColumnNames[0] = new String[aSlaveFieldNamesVector.size()];
+            sKeyColumnNames[1] = new String[aMasterFieldNamesVector.size()];
+            aSlaveFieldNamesVector.toArray(sKeyColumnNames[0]);
+            aMasterFieldNamesVector.toArray(sKeyColumnNames[1]);
+        }
+        catch (Exception e)
+        {
+            e.printStackTrace(System.err);
+        }
+        return sKeyColumnNames;
+    }
+}