import  java.lang.*;
 import  java.util.Hashtable;
 import  java.sql.*;
 import  java.io.*;
 import  org.postgresql.largeobject.*;
 import  org.postgresql.util.*;

/**
 * Загрузчик классов из базы данных
 */

  public   class  sqlClassLoader  extends  ClassLoader {

  Hashtable cache =  new  Hashtable();
  Connection conn;

  /**
   * Обращение к базе данных
   * @param name
   * @return */
     private   byte [] loadClassData(String name) {
     try  {
       byte  result[] =  null ;
      conn.setAutoCommit(false);
      LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();
      PreparedStatement stmt =
 	 conn.prepareStatement("SELECT object_data FROM client_object WHERE object_name = ?");

      stmt.setString( 1 , name);
      System.out.println(stmt);
       try {
      ResultSet rs = stmt.executeQuery();
      System.out.println("2");
      System.out.println(rs);
       if  (rs.next()){
         int  oid =  0 ;        
        oid = rs.getInt( 1 );
        System.out.println(oid);
        LargeObject obj = lobj.open(oid, LargeObjectManager.READ);       
        result =  new   byte [obj.size()];
        obj.read(result,  0 , obj.size());        
        System.out.println(obj.size());
        obj.close();
        
      }   
      rs.close();
      } catch  (PSQLException e){
         return   null ;
      }
      stmt.close();

       return  result;
    }  catch  (SQLException e) {
      e.printStackTrace();
   }
 return   null ;
}

  /**
   * Получить класс из базы данных
   * @param name
   * @return * @throws ClassNotFoundException
   */
   public   synchronized   Class  loadClass(String name)  throws  ClassNotFoundException {
     // Получить класс из кэша
      Class  c;
     c = ( Class ) cache.get(name);
	 if  (c !=  null )  return  c;
    // В кэше класс не обнаружен -
    // ищем класс в базе данных
    //   System.out.println("1");
        byte [] data = loadClassData(name);
       
     if  (data ==  null ) {
       // Класс в базе данных не обнаружен -
       // выбрасываем исключение
       c = getParent().loadClass( name );
       cache.put(name, c);   
        return  c;
     }  else  {
      // Класс обнаружен
      
      c = defineClass(name, data,  0 , data.length);
      System.out.println(data);
      cache.put(name, c);
       return  c;
    }
  }

   public   void  setConnection(Connection conpr){
    conn = conpr;
  }
}

 import  java.sql.*;
 import  java.io.*;

 public   class  Welcome
{ 

   public   static   void  Wellcome_run(java.sql.Connection conn)
  {
    String result =  null ;  
    ResultSet rs =  null ;
  
     try {
      
      PreparedStatement stmt =
 	 conn.prepareStatement("select * from official_position");

      System.out.println(stmt);
     
      try {   
        rs = stmt.executeQuery();
     } catch  (SQLException e){
       e.printStackTrace();
     } 
         while  (rs.next()) {
           for  ( int  i= 1 ; i <= 1 ; i++){
            result = rs.getString(i);        
            System.out.println(rs.getString( 1 ) + "|"+rs.getString( 2 ));
          }

 }
     
       
      

      } catch  (SQLException e) {
        System.out.println(e);
   }
   }
}

 import  java.io.*;
 import  java.sql.*;

/**
 *
 * @author yr
 */
 public   class  Main {
    
    /** Creates a new instance of Main */
    
    /**
     * @param args the command line arguments
     */
     public   static   void  main(String[] args) {
        // TODO code application logic here
       try {
       Class .forName("org.postgresql.Driver");
      } catch  (ClassNotFoundException e) {
      e.printStackTrace();
    }
     Welcome wel =  null ; 
     try {
      Connection conn =  DriverManager.getConnection(
      "jdbc:postgresql://127.0.0.1:5432/db",
       "user", "pass");
      System.out.println(conn);
   
     try {
     sqlClassLoader sql =  new  sqlClassLoader();
     sql.setConnection(conn);
     // Загружаем класс
      Class  a =  null ;
     a = sql.loadClass("Welcome");
     Object we = a.newInstance(); 
     wel = (Welcome)we;
        
    
     
   } catch (ClassNotFoundException e){
      e.printStackTrace();
     }
   } catch  (SQLException e) {
        e.printStackTrace();
    } catch  (InstantiationException e) {
        e.printStackTrace();
    }
      catch  (ClassCastException e) {
        e.printStackTrace();
    } catch  (IllegalAccessException e) {
        e.printStackTrace();
    } 
    }
}

 import  java.io.*;
 import  java.lang.reflect.Method;
 import  java.sql.*;

