ITPub博客
首页 博客 专栏 学院 社区 IT新媒体评选
发博

首页 > 数据库 > Oracle > 用sqlldr批量导文本数据到oracle的一些经验

用sqlldr批量导文本数据到oracle的一些经验

原创 Oracle 作者：jvche12 时间：2017-05-08 11:34:35 1 删除 编辑

最近工作将3T左右的数据导入oracle，按月分类了文件夹，每个文件夹有当月每天的文本文件，每月大概300G。

第一步：分析原始数据文件的格式，创建表，由于数据量大，按每天进行分区，即使这样，每个分区也有10G左右的大小，oracle建议单个表不超过2G，查询应该会较慢
，另原始文件的第一列不需要
create table T_GPSDATA_WEIXINGDINGWEI
(
  bus_id          VARCHAR2(96) not null,
  line_id         VARCHAR2(96) not null,
  child_line_id   VARCHAR2(96) not null,
  orgz_id         NUMBER,
  lct_status      NUMBER,
  lng             NUMBER(15,6),
  lat             NUMBER(15,6),
  lct_altitude    NUMBER(15,6),
  lct_time        DATE,
  lct_speed       NUMBER(15,2),
  lct_direction   NUMBER(38,2),
  edr_speed       NUMBER(15,2),
  edr_miles       NUMBER(15,2)
PARTITION BY RANGE (LCT_TIME) 
INTERVAL(NUMTODSINTERVAL(1,'DAY'))
STORE IN (GPSDATA_WEIXINGDINGWEI) 
(
  PARTITION LCT_TIME_PART01 VALUES LESS THAN (TO_DATE('2015-05-01','yyyy-mm-dd')) TABLESPACE GPSDATA_WEIXINGDINGWEI
);

第二步：创建控制文件的初步模型，导入过程发现了一些问题，需要调整控制文件
load data
characterset AL32UTF8
infile 'E:\gpsdata\201506\weixingdingwei\卫星定位信息2015060205'
append into table T_GPSDATA_WEIXINGDINGWEI
fields terminated by ','
( terminated,
  bus_id,
  line_id,
  child_line_id,
  orgz_id,
  lct_status,
  lng,
  lat,
  lct_altitude,
  lct_time "to_date(:lct_time,'''yyyy-mm-dd hh24:mi:ss''')",
  lct_speed,
  lct_direction,
  edr_speed,
  edr_miles
)
第三步：实验发现几个问题
    第一：文本类型不是txt格式，这个容易，直接写个bat将所有文件类型转换成txt格式
    第二：打开文本文件发现是UTF-16LE格式，这个亲身试验，导入报错，手动改成utf-8格式，就可以导入，在网上找了个文本格式转换的java源代码，具体参考博文后面的BatchConvertFileEncode.java
    第三：lct_time, bus_id, line_id, child_line_id的有些记录为空（2个双引号括起来，中间没有任何内容），并且原始数据文件每个字段都用双引号括起来了，控制文件修改如下：
    第四：每个文件夹有几百个文件，我不可能手动输入infile的每个具体的文件位置及名称，还有每个文件的名称都包含中文，也会报错，用java解决，因此自己写了个代码，具体 参考博文后面的zip3.java
options(errors=999999999)                     //允许的错误数，根据需要修改
load data
characterset AL32UTF8
infile 'E:\gpsdata\201506\weixingdingwei\ 卫星定位信息2015060205 '
append into table T_GPSDATA_WEIXINGDINGWEI
fields terminated by ','                            //表示每个字段由逗号分隔
OPTIONALLY ENCLOSED BY  '"'               //表示字段由双引号括起来
( terminated filler,                                //加上filler表示不导入该列
  bus_id "nullif(:bus_id,'')",                   //nullif对该字段做判断，如果为''（中间没有字符），则插入null显示在oracle就是空
  line_id "nullif(:line_id,'')",
  child_line_id "nullif(:child_line_id ,'')",
  orgz_id,
  lct_status,
  lng,
  lat,
  lct_altitude,
  lct_time "to_date(nullif(:lct_time,''),'''yyyy-mm-dd hh24:mi:ss''')",
  lct_speed,
  lct_direction,
  edr_speed,
  edr_miles
)
最终通过java代码生成如下的控制文件，（zip3.java生成的不完全是，主要是表的字段不一样，这个手动好改）：

点击( 此处)折叠或打开

  1. options (errors=999999999 )
  2. load data
  3. characterset AL32UTF8
  4. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060114.txt'
  5. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060115.txt'
  6. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060116.txt'
  7. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060117.txt'
  8. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060118.txt'
  9. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060119.txt'
  10. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060120.txt'
  11. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060121.txt'
  12. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060122.txt'
  13. infile 'E:\gpsdata\201506\weixingdingwei2\weixingdingwei2015060123.txt'

  1. append into table T_GPSDATA_WEIXINGDINGWEI
  2. fields terminated by ','
  3. OPTIONALLY ENCLOSED BY '"'
  4. ( terminated filler ,
  5.   bus_id "nullif(:bus_id,'')" ,
  6.   line_id "nullif(:line_id,'')" ,
  7.   child_line_id "nullif(:child_line_id ,'')" ,
  8.   orgz_id ,
  9.   lct_status ,
  10.   lng ,
  11.   lat ,
  12.   lct_altitude ,
  13.   lct_time "to_date(nullif(:lct_time,'null'),'''yyyy-mm-dd hh24:mi:ss''')" ,
  14.   lct_speed ,
  15.   lct_direction ,
  16.   edr_speed ,
  17.   edr_miles
  18. )




第四步：在处理好的文件夹下，输入cmd，输入：sqlldr userid=gpsdata/gpsdata@its0 control=000input.ctl rows=100160 readsize=20971520 bindsize=20971520 PARALLEL=TRUE
这里用的是并行的（ PARALLEL=TRUE）方式导入，速度较快，具体可参考sqlldr性能优化
http://blog.csdn.net/kangkangwanwan/article/details/51869994
另外详细的sqlldr参数可参考
https://wenku.baidu.com/view/63737c19cc7931b765ce1517.html



------附上2个java代码

BatchConvertFileEncode.java的内容，只需修改路径，文件转换前后的格式，文件类型即可

点击( 此处)折叠或打开

  1. package test ;

  3. import java . io . File ;
  4. import java . io . FileFilter ;
  5. import java . io . FileInputStream ;
  6. import java . io . FileOutputStream ;
  7. import java . io . IOException ;
  8. import java . io . InputStreamReader ;
  9. import java . io . OutputStreamWriter ;
  10. import java . util . ArrayList ;
  11. import java . util . List ;

  13. /**
  14.  * 批量转换文件编码
  15.  *
  16.  * @date 2014-10-23
  17.  *
  18.  * @author xsoftlab.net
  19.  */
  20. public class BatchConvertFileEncode {
  21.      /**
  22.      * 获取文件或文件夹 不存在则创建
  23.      *
  24.      * @param path
  25.      *            文件或文件夹路径
  26.      * @return 已有/新创建的文件
  27.      * @throws IOException
  28.      *             可能产生的异常
  29.      */
  30.      public static File getFile ( String path ) throws IOException {
  31.          File file = new File (path ) ;
  32.          if ( file . isDirectory ( ) ) {
  33.              if ( ! file . exists ( ) )
  34.                  file . mkdirs ( ) ;
  35.          } else {
  36.              // 判断目标文件所在的目录是否存在
  37.              if ( ! file . getParentFile ( ) . exists ( ) )
  38.                  file . getParentFile ( ) . mkdirs ( ) ;
  39.              if ( ! file . exists ( ) )
  40.                  file . createNewFile ( ) ;
  41.          }
  42.          return file ;
  43.      }

  45.      /**
  46.      * 递归查找指定后缀名的文件
  47.      *
  48.      * @param folder
  49.      *            目标文件夹
  50.      * @param suffix
  51.      *            目标后缀名
  52.      * @return 找到的文件集合
  53.      */
  54.      public static List < File > searchFile ( File folder , final String suffix ) {
  55.          List < File > result = new ArrayList < File > ( ) ;
  56.          File [ ] subFolders = folder . listFiles ( new FileFilter ( ) { // 运用内部匿名类获得文件
  57.                     @ Override
  58.                      public boolean accept ( File pathname ) { // 实现FileFilter类的accept方法
  59.                          if (pathname . isDirectory ( )
  60.                                  | | (pathname . isFile ( ) & & pathname . getName ( )
  61.                                          . toLowerCase ( )
  62.                                          . endsWith (suffix . toLowerCase ( ) ) ) ) // 根据文件后缀名过滤
  63.                              return true ;
  64.                          return false ;
  65.                      }
  66.                  } ) ;
  67.          if (subFolders ! = null ) {
  68.              for ( File file : subFolders ) {
  69.                  if ( file . isFile ( ) ) {
  70.                      // 如果是文件则将文件添加到结果列表中
  71.                      result . add ( file ) ;
  72.                  } else {
  73.                      // 如果是文件夹，则递归调用本方法，然后把所有的文件加到结果列表中
  74.                      result . addAll (searchFile ( file , suffix ) ) ;
  75.                  }
  76.              }
  77.          }
  78.          return result ;
  79.      }

  81.      /**
  82.      * 单个文件转换编码
  83.      *
  84.      * @param file
  85.      *            要转换的文件
  86.      * @param tarFile
  87.      *            转换后的文件
  88.      * @param charset
  89.      *            转换前的编码
  90.      * @param tarCharset
  91.      *            转换后的编码
  92.      * @throws IOException
  93.      *             可能出现的异常
  94.      */
  95.      public static void convertFileEncode ( File file , File tarFile ,
  96.              String charset , String tarCharset ) throws IOException {
  97.          InputStreamReader reader = null ;
  98.          OutputStreamWriter writer = null ;
  99.          int length ;
  100.          char [ ] b = new char [3 * 1024 ] ;
  101.          try {
  102.              // 打开文件输出流
  103.              reader = new InputStreamReader ( new FileInputStream ( file ) , charset ) ;
  104.              writer = new OutputStreamWriter ( new FileOutputStream (tarFile ) ,
  105.                     tarCharset ) ;
  106.              while ( ( length = reader . read (b ) ) ! = -1 ) {
  107.                  writer . write (b , 0 , length ) ;
  108.                  writer . flush ( ) ;
  109.              }
  110.          } finally {
  111.              // 关闭文件流
  112.              if ( reader ! = null )
  113.                  reader . close ( ) ;
  114.              if ( writer ! = null )
  115.                  writer . close ( ) ;
  116.          }
  117.      }

  119.      /**
  120.      * 根据文件夹批量转换编码
  121.      *
  122.      * @param folder
  123.      *            要转换的文件夹
  124.      * @param tarFolder
  125.      *            输出文件夹
  126.      * @param charset
  127.      *            转换前的编码
  128.      * @param tarCharset
  129.      *            转换后的编码
  130.      * @param suffix
  131.      *            要转换的文件后缀名
  132.      * @throws IOException
  133.      *             可能出现的异常
  134.      */
  135.      public static void convertFileEncodeByFolder ( String folder ,
  136.              String tarFolder , String charset , String tarCharset , String suffix )
  137.              throws IOException {
  138.          String relTar = null ;
  139.          List < File > result = searchFile ( new File (folder ) , suffix ) ; // 调用方法获得文件数组
  140.          System .out . println ( "找到 " + result . size ( ) + " 个需要转换的文件" ) ;
  141.          // 文件尾部处理
  142.          if ( !folder . endsWith ( "/" ) & & !folder . endsWith ( "\\" ) )
  143.             folder + = File .separator ;
  144.          if ( !tarFolder . endsWith ( "/" ) & & !tarFolder . endsWith ( "\\" ) )
  145.             tarFolder + = File .separator ;
  146.          for ( File file : result ) {
  147.              // 使目标文件夹目录层次与源文件夹对应
  148.             relTar = tarFolder
  149.                      + file . getAbsolutePath ( ) . replace (folder . replace ( "/" , "\\" ) ,
  150.                              "" ) ;
  151.             convertFileEncode ( file , getFile (relTar ) , charset , tarCharset ) ;
  152.          }
  153.          System .out . println ( "转换成功!" ) ;
  154.      }

  156.      public static void main ( String [ ] args ) {
  157.          try {
  158.             convertFileEncodeByFolder ( "E:\\gpsdata\\201506\\weixingdingwei" ,
  159.                      "E:\\gpsdata\\201506\\weixingdingwei2" , "UTF-16LE" ,
  160.                      "UTF-8" , "txt" ) ;
  161.          } catch ( IOException e ) {
  162.             e . printStackTrace ( ) ;
  163.          }
  164.      }
  165. }


zip3.java，其中 zipPath是文件夹目录， ctlfile是控制文件名称， oldstr， newstr意思是需要将文件名称内容为 oldstr替换为newstr，
里面有些函数，比如重命名文件，比如自动创建控制文件（主要是为了不手动输入每个文件的位置名称）等，根据需要运行，注释不需要的功能即可

点击( 此处)折叠或打开

  1. package test ;

  3. import java . io . BufferedInputStream ;
  4. import java . io . BufferedOutputStream ;
  5. import java . io . BufferedWriter ;
  6. import java . io . File ;
  7. import java . io . FileInputStream ;
  8. import java . io . FileNotFoundException ;
  9. import java . io . FileOutputStream ;
  10. import java . io . FileWriter ;
  11. import java . io . FilenameFilter ;
  12. import java . io . IOException ;
  13. import java . util . ArrayList ;
  14. import java . util . zip . ZipEntry ;
  15. import java . util . zip . ZipInputStream ;

  17. public class zip3 {

  19.      public static void main ( String [ ] args ) throws IOException {
  20. //        File dir = new File("F:\\ICDATA\\ic卡数据txt版\\201511\\20151108");
  21. //        String strcmd = "cmd /c start F:\\ICDATA\\ic卡数据txt版\\201511\\20151108\\000.bat";  //调用我们在项目目录下准备好的bat文件，如果不是在项目目录下，则把“你的文件名.bat”改成文件所在路径。
  22. //        run_cmd(strcmd,dir);  //调用上面的run_cmd方法执行操作
  23.         
  24.          String zipPath = "E:\\gpsdata\\201506\\weixingdingwei" ;
  25.          String ctlfile = "000input.ctl" ;
  26.          String oldstr = "卫星定位信息" ;
  27.          String newstr = "weixingdingwei" ;
  28.          ArrayList < String > filelist = getFiles ( new ArrayList < String > ( ) ,zipPath ) ;
  29.         
  30.          for ( String str :filelist ) {
  31.              System .out . println (str ) ;
  32.             
  33.              /*批量重命名文件*/
  34.              renameFile (str ,oldstr ,newstr ) ;
  35.             
  36.              /*自动创建控制文件*/
  37. //            createCtlFile(ctlfile,str);
  38.             
  39.              /*自动拷贝bat文件*/
  40. //            copyFile("F:\\ICDATA\\icdatatxt\\000自动导入.bat",str+"\\000自动导入.bat");
  41.             
  42.              /*自动执行bat文件*/
  43. //            File dir = new File(str);
  44. //            String strcmd = "cmd /c start "+str+"\\000.bat";  //调用我们在项目目录下准备好的bat文件，如果不是在项目目录下，则把“你的文件名.bat”改成文件所在路径。
  45. //            run_cmd(strcmd,dir);  //调用上面的run_cmd方法执行操作
  46. //            try {
  47. //                Thread.sleep(60000);
  48. //            } catch (InterruptedException e1) {
  49. //                e1.printStackTrace();
  50. //            }
  51.             
  52.              /*自动执行数据导入*/
  53. //            File dir = new File(str);
  54. //            String strcmd = "cmd /c start "+str+"\\000自动导入.bat";  //调用我们在项目目录下准备好的bat文件，如果不是在项目目录下，则把“你的文件名.bat”改成文件所在路径。
  55. //            run_cmd(strcmd,dir);  //调用上面的run_cmd方法执行操作
  56. //            try {
  57. //                Thread.sleep(60000);
  58. //                break;
  59. //            } catch (InterruptedException e1) {
  60. //                e1.printStackTrace();
  61. //            }            
  62.             
  63.              /*自动删除000.txt文件*/
  64. //            File f = new File(str+"\\000.txt");  // 输入要删除的文件位置
  65. //            if(f.exists())
  66. //                f.delete();
  67. //            else
  68. //                System.out.println("未找到文件");
  69.                         
  70.          }
  71.         
  72.         
  73.      }
  74.     

  76.      static void renameFile ( String path , String oldstr , String newstr )
  77.      {
  78.          File filename = new File (path ) ;
  79.          File [ ] filelist = filename . listFiles ( ) ;
  80.          for ( File file :filelist ) {
  81.              String oldname = file . getName ( ) ;
  82.              //System.out.println(oldname);
  83.              if (oldname . indexOf ( ".txt" ) ! = -1 ) {
  84.                  if (oldname . indexOf (oldstr ) ! = -1 ) {
  85.                      String newname = oldname . replace (oldstr , newstr ) ;
  86.                      System .out . println (newname ) ;
  87.                      file . renameTo ( new File (path + '\\' +newname ) ) ;
  88.                  }
  89.              } else {
  90.                  System .out . println ( "不是txt类型文件" ) ;
  91.              }
  92.          }
  93.      }

  95.      /*创建一个指内容的ctl文件*/
  96.      static void createCtlFile ( String ctlfile , String filePath ) throws IOException {
  97.          String data1 = "load data\r\n" ;
  98.          String data2 = "characterset AL32UTF8\r\n" ;
  99.          String data3 = "infile '" ;
  100.          String data4 = "\\" ;
  101.          String data5 = "'" ;
  102.          String data6 = "\r\n" ;
  103.          String datamonth = "append into table T_GPSDATA_INSTATION\r\n" ;
  104.          String datatable = "fields terminated by ','\r\n" +
  105. "( terminated filler,\r\n" +
  106. "  bus_id,\r\n" +
  107. "  line_id,\r\n" +
  108. "  child_line_id,\r\n" +
  109. "  orgz_id,\r\n" +
  110. "  lct_status,\r\n" +
  111. "  lng,\r\n" +
  112. "  lat,\r\n" +
  113. "  lct_altitude,\r\n" +
  114. "  lct_time " + "\"" + "to_date(:lct_time,'''yyyy-mm-dd hh24:mi:ss''')" + "\",\r\n" +
  115. "  lct_speed,\r\n" +
  116. "  lct_direction,\r\n" +
  117. "  edr_speed,\r\n" +
  118. "  edr_miles,\r\n" +
  119. "  time_in " + "\"" + "to_date(:time_in,'''yyyy-mm-dd hh24:mi:ss''')" + "\",\r\n" +
  120. "  next_stop_id\r\n" +
  121. ")" ;
  122.          String filenameTemp = filePath + "\\" +ctlfile ; //文件路径+文件名称
  123.          System .out . println (filenameTemp ) ;
  124.          File filename = new File (filePath ) ;
  125.          File [ ] strarr = filename . listFiles ( ) ;
  126.          File file = new File (filenameTemp ) ;
  127.          if ( ! file . exists ( ) ) {
  128.              try {
  129.                  file . createNewFile ( ) ;
  130.              } catch ( IOException e ) {
  131.                  // TODO Auto-generated catch block
  132.                 e . printStackTrace ( ) ;
  133.              }
  134.          }

  136.          byte [ ] byteindata1 = data1 . getBytes ( ) ;
  137.          byte [ ] byteindata2 = data2 . getBytes ( ) ;
  138.          try {
  139.              FileOutputStream output = new FileOutputStream (filenameTemp ) ;
  140.              try {
  141.                  output . write (byteindata1 ) ;
  142.                  output . write (byteindata2 ) ;
  143.                  byte [ ] byteinfilepath = filePath . getBytes ( ) ;
  144.                  byte [ ] byteindata3 = data3 . getBytes ( ) ;
  145.                  byte [ ] byteindata4 = data4 . getBytes ( ) ;
  146.                  byte [ ] byteindata5 = data5 . getBytes ( ) ;
  147.                  byte [ ] byteindata6 = data6 . getBytes ( ) ;
  148.                  byte [ ] byteindatamonth = datamonth . getBytes ( ) ;
  149.                  byte [ ] byteindatatable = datatable . getBytes ( ) ;
  150.                  for ( int i = 0 ; i < strarr . length ; i + + ) {
  151.                      //System.out.println(strarr[i].getName());
  152.                      if (strarr [i ] . getName ( ) . equals ( "000input.ctl" ) ) {
  153.                          continue ;
  154.                      }
  155.                      byte [ ] byteinstrname = strarr [i ] . getName ( ) . getBytes ( ) ;
  156.                      output . write (byteindata3 ) ;
  157.                      output . write (byteinfilepath ) ;
  158.                      output . write (byteindata4 ) ;
  159.                      output . write (byteinstrname ) ;
  160.                      output . write (byteindata5 ) ;
  161.                      output . write (byteindata6 ) ;
  162.                  }
  163.                  output . write (byteindatamonth ) ;
  164.                  output . write (byteindatatable ) ;
  165.                  output . flush ( ) ;
  166.                  output . close ( ) ;
  167.              } catch ( IOException e ) {
  168.                  // TODO Auto-generated catch block
  169.                 e . printStackTrace ( ) ;
  170.              }
  171.          } catch ( FileNotFoundException e ) {
  172.              // TODO Auto-generated catch block
  173.             e . printStackTrace ( ) ;
  174.          }
  175.      }

  177.      /*复制文件到指定目录下*/
  178.      static void copyFile ( String path , String copyPath ) {
  179.          try {
  180.              //path: "f://downloads//kon.jpg"
  181.              FileInputStream input = new FileInputStream (path ) ; //可替换为任何路径何和文件名
  182.              //copyPath: "f://kon.jpg"
  183.              FileOutputStream output = new FileOutputStream (copyPath ) ; //可替换为任何路径何和文件名
  184.              int in =input . read ( ) ;
  185.              while (in!=-1 ) {
  186.              output . write ( in ) ;
  187.              in =input . read ( ) ;
  188.              }
  189.              } catch ( IOException e ) {
  190.              System .out . println (e . toString ( ) ) ;
  191.              }
  192.      }
  193.      /*
  194.      * 通过递归得到某一路径下所有的目录及其文件
  195.      */
  196.      static ArrayList < String > getFiles ( ArrayList < String > filelist , String filePath ) {
  197.      File root = new File (filePath ) ;
  198.      File [ ] files = root . listFiles ( ) ;
  199.      for ( File file :files ) {
  200.      if ( file . isDirectory ( ) ) {
  201.      getFiles (filelist , file . getAbsolutePath ( ) ) ;
  202.     
  203.          } else {
  204.                  int a =0 ;
  205.                  String fileParentPath = file . getParent ( ) ;
  206.      for ( String str :filelist ) {
  207.                  if (str . endsWith (fileParentPath ) ) {
  208.                        a =1 ;
  209.                  }
  210.      }
  211.      if (a = =0 ) {
  212.                    filelist . add ( file . getParent ( ) ) ;
  213.          //System.out.println("显示:"+fileParentPath);
  214.      }
  215.      }
  216.      }
  217.      return filelist ;
  218.      }
  219.      /*
  220.      * 添加问价后缀
  221.      */
  222.      static void getFileNames ( String path ) {
  223.          File file = new File (path ) ;
  224.          if ( file . exists ( ) ) {
  225.              File [ ] files = file . listFiles ( ) ;
  226.              if (files . length = = 0 ) {
  227.                  System .out . println ( "文件夹是空的!" ) ;
  228.                  return ;
  229.              } else {
  230.                  for ( File file2 : files ) {
  231.                      if (file2 . isDirectory ( ) ) {
  232.                         getFileNames (file2 . getAbsolutePath ( ) ) ;
  233.                      } else {
  234.                          file2 . renameTo ( new File (file2 . getParent ( ) + "/" + file2 . getName ( ) + ".txt" ) ) ;
  235.                      }
  236.                  }
  237.              }
  238.          } else {
  239.              System .out . println ( "文件不存在!" ) ;
  240.          }
  241.      }
  242.      /*执行bat文件*/
  243.      /*指定bat执行目录*/
  244.      static void run_cmd ( String strcmd , File dir ) {
  245.          //
  246.          Runtime rt = Runtime . getRuntime ( ) ; //Runtime.getRuntime()返回当前应用程序的Runtime对象
  247.          Process ps = null ; //Process可以控制该子进程的执行或获取该子进程的信息。
  248.          try {
  249.                     ps = rt . exec (strcmd , null ,dir ) ; //该对象的exec()方法指示Java虚拟机创建一个子进程执行指定的可执行程序，并返回与该子进程对应的Process对象实例。
  250.                     ps . waitFor ( ) ; //等待子进程完成再往下执行。
  251.          } catch ( IOException e1 ) {
  252.                     e1 . printStackTrace ( ) ;
  253.          } catch ( InterruptedException e ) {
  254.          // TODO Auto-generated catch block
  255.                     e . printStackTrace ( ) ;
  256.          }

  258.          int i = ps . exitValue ( ) ; //接收执行完毕的返回值
  259.          if (i = = 0 ) {
  260.          System .out . println ( "执行完成." ) ;
  261.          } else {
  262.          System .out . println ( "执行失败." ) ;
  263.          }

  265.                 ps . destroy ( ) ; //销毁子进程
  266.                 ps = null ;
  267.      }
  268.        /*不指定执行目录*/
  269. //    static void run_cmd(String strcmd) {
  270. //        //
  271. //                Runtime rt = Runtime.getRuntime(); //Runtime.getRuntime()返回当前应用程序的Runtime对象
  272. //                Process ps = null;  //Process可以控制该子进程的执行或获取该子进程的信息。
  273. //                try {
  274. //                    ps = rt.exec(strcmd);   //该对象的exec()方法指示Java虚拟机创建一个子进程执行指定的可执行程序，并返回与该子进程对应的Process对象实例。
  275. //                    ps.waitFor();  //等待子进程完成再往下执行。
  276. //                } catch (IOException e1) {
  277. //                    e1.printStackTrace();
  278. //                } catch (InterruptedException e) {
  279. //                    // TODO Auto-generated catch block
  280. //                    e.printStackTrace();
  281. //                }
  282. //
  283. //                int i = ps.exitValue();  //接收执行完毕的返回值
  284. //                if (i == 0) {
  285. //                    System.out.println("执行完成.");
  286. //                } else {
  287. //                    System.out.println("执行失败.");
  288. //                }
  289. //
  290. //                ps.destroy();  //销毁子进程
  291. //                ps = null;
  292. //    }
  293.      /**/
  294. }





来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/29399342/viewspace-2138676/ ，如需转载，请注明出处，否则将追究法律责任。

0
0
上一篇： 没有了~
下一篇： 如何在十分钟内插入1亿条记录到Oracle数据库？
请登录后发表评论 登录
全部评论
jvche12

注册时间：2017-05-03

  • 博文量
    3
  • 访问量
    8578

最新文章

支持我们 作者招募 用户协议 FAQ Contact Us

北京盛拓优讯信息技术有限公司. 版权所有  京ICP备16024965号-8 北京市公安局海淀分局网监中心备案编号：11010802021510 niuxiaotong@pcpop.com 17352615567 未成年人举报专区

广播电视节目制作经营许可证(京) 字第1234号 中国互联网协会会员

违法和不良信息举报电话:18101376593