package  ads;

 import  java.sql.*;
 import  javax.naming.Context;
 import  javax.naming.InitialContext;
 import  javax.naming.NamingException;
 import  javax.sql.DataSource;

/**
 *
 * @author automation10
 */
 public   class  ConnectionClass {

    @SuppressWarnings("CallToThreadDumpStack")
     public   static  Connection initConnection() {

        Connection cn =  null ;
         try  {
            Context ctx =  new  InitialContext();
            DataSource ds = (DataSource) ctx.lookup("jdbc/os_common");
            cn = ds.getConnection();           
        }  catch  (SQLException ex) {
            ex.printStackTrace();
        }  catch  (NamingException ex) {
            ex.printStackTrace();
        }

         return  cn;
    }

}

 public  String save_Info(@WebParam(name = "inArray1") String[][] rec_obje,
    @WebParam(name = "inArray") String[][] inArray,
    @WebParam(name = "inArrayContact") String[][] inContact,
    @WebParam(name = "Gr")  int  group,
    @WebParam(name = "SubGr")  int  subgroup,
    @WebParam(name = "PD") String sxPubDate,
    @WebParam(name = "city")  int  ixCity_id,
    @WebParam(name = "PT")  int  ixPubType,
    @WebParam(name = "PC")  int  ixPubCount,
    @WebParam(name = "orderid")  int  ixOrderId )  throws  UnsupportedEncodingException {

        int  i;
      String arValues="";
        try  {
           
            StructDescriptor structDesc = StructDescriptor.createDescriptor("RECTYPE", cn);
            ArrayDescriptor arrayDesc = ArrayDescriptor.createDescriptor("RECTAB", cn);
            StructDescriptor structDesc1 = StructDescriptor.createDescriptor("OBJ_ELEMENT", cn);
            ArrayDescriptor arrayDesc1 = ArrayDescriptor.createDescriptor("REC_OBJ_ELEMENT", cn);
            StructDescriptor structDesc2 = StructDescriptor.createDescriptor("OBJ_CONTACT", cn);
            ArrayDescriptor arrayDesc2 = ArrayDescriptor.createDescriptor("REC_OBJ_CONTACT", cn);
       
            CharacterSet chs = CharacterSet.make(CharacterSet.CL8MSWIN1251_CHARSET);
            // ?нициализация коллекции для объектов STRUCT.
            ArrayList<STRUCT> arrayList =  new  ArrayList<STRUCT>();
            ArrayList<STRUCT> arrayList1 =  new  ArrayList<STRUCT>();
            ArrayList<STRUCT> arrayList2 =  new  ArrayList<STRUCT>();
           Object[] record= new  Object[rec_obje[ 0 ].length];
                 for   (i= 0 ; i<rec_obje.length;i++){
                record[ 0 ] = Integer.valueOf(rec_obje[i][ 0 ]);
                record[ 1 ] = Integer.valueOf(rec_obje[i][ 1 ]); 
                record[ 2 ] = Integer.valueOf(rec_obje[i][ 2 ]);
                record[ 3 ] = Integer.valueOf(rec_obje[i][ 3 ]);
                record[ 4 ] = Integer.valueOf(rec_obje[i][ 4 ]);
                record[ 5 ] = Integer.valueOf(rec_obje[i][ 5 ]);
               }
            arrayList.add( new  STRUCT(structDesc, cn, record));
            ARRAY array =  new  ARRAY(arrayDesc, cn, arrayList.toArray());
         
             Object[] record1 =  new  Object[inArray[ 0 ].length];
             for  (i =  0 ; i < inArray.length; i++) {
                record1[ 0 ] = Integer.valueOf(inArray[i][ 0 ]);
                record1[ 1 ] =  new   CHAR  (inArray[i][ 1 ].getBytes("cp1251"), chs); 
                record1[ 2 ] = Integer.valueOf(inArray[i][ 2 ]);
                }
               
                arrayList1.add( new  STRUCT(structDesc1, cn, record1));
            }
            ARRAY array1 =  new  ARRAY(arrayDesc1, cn, arrayList1.toArray());
            Object[] record2 =  new  Object[inContact[ 0 ].length];
             for  (i =  0 ; i < inContact.length; i++) {
                record2[ 0 ] = Integer.valueOf(inContact[i][ 0 ]);
                 if  (inContact[i][ 1 ].equals("")){
                    record2[ 1 ] =  0 ;
                }  else  {
                record2[ 1 ] = Integer.valueOf(inContact[i][ 1 ]);
                }
                record2[ 2 ] =  new   CHAR (String.valueOf(inContact[i][ 2 ]).getBytes("cp1251"), chs);
                record2[ 3 ] =  new   CHAR (String.valueOf(inContact[i][ 3 ]).getBytes("cp1251"), chs);
                record2[ 4 ] =  new   CHAR (String.valueOf(inContact[i][ 4 ]).getBytes("cp1251"), chs);
                record2[ 5 ] =  new   CHAR (String.valueOf(inContact[i][ 5 ]).getBytes("cp1251"), chs);

                arrayList2.add( new  STRUCT(structDesc2, cn, record2));
            }
            ARRAY array2 =  new  ARRAY(arrayDesc2, cn, arrayList2.toArray());

            st =  cn.prepareCall("begin pkg_ads.save_object(?,?,?,?,?,?,?,?,?,?); end;");
            arValues="1";
            st.setObject( 1 , array, OracleTypes.ARRAY);
            st.setObject( 2 , array1,OracleTypes.ARRAY);
            st.setObject( 3 , array2,OracleTypes.ARRAY);
            st.setInt( 4 ,group);
            st.setInt( 5 ,subgroup);
            st.setString( 6 , sxPubDate);
            st.setInt( 7 ,ixCity_id);
            st.setInt( 8 , ixPubType);
            st.setInt( 9 , ixPubCount);
            st.setInt( 10 , ixOrderId);
            st.execute();
 
        st.close();
        cn.close();
        
         arValues="2";
        }  catch  (SQLException e) {
            //arValues="noSAVE";
            System.out.print(e.toString());
        }
//----------------------
 
         return  arValues;
    }

 public   static  Connection initConnection() {
        Connection cn =  null ;
        Locale originalLocale = Locale.getDefault();
        Locale.setDefault(Locale.US);
         try  {
             try  {
                 Class .forName("oracle.jdbc.driver.OracleDriver");
            }  catch  (ClassNotFoundException e) {
                e.printStackTrace();
            }
            cn = DriverManager.getConnection("jdbc:oracle:thin:@os.br.mkl.ru:1521:orcl", "test", "testsh");
        }  catch  (SQLException e) {
        }
        Locale.setDefault(originalLocale);
         return  cn;
}