java 直接调用python脚本，并传递参数代码实例

@async

     public void readfilebypython(list<string> filepaths) throws filenotfoundexception {

         url localsrcurl = abstractreadfileline. class .getresource( "" );

         string localsrcpath = localsrcurl.getpath();

         localsrcpath = localsrcpath.substring( 1 , localsrcpath.length());

         string pythonfile = localsrcpath + "pythonfilehandle.py" ;

         int size = filepaths.size() + 2 ;

         string[] args = new string[size];

         args[ 0 ] = "python" ;

         args[ 1 ] = pythonfile;

         for ( int i = 0 ;i<filepaths.size() ;i++){

             int index = i+ 2 ;

             args[index] = filepaths.get(i);

         }

         try {

           system.out.println( "start" );

           process proc = runtime.getruntime().exec(args);

           inputstream is = proc.geterrorstream();

           inputstreamreader isr = new inputstreamreader(is);

           bufferedreader br = new bufferedreader(isr);

           string line = null ;

           system.out.println( "<error>" );

           while ((line = br.readline())!= null ){

               system.out.println(line);

               system.out.println( "</error>" );

               int exitvalue = proc.waitfor();

               system.out.println( "process exitvalue=" +exitvalue);

           }

           system.out.println( "end" );

           } catch (exception e){

           e.printstacktrace();

           }

     }

import pymssql,time,sys

reload(sys)

sys.setdefaultencoding( "utf-8" )

class mssql:

   def __init__(self,host,user,pwd,db):

     self.host = host

     self.user = user

     self.pwd = pwd

     self.db = db

   def __getconnect(self):

     if not self.db:

       raise(nameerror, "" )

     self.conn = pymssql.connect(host=self.host,user=self.user,password=self.pwd,database=self.db,charset= "utf8" )

     cur = self.conn.cursor()

     if not cur:

       raise(nameerror, "" )

     else :

       return cur

   def execquery(self,sql):

     cur = self.__getconnect()

     cur.execute(sql)

     reslist = cur.fetchall()

     #

     self.conn.close()

     return reslist

   def execnonquery(self,sql):

     cur = self.__getconnect()

     cur.execute(sql)

     self.conn测试数据mit()

     self.conn.close()

def inserttocloselist(data ,ms):

   sql = "insert into t_isee_closelist_infos (work_order_id,crm_cdsc_id,appraise_type,crm_accept_date,latn_code,theme_row_id,task_execute_row_id,crm_accept_reason,asset_integ_id) values ( '"

   temp = "' , '"

   sqlstr = temp.join(data)

   sql = sql + sqlstr + "')"

   ms.execnonquery(sql)

ms = mssql(host= "172.30.0.186" ,user= "sa" ,pwd= "" ,db= "test" )

fengefu = '$%$'

for i in range( 1 , len(sys.argv)):

   read = open(sys.argv[i] , 'r' )

   for line in read:

     line=line.strip( '\n' )

     data = line.split(fengefu)

     inserttocloselist(data,ms)

   read.close