JAVA执行SAS程序和存储过程！

Stored Process:

%global prd1;


*ProcessBody;


Data one;


  set sashelp.shoes(where=(product="&prd1"));


run;

-------------------------------------------------------------------------------

import java.sql.*;
import java.util.Properties;

public class TestShareApp {

  String userpass = new String("me");
  String apname = new String("test");
  String server="localhost";
  String port="5010";
  Connection con = null;
  Driver driver = null;
  Properties properties = null;
  public TestShareApp() {
  properties = new Properties();
  properties.put("shareUser", new String(userpass));
  properties.put("sharePassword", new String(userpass));
  properties.put("appname",apname);
  System.out.println("Connecting to server. Server:" +
server.trim() + " port:" + port.trim());
  try {
  driver
=(Driver)Class.forName("com.sas.net.sharenet.ShareNetDriver").newInstance();
  }
  catch (Exception ex) {
  System.out.println(ex.getMessage());
  }
  String url = "jdbc:sharenet://"+server.trim()+":"+port.trim();
  try {
  //con = driver.connect(url,properties);
  con = driver.connect(url, null);

  System.out.println("Connection to server
complete");
  System.out.println("Disconnecting from
server.");
  con.close();
  System.out.println("Disconnection to server
complete");
  }
  catch (SQLException ex) {
  System.out.println(ex.getMessage());
  }
  }
  public static void main(String[] args){
  System.out.println("USAGE: java TestShareApp
share.server port");
  new TestShareApp();
  }

}

JSP :






<%@ taglib uri=" prefix="sas" %>


<%@ taglib uri="ads prefix="sasads" %>






<%@ page import="


java.sql.*,


java.util.*,


com.sas.iom.SAS.*,


com.sas.iom.WorkspaceFactory,


com.sas.rio.*"


%>


<%






  Properties iomServerProperties = new Properties();


  iomServerProperties.put("host","FRET0012");


  iomServerProperties.put("port","8591");


  iomServerProperties.put("userName","sasadm");


  iomServerProperties.put("password","sasadm");


  Properties[] serverList = {iomServerProperties};






  // Connect to the Workspace


  WorkspaceFactory climf = new WorkspaceFactory();


  IWorkspace climWorkspace =
climf.createWorkspaceByServer(iomServerProperties);


  ILanguageService climLang = climWorkspace.LanguageService();






  //Acquire the Stored process service


  IStoredProcessService climSP =climLang.StoredProcessService();






  //Set the repository of the Stored process


  climSP.Repository("file: /progi/config/cfg912/Lev1/SASMain/Samples");






  //Set the program and supply the required Parameters


  climSP.Execute("sample1", " prd1="+request.getParameter("prd1"));
//prd1 - can be the user supplied Parameters!


  //JDBC Connect using MVA


  IDataService climDataService = climWorkspace.DataService();


  java.sql.Connection climconnect = new MVAConnection(climDataService,
new Properties());


  java.sql.Statement statement = climconnect.createStatement();


  java.sql.ResultSet rs = statement.executeQuery("Select * from
work.one");






  // Display the result


%>









 


 


 


 


 


 


 






<% while(rs.next()) {


 %>


 


 


 


 






 






<%


}


%>

Region	Product	Subsidiary	Sales	Returns
<%   String region = rs.getString("Region");   out.println(region);   %>	<%   String Product = rs.getString("Product");   out.println(Product);   %>	<%   String Subsidiary = rs.getString("Subsidiary");   out.println(Subsidiary);   %>	<%   int Sales = rs.getInt("Sales");   out.println(Sales);   %>	<%   int Returns = rs.getInt("Returns");   out.println(Returns);   %>

Result:








Region


Product


Subsidiary


Sales


Returns




Africa


Slipper


Addis Ababa


68641


1771




Africa


Slipper


Algiers


64891


1823




Africa


Slipper


Cairo


13732


1216


Etc...


Etc...


Etc...