先来一个MessageInputer.java
//MessageInputer.java
import java.io.*;
import java.util.*;
public class MessageInputer {
private static PrintWriter stdOut =
new PrintWriter(System.out, true);
private static BufferedReader stdIn =
new BufferedReader(new InputStreamReader(System.in));
private static PrintWriter stdErr =
new PrintWriter(System.err, true);
Vector vector = new Vector();
public void process_in() throws IOException{
String str="";
stdOut.println("Input:");
do{
str=stdIn.readLine();
if ("n".equalsIgnoreCase(str))
{
break;
}
vector.add(str);
stdOut.println("Continue(n to cancle)?");
}while(true);
}
public Vector get_vector(){
return vector;
}
}
第二个
//FillOpterator.java
import java.io.*;
import java.util.*;
public class FillOpterator {
private static PrintWriter stdOut =
new PrintWriter(System.out, true);
private static BufferedReader stdIn =
new BufferedReader(new InputStreamReader(System.in));
private static PrintWriter stdErr =
new PrintWriter(System.err, true);
public void process_file(Vector m_vector) throws IOException{
PrintWriter output =
new PrintWriter(new FileWriter("Mytext.DF",true));
for (Iterator i = m_vector.iterator() ; i.hasNext(); ) {
stdErr.flush();
String input=(String)i.next();
if(input != null) {
output.println(input);
}
stdOut.println("done");
}
output.close();
}
}
第三个
//DBHandle.java
import java.io.*;
import java.sql.*;
public class DBHandle {
private static BufferedReader stdIn =
new BufferedReader(new InputStreamReader(System.in));
/* Standard output stream */
private static PrintWriter stdOut =
new PrintWriter(System.out, true);
/* Standard error stream */
private static PrintWriter stdErr =
new PrintWriter(System.err, true);
static public void getConnection() throws IOException, SQLException
{
stdErr.flush();
BufferedReader input =
new BufferedReader( new FileReader("Mytext.DF"));
String line = input.readLine();
//ResultSet rs = null;
Connection conn = null;
while(line != null){
try{
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
conn = DriverManager.getConnection("jdbc:odbc:driver={Microsoft Access Driver (*.mdb)};" +
"DBQ=Mytext.mdb");
System.out.println(line);
Statement statement = conn.createStatement();
String sql = "insert into user values("+ "'"+line+"')";
statement.executeUpdate(sql);
line = input.readLine();
}
catch(Exception ex){
System.out.println(ex);
System.exit(0);
}
//rs.close();
conn.close();
}
return ;
}
}
第四个:
//MessageCenter.java
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.sql.SQLException;
import java.util.*;
public class MessageCenter {
/**
* @param args
* @throws IOException
*/
private static PrintWriter stdOut =
new PrintWriter(System.out, true);
private static BufferedReader stdIn =
new BufferedReader(new InputStreamReader(System.in));
private static PrintWriter stdErr =
new PrintWriter(System.err, true);
public static void main(String[] args) throws IOException, SQLException {
// TODO Auto-generated method stub
MessageInputer a=new MessageInputer();
a.process_in();
String result = "";
for (Iterator i = a.get_vector().iterator() ; i.hasNext(); ) {
result += (String) i.next();
}
stdOut.println(result);
FillOpterator f = new FillOpterator();
f.process_file(a.get_vector());
DBHandle.getConnection();
}
}
累死了,,呵呵
不知道是不是你想要的,当然,如果是的话你也要修改一下
如果不是也没关系,就当顺便把java学了,呵呵
数据库要自己建,我没对没数据库的情况做异常出理
PrintWriter(new FileWriter("Mytext.DF",true))和PrintWriter(new FileWriter("Mytext.DF"))有区别
温馨提示:答案为网友推荐,仅供参考