/**
 *
 * @author yr
 */
 public   class  Main {
    
    /** Creates a new instance of Main */
     public  Main() {
    }
    
    /**
     * @param args the command line arguments
     */
     public   static   void  main(String[] args) {
        // TODO code application logic here
          try {
       Class .forName("org.postgresql.Driver");
      } catch  (ClassNotFoundException e) {
      e.printStackTrace();
    }
     Runnable wel =  null ; 
     try {
      Connection conn =  DriverManager.getConnection(
      "jdbc:postgresql://127.0.0.1:5432/base",
       "user", "pass");
  
   
  
     sqlClassLoader sql = (sqlClassLoader)ClassLoader.getSystemClassLoader();
  
     sql.setConnection(conn);
       // Загружаем класс
      Object we = sql.retObject("Welcome");
    
     
     Welcome w =  new  Welcome();
     
    
    w = (Welcome) we;
    
    } catch  (SQLException e) {
        e.printStackTrace();
         
    }
 
}

 import  java.lang.*;
 import  java.util.Hashtable;
 import  java.sql.*;
 import  java.io.*;
 import  org.postgresql.largeobject.*;
 import  org.postgresql.util.*;
 import  java.net.*;
 import  java.security.*;

/**
 * Загрузчик классов из базы данных
 */

  public   class  sqlClassLoader  extends  URLClassLoader {
   static  Connection conn =  null ;
  
  Hashtable cache =  new  Hashtable();
   private  ClassLoader parent =  null ;
  
 
  public  sqlClassLoader(ClassLoader parent){  
     super ( new  URL[ 0 ], parent);
     this .parent = parent;
  }
 
  /**
   * Обращение к базе данных
   * @param name
   * @return */
     private   byte [] loadClassData(String name) {
     if  (conn ==  null )
         return   null ;
     try  {
       byte  result[] =  null ;
      conn.setAutoCommit(false);
      LargeObjectManager lobj = ((org.postgresql.PGConnection)conn).getLargeObjectAPI();
      PreparedStatement stmt =
 	 conn.prepareStatement("SELECT object_data FROM client_object WHERE object_name = ?");

      stmt.setString( 1 , name);
    
       try {
      ResultSet rs = stmt.executeQuery();
       if  (rs.next()){
         int  oid =  0 ;        
        oid = rs.getInt( 1 );
        LargeObject obj = lobj.open(oid, LargeObjectManager.READ);       
        result =  new   byte [obj.size()];
        obj.read(result,  0 , obj.size());        
        obj.close();
        
      }   
      rs.close();
      } catch  (PSQLException e){
         return   null ;
      }
      stmt.close();
       return  result;
    }  catch  (SQLException e) {
      e.printStackTrace();
   }
   return   null ;

}

  /**
   * Получить класс из базы данных
   * @param name
   * @return * @throws ClassNotFoundException
   */
   public   Class  loadClass(String name)  throws  ClassNotFoundException  {
      
       return   this .findClass(name);
    
  }
   public   synchronized   Class  findClass(String name)  throws  ClassNotFoundException {
     // Получить класс из кэша
     
      Class  c;
     c = ( Class ) cache.get(name);
	 if  (c !=  null )  return  c;
    // В кэше класс не обнаружен -
    // ищем класс в базе данных
    
        byte [] data = loadClassData(name);
       
     if  (data ==  null ) {
       // Класс в базе данных не обнаружен -
      
       c =  super .loadClass(name);     
       cache.put(name, c);
        return  c;      
     }  else  {
      // Класс обнаружен
     
      c = defineClass(name, data,  0 , data.length);     
      cache.put(name, c);
       return  c;
    }
  }

   public   void  setConnection(Connection conpr){
    conn = conpr;
  }
   public  Object retObject(String name){
    try {
    Object a = loadClass(name).newInstance(); 
     return  a;
   } catch (ClassNotFoundException e){
        return   null ;
   } catch (InstantiationException e){
       return   null ;
   } catch (IllegalAccessException e){
      return   null ;
   }
  
 } 

 }

 import  java.sql.*;
 import  java.io.*;

 public   class  Welcome
{ 
  
  /**
   * 
   * @param conn 
   */
   public   static   void  Wellcome_run(Connection conn)
  {
    String result =  null ;  
    String cp1 =  new  String("_Cp1251_");
    ResultSet rs =  null ;
  
     try {
      
      PreparedStatement stmt =
 	 conn.prepareStatement("select * from official_position");     
      try {   
        rs = stmt.executeQuery();
     } catch  (SQLException e){
       e.printStackTrace();
     } 
         while  (rs.next()) {
           for  ( int  i= 1 ; i <= 1 ; i++){
            result = rs.getString(i);       
           System.out.print(rs.getString( 1 ) + "|"+rs.getString( 2 ));
          }
 }
     
      } catch  (SQLException e) {
        System.out.println(e);
   }
   }
}