lotus數(shù)據(jù)用java程序?qū)雽?dǎo)出實(shí)現(xiàn)數(shù)據(jù)移置的方案

1、下面的代碼實(shí)現(xiàn)了數(shù)據(jù)導(dǎo)出,并實(shí)現(xiàn)了數(shù)據(jù)導(dǎo)入到其他系統(tǒng)中.,包括附件的處理.public void run(String servername, String username, String password,String dbname, String viewname) try / 取得配置文件取得臨時(shí)中專的文件目錄.提交的數(shù)據(jù)到服務(wù)的名稱 ,端口ResourceBundle localizationResources = ResourceBundle.getBundle("ip");/ 臨時(shí)目錄String temppath = localizationResource

2、s.getString("temppath");/ 端口String port = localizationResources.getString("port");/ 應(yīng)用名稱String webapp = localizationResources.getString("webapp");/ 文檔數(shù)量int rundocnum = 0;/ 附件的文件數(shù)量int = 0;/ 應(yīng)用的域名String dominoHost = servername;/ "dev1"/ 數(shù)據(jù)操作的sessionSession sessi

3、on;/ 通過 http 獲取 IORString strIOR = null;URL url = new URL("http:/" + dominoHost + "/diiop_ior.txt");InputStream in = url.openStream();BufferedReader br = new BufferedReader(new InputStreamReader(in);for (boolean bExit = false; !bExit;) String line = br.readLine();if (line = null)

4、 bExit = true; else if (strIOR = null)strIOR = line;elsestrIOR = strIOR + line;if (strIOR.startsWith("IOR:")bExit = true;br.close();/ System.out.println("strIOR - " + strIOR);session = NotesFactory.createSessionWithIOR(strIOR, username,password);/ System.out.println("session

5、" + session); / 如果這一行打印出來了,表示連接成功/ Database db = session.getDatabase(null, "zboa/gkxx.nsf");/ Database db = session.getDatabase(null, "zboa/scjyxx.nsf");Database db = session.getDatabase(null, dbname);/ String p = session.getPlatform();/ System.out.println("run Platform

6、 = " + p);/ 開始執(zhí)行的時(shí)間long a = System.currentTimeMillis();System.out.print("開始計(jì)時(shí) ");/* Vector vss= (Vector)db.getViews(); List vs=new ArrayList();* for(int i=0;i<vss.size();i+) /* vs.add(View)vss.get(i).getName() ; System.out.println(View)* vss.get(i).getName(); * * vss.clear(); Syste

7、m.out.print("getViews"+db.getViews().size();* for(int i=0;i<2;i+)* System.out.print("用時(shí)："+(System.currentTimeMillis()-a); View v =* (View) db.getView(vs.get(i).toString().trim();*/View v = (View) db.getView(viewname);/ 直接使用某個(gè)視圖/ 當(dāng)前視圖的文檔數(shù)量int count = v.getAllEntries().getCount(

8、);System.out.println("視圖名稱：" + v.getName();System.out.print("別名：" + v.getAliases();ViewNavigator nav = v.createViewNav();ViewEntry entry = nav.getFirstDocument();/* 對(duì)視圖包括的文檔的循環(huán)查詢并處理*/for (int j = 0; j < count; j+) rundocnum+;String title = ""String user = ""

9、;String body = ""String key = ""List = new ArrayList();System.out.print(j + 1) + ".");System.out.println("標(biāo)題"+ entry.getDocument().getItemValueString("title");title = entry.getDocument().getItemValueString("title");String oldname = entry.ge

10、tDocument().getAuthors().toString().trim();String newname = oldname.substring(oldname.indexOf("cn=") + 5,oldname.indexOf("/OU");user = erInfoUtil.findUIDbyName(entry.getDocument().getAuthors().toString().trim();System.out.println("作者：" + user);body = entry.getDocument()

11、.getItemValueString("body");System.out.println("正文:" + body);Enumeration items = entry.getDocument().getItems().elements();/ 刪除上一個(gè)文檔附件文件在本地的副本if (!entry.getDocument().getItems().isEmpty() = new );if (f1.isDirectory() for (int m = 0; m < f1.listFiles().length; m+) System.out.pr

12、int("刪除文件"+ f1.listFiles()m.getAbsoluteFile().getPath();f1.listFiles()m.getAbsoluteFile().delete();/ 對(duì)當(dāng)前文檔的附件生成副本并上傳到服務(wù)器while (items.hasMoreElements() Item item = (Item) items.nextElement();if (item.getType() != Item.ATTACHMENT) else ;System.out.println("附件："+ entry.getDocument()

13、.getAttachment(item.getValueString().getName();EmbeddedObject EObjAttachment = entry.getDocument().getAttachment(item.getValueString();InputStream is = EObjAttachment.getInputStream();long = is.available();if ( > 0) byte buf = new byte(int) ;is.read(buf);File f = new + "/"+ EObjAttachme

14、nt.getSource(); fos = new (f);fos.write(buf);fos.flush();fos.close();System.out.print("創(chuàng)建文件" + f.getAbsolutePath();(f);/ 提交數(shù)據(jù)到數(shù)據(jù)庫/ 調(diào)用增加數(shù)據(jù)到數(shù)據(jù)庫的方法1 返回一個(gè)keykey = "0"/ 此處增加數(shù)據(jù)到數(shù)據(jù)庫/ 調(diào)用http post 的方式提交數(shù)據(jù)if () > 0) InetAddress addr = InetAddress.getLocalHost();String sAddr = addr.toStr

15、ing(); / localhost/String sIP = sAddr.substring(sAddr.indexOf('/') + 1);if (!webapp.equals("") webapp = webapp + "/"PostMethod = new PostMethod("http:/" + sIP+ ":" + port + webapp + "servlet/upload?key="+ key);System.out.println(&quo

16、t;http:/" + sIP + ":" + port+ webapp + "servlet/upload?key=" + key);try Part parts = new Part();for (int i = 0; i < (); i+) partsi = new ("hello" + i, new File(i).toString();.setRequestEntity(new MultipartRequestEntity(parts, ();HttpClient client = new HttpClient();client.getHttpConnectionManager().getParams().setConnectionTimeout(5000);int status = client.executeMethod(); catch (Exception e) e.printStackTrace();/ 提交完成/ 每當(dāng)處理完當(dāng)前文檔,必須把指針指向下一個(gè)文檔地址entry = nav.getNextDocument();