时间：2020-11-15 13:55:07 | 栏目：JAVA代码 | 点击：次
最近陆续用python写了很多文件处理脚本，虽然功能都比较简单 ，但还是感觉到python对文件处理的简洁高效 ，越发觉得java的语法相当的繁琐~
接到个需求处理ftp数据接口 。所以想把python脚本也用上。java代码定时扫描ftp数据仓库 ，调用python脚本入库。
直接采用java执行系统命令的方式
@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();
}
}
String[] args = new String[size];
args[0] = "python"; args[1] = pythonFile; args[0]表示要执行的是python 脚本 ，args[1] 脚本文件的全路径
该方法调用 AbstractReadFileLine.class 文件路径下的 PythonFileHandle.py 脚本 ，并传入String数组类型的参数（需要处理的文件全路径）
PythonFileHandle脚本接受java传入的文件路径参数（数组），解析并入库
PythonFileHandle.py 代码
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.commit()
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
sys.argv[0] 存储的是py文件自身的路径，故接受参数从sys.argv[1]开始。