package org.apache.torque.engine.platform;

 /*

  * 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

  *

  * Unless required by applicable law or agreed to in writing,

  * software distributed under the License is distributed on an

  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY

  * KIND, either express or implied.  See the License for the

  * specific language governing permissions and limitations

  * under the License.

  */

 import java.sql.Connection;

 import java.sql.DatabaseMetaData;

 import java.sql.PreparedStatement;

 import java.sql.ResultSet;

 import java.sql.SQLException;

 import java.util.List;

 import org.apache.torque.engine.database.model.Domain;

 import org.apache.torque.engine.database.model.SchemaType;

 /**

  * Oracle Platform implementation.

  * 

  * @author <a href="mailto:mpoeschl@marmot.at">Martin Poeschl</a>

  * @version $Id: PlatformOracleImpl.java,v 1.1.6.1 2008-04-18 17:04:37 jkeller Exp $

  */

 public class PlatformOracleImpl extends PlatformDefaultImpl {

         /**

          * Default constructor.

          */

         public PlatformOracleImpl() {

                 super();

                 initialize();

         }

         /**

          * Initializes db specific domain mapping.

          */

         private void initialize() {

                 setSchemaDomainMapping(new Domain(SchemaType.TINYINT, "NUMBER", "3", "0"));

                 setSchemaDomainMapping(new Domain(SchemaType.SMALLINT, "NUMBER", "5", "0"));

                 setSchemaDomainMapping(new Domain(SchemaType.INTEGER, "NUMBER", "10", "0"));

                 setSchemaDomainMapping(new Domain(SchemaType.BOOLEANINT, "NUMBER", "1", "0"));

                 setSchemaDomainMapping(new Domain(SchemaType.BIGINT, "NUMBER", "20", "0"));

                 setSchemaDomainMapping(new Domain(SchemaType.REAL, "NUMBER"));

                 setSchemaDomainMapping(new Domain(SchemaType.DOUBLE, "FLOAT"));

                 setSchemaDomainMapping(new Domain(SchemaType.DECIMAL, "NUMBER"));

                 setSchemaDomainMapping(new Domain(SchemaType.NUMERIC, "NUMBER"));

                 setSchemaDomainMapping(new Domain(SchemaType.VARCHAR, "VARCHAR2"));

                 setSchemaDomainMapping(new Domain(SchemaType.LONGVARCHAR, "VARCHAR2", "2000"));

                 setSchemaDomainMapping(new Domain(SchemaType.TIME, "DATE"));

                 setSchemaDomainMapping(new Domain(SchemaType.TIMESTAMP, "TIMESTAMP"));

                 setSchemaDomainMapping(new Domain(SchemaType.BINARY, "LONG RAW"));

                 setSchemaDomainMapping(new Domain(SchemaType.VARBINARY, "BLOB"));

                 setSchemaDomainMapping(new Domain(SchemaType.LONGVARBINARY, "LONG RAW"));

         }

         @Override

         public String getSchemaName(String artifactId) {

                 String s = super.getSchemaName(artifactId);

                 return s.toUpperCase();

         }

         /**

          * @see Platform#getMaxColumnNameLength()

          */

         public int getMaxColumnNameLength() {

                 return 30;

         }

         /**

          * @see Platform#getNativeIdMethod()

          */

         public String getNativeIdMethod() {

                 return Platform.SEQUENCE;

         }

         /**

          * @see Platform#getAutoIncrement()

          */

         public String getAutoIncrement() {

                 return "";

         }

         @Override

         public List<String> getPrimaryKeys(DatabaseMetaData dbMeta, String dbSchema, String tableName) throws SQLException {

                 return super.getPrimaryKeys(dbMeta, dbSchema.toUpperCase(), tableName);

         }

         public List<String> getTableNames(DatabaseMetaData dbMeta, String databaseSchema) throws SQLException {

                 return super.getTableNames(dbMeta, databaseSchema.toUpperCase());

         }

         @Override

         public boolean isSpecialDefault(String defaultValue) {

                 defaultValue = defaultValue.toUpperCase();

                 if (defaultValue.contains("SYS_GUID()") || defaultValue.contains("SYSDATE") || defaultValue.contains("USERENV(\'SESSIONID\')")) {

                         return true;

                 }

                 return false;

         }

         @Override

         public Long getSequenceNextVal(Connection con, String schema, String sequenceName) {

                 try {

                         PreparedStatement ps = con.prepareStatement("SELECT last_number FROM all_sequences WHERE sequence_owner = ? AND sequence_name = ?");

                         Long nextVal = 0L;

                         ps.setString(1, schema.toUpperCase());

                         ps.setString(2, sequenceName.toUpperCase());

                         ResultSet rs = ps.executeQuery();

                         if (rs.next()) {

                                 nextVal = rs.getLong(1);

                         }

                         rs.close();

                         ps.close();

                         return nextVal;

                 } catch (SQLException ex) {

                         System.err.println("Unable to extract sequence definition: " + schema + "." + sequenceName);

                         ex.printStackTrace();

                         return 0L;

                 }

         }

         @Override

         public String getViewDefinition(Connection con, String schema, String viewName) {

                 try {

                         PreparedStatement ps = con.prepareStatement("SELECT text FROM all_views WHERE owner = ? AND view_name = ?");

                         String definition = "";

                         ps.setString(1, schema.toUpperCase());

                         ps.setString(2, viewName.toUpperCase());

                         ResultSet rs = ps.executeQuery();

                         if (rs.next()) {

                                 definition = rs.getString(1);

                         }

                         rs.close();

                         ps.close();

                         return definition;

                 } catch (SQLException ex) {

                         System.err.println("Unable to extract view definition: " + schema + "." + viewName);

                         ex.printStackTrace();

                         return "";

                 }

         }

 }