l?o?t?u?s?数?据?用?j?a?v?a?程?序?导?入?导?出代码,Java代码库,德仔网

代码语言
代码分类
【Java】 l?o?t?u?s?数?据?用?j?a?v?a?程?序?导?入?导?出
作者:entry / 发布于2014/7/25/ 896

	public void run(String servername, String username, String password,
	String dbname, String viewname) {
	try {
	// 取得配置文件取得临时中专的文件目录.提交的数据到服务的名称 ,端口
	ResourceBundle localizationResources = ResourceBundle
	.getBundle("ip");
	// 临时目录
	String temppath = localizationResources.getString("temppath");
	// 端口
	String port = localizationResources.getString("port");
	// 应用名称
	String webapp = localizationResources.getString("webapp");
	// 文档数量
	int rundocnum = 0;
	// 附件的文件数量
	int filenum = 0;
	// 应用的域名
	String dominoHost = servername;// "dev1";
	// 数据操作的session
	Session session;
	// 通过 http 获取 IOR
	String 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) {
	bExit = true;
	} else {
	if (strIOR == null)
	strIOR = line;
	else
	strIOR = 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" + 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 = " + p);
	// 开始执行的时间
	long a = System.currentTimeMillis();

	System.out.print("开始计时 ");
	/*
	* 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(); System.out.print("getViews"+db.getViews().size());
	* for(int i=0;i<2;i++){
	* System.out.print("用时："+(System.currentTimeMillis()-a)); View v =
	* (View) db.getView(vs.get(i).toString().trim());
	*/

	View v = (View) db.getView(viewname);// 直接使用某个视图
	// 当前视图的文档数量
	int count = v.getAllEntries().getCount();
	System.out.println("视图名称：" + v.getName());
	System.out.print("别名：" + v.getAliases());
	ViewNavigator nav = v.createViewNav();
	ViewEntry entry = nav.getFirstDocument();
	/**
	* 对视图包括的文档的循环查询并处理
	*/
	for (int j = 0; j < count; j++) {
	rundocnum++;
	String title = "";
	String user = "";
	String body = "";
	String key = "";
	List filelist = new ArrayList();
	System.out.print((j + 1) + "...");
	System.out.println("标题"
	+ entry.getDocument().getItemValueString("title"));
	title = entry.getDocument().getItemValueString("title");

	String oldname = entry.getDocument().getAuthors().toString()
	.trim();
	String newname = oldname.substring(oldname.indexOf("cn=") + 5,
	oldname.indexOf("/OU"));
	user = com.mdcl.bjcnc.information.util.UserInfoUtil
	.findUIDbyName(entry.getDocument().getAuthors()
	.toString().trim());
	System.out.println("作者：" + user);
	body = entry.getDocument().getItemValueString("body");
	System.out.println("正文:" + body);

	Enumeration items = entry.getDocument().getItems().elements();
	// 删除上一个文档附件文件在本地的副本
	if (!entry.getDocument().getItems().isEmpty()) {
	File f1 = new File(temppath);
	if (f1.isDirectory()) {
	for (int m = 0; m < f1.listFiles().length; m++) {
	System.out.print("删除文件"
	+ f1.listFiles()[m].getAbsoluteFile()
	.getPath());
	f1.listFiles()[m].getAbsoluteFile().delete();

	}
	}
	// 对当前文档的附件生成副本并上传到服务器
	while (items.hasMoreElements()) {
	Item item = (Item) items.nextElement();
	if (item.getType() != Item.ATTACHMENT) {
	} else {
	filenum++;
	System.out.println("附件："
	+ entry.getDocument().getAttachment(
	item.getValueString()).getName());
	EmbeddedObject EObjAttachment = entry.getDocument()
	.getAttachment(item.getValueString());
	InputStream is = EObjAttachment.getInputStream();
	long fileSize = is.available();
	if (fileSize > 0) {
	byte[] buf = new byte[(int) fileSize];
	is.read(buf);
	File f = new File(temppath + "/"
	+ EObjAttachment.getSource());
	FileOutputStream fos = new FileOutputStream(f);
	fos.write(buf);
	fos.flush();
	fos.close();
	System.out.print("创建文件" + f.getAbsolutePath());
	filelist.add(f);
	}
	}
	}
	// 提交数据到数据库
	// 调用增加数据到数据库的方法1 返回一个key
	key = "0";// 此处增加数据到数据库
	// 调用http post 的方式提交数据
	if (filelist.size() > 0) {
	InetAddress addr = InetAddress.getLocalHost();
	String sAddr = addr.toString(); // localhost/127.0.0.1
	String sIP = sAddr.substring(sAddr.indexOf('/') + 1);
	if (!webapp.equals("")) {
	webapp = webapp + "/";
	}
	PostMethod filePost = new PostMethod("http://" + sIP
	+ ":" + port + webapp + "servlet/upload?key="
	+ key);
	System.out.println("http://" + sIP + ":" + port
	+ webapp + "servlet/upload?key=" + key);
	try {
	Part[] parts = new Part[filelist.size()];
	for (int i = 0; i < filelist.size(); i++) {
	parts[i] = new FilePart("hello" + i, new File(
	filelist.get(i).toString()));
	}
	filePost
	.setRequestEntity(new MultipartRequestEntity(
	parts, filePost.getParams()));
	HttpClient client = new HttpClient();
	client.getHttpConnectionManager().getParams()
	.setConnectionTimeout(5000);
	int status = client.executeMethod(filePost);
	} catch (Exception e) {

	e.printStackTrace();
	}
	}
	// 提交完成
	// 每当处理完当前文档,必须把指针指向下一个文档地址
	entry = nav.getNextDocument();
	}
	}
	System.out.println("用时：" + (System.currentTimeMillis() - a));
	System.out.println("doc num：" + rundocnum);
	System.out.println("file num：" + filenum);
	} catch (NotesException e) {
	e.printStackTrace();
	} catch (Exception e1) {
	e1.printStackTrace();
	}
	}
试试其它关键字
　导?入?导?出　
同语言下
可能有用的
entry贡献的其它代码(10)