Java访问SAS Metadata和SAS数据的方法

shiyiming

[code:04f15]import java.util.*;
import java.sql.*;

public class DataModel {

        private String SASUsername = "username";

        private String SASPassword = "password";

        public Vector getLibraries() {
                Vector libraries = new Vector();
                try {
                        Class.forName("com.sas.rio.MVADriver");
                        Connection conn = DriverManager.getConnection(
                                        "jdbc:sasiom://localhost:8591", SASUsername, SASPassword);
                        Statement stmt = conn.createStatement();
                        DatabaseMetaData meta = conn.getMetaData();
                        ResultSet rs = meta.getSchemas();
                        while (rs.next()) {
                                String library = rs.getString(1);
                                libraries.add(library);
                        }
                        rs.close();
                        stmt.close();
                        conn.close();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return libraries;
        }

        public Vector getTables(String library) {
                Vector tables = new Vector();
                try {
                        Class.forName("com.sas.rio.MVADriver");
                        Connection conn = DriverManager.getConnection(
                                        "jdbc:sasiom://localhost:8591", SASUsername, SASPassword);
                        Statement stmt = conn.createStatement();
                        DatabaseMetaData meta = conn.getMetaData();
                        ResultSet rs = meta.getTables(null, library, null,
                                        new String[] { "TABLE" });
                        while (rs.next()) {
                                String table = rs.getString(3);
                                tables.add(table);
                        }
                        rs.close();
                        stmt.close();
                        conn.close();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return tables;
        }

        public Vector getColumns(String library, String table) {
                Vector columns = new Vector();
                try {
                        Class.forName("com.sas.rio.MVADriver");
                        Connection conn = DriverManager.getConnection(
                                        "jdbc:sasiom://localhost:8591", SASUsername, SASPassword);
                        Statement stmt = conn.createStatement();
                        DatabaseMetaData meta = conn.getMetaData();
                        ResultSet rs = meta.getColumns(null, library, table, null);
                        while (rs.next()) {
                                String column = rs.getString(4);
                                columns.add(column);
                        }
                        rs.close();
                        stmt.close();
                        conn.close();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return columns;
        }

        public Vector getRows(String library, String table) {
                Vector columns = new Vector();
                try {
                        Class.forName("com.sas.rio.MVADriver");
                        Connection conn = DriverManager.getConnection(
                                        "jdbc:sasiom://localhost:8591", SASUsername, SASPassword);
                        Statement stmt = conn.createStatement();
                        DatabaseMetaData meta = conn.getMetaData();
                        ResultSet rs = meta.getColumns(null, library, table, null);
                        while (rs.next()) {
                                String column = rs.getString(4);
                                columns.add(column);
                        }
                        rs.close();
                        stmt.close();
                        conn.close();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return columns;
        }

        public static void main(String[] args) {
        }

}[/code:04f15]

shiyiming

我引用一个更好sample，既可以得到JDBC的connection，又可以得到一个Workspace，两全其美。

[code:5ef24]import java.util.Properties;
import com.sas.iom.SAS.IWorkspace;
import com.sas.iom.SAS.IWorkspaceHelper;
import com.sas.iom.SAS.*;
import com.sas.iom.*;
import com.sas.rio.MVAConnection;

public class CreditServiceImpl implements CreditServiceIF, java.rmi.Remote {
   public double getCreditLimit(java.lang.String custName, java.lang.String custID)
      throws java.rmi.RemoteException {

      /* Here's the place to put some validation code */
      double _retVal = 0;

      /* Define a connection to a SAS IOM server via a iWorkspace object */
      try {
         WorkspaceFactory wsf = new WorkspaceFactory();
         Properties serverInfo = new Properties();
         serverInfo.put("host", "localhost");
         serverInfo.put("port", "5307");
         serverInfo.put("userName", "username");
         serverInfo.put("password", "password");
         IWorkspace iWorkspace = wsf.createWorkspaceByServer(serverInfo);

         /* Use the StoredProcessService to execute the SAS code */
         ILanguageService iLang = iWorkspace.LanguageService();
         IStoredProcessService iSP = iLang.StoredProcessService();
         iSP.Repository("file:c:\\SASRepository");
         iSP.Execute("GetCreditLimit", "custname" + "=" + custName
                    + " custid=" + custID + " outData=work.out");
         
         /* Print out SAS log for debugging.
            Output is in /logs/catalina.out. */
         String log = iLang.FlushLog(50000);
         System.out.println(log);
                                        
         /* Read the result via an MVAConnection */
         IDataService iDataService = iWorkspace.DataService();

         java.sql.Connection connection = new MVAConnection(iDataService,
                                                    new Properties());
         java.sql.Statement statement = connection.createStatement();
         java.sql.ResultSet rs = statement.executeQuery(
                                "Select * from work.out");

         /* Get the credit limit and return it to the calling client */
         if( rs.next() )
         {
            String creditLimit = rs.getString("creditLimit");
            _retVal = Double.parseDouble(creditLimit);
         }
      }
      catch( Throwable t ) {
         t.printStackTrace();
         java.rmi.RemoteException ex =
            new java.rmi.RemoteException("Error getting credit limit", t);
         throw ex;
      }
      finally {
         try{
            /* Close JDBC connection if open */
            if(connection != null)
            {
               if(!connection.isClosed())
                  connection.close();
            }

            /* Close iWorkspace */
            if(iWorkspace != null)
               iWorkspace.Close();

            /* Shutdown WorkspaceFactory */
            if(wsf != null)
               wsf.shutdown();
         } catch(Throwable t) {
            //t.printStackTrace();
         }
      }
      return _retVal;
   }
}[/code:5ef24]

shiyiming

这么好的贴，我来顶！