读书人
栏目▼

小妹留学僧~关于java的有关问题异国

发布时间： 2012-12-22 12:05:07 作者： rapoo

小妹留学僧~关于java的问题，异国他乡向各位同胞大大求助啊，求助求助！
本帖最后由 thistf 于 2012-11-14 02:07:08 编辑 作业基本就是一个利用jdbc连接数据库并且操作数据的编程作业..因为之前没有接触过java，所以都是摸索着来的，这个是我实现的能够读配置文件连接数据库，并且把一个文件的内容导入到数据库中.代码贴在下面，本来我这个程序直接java db 就可以运行了， 可是老师要求运行程序的命令行是java -classpath .;mysql-connector-java-5.1.18-bin.jar Populate db.properties student.txt vehicle.txt route.txt stop.txt zone.txt
的格式

因为没有学过java，都是找类似资料来实现的，这个要求找不到相应的资料只能求助各位大大了~拜托拜托了！

还有就是我的代码只是实现了读一个文件进去，老师这个要求是一下子读5个文件进去，分别存到不同的表里，而且要求要用 JDBC PreparedStatement construct来实现重复的语句...请问这个该怎么修改代码啊

祝路过各位大大一生平安啊！！！

package practice;
/*test*/
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.util.List;
import java.util.ArrayList;
import java.io.*;
import java.io.File;
import java.io.FileInputStream;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.SQLException;  
import java.sql.Statement; 
public class DB {
    public static void main(String[]args){
        String s;
int t = 0;
String[] sa=new String[5];
        List data = new ArrayList();
        try{
        BufferedReader in =new BufferedReader(new FileReader("src/db.properties"));
        while((s=in.readLine())!=null){
            sa[t] =s.substring(0);
t++;
        }
        }
        catch(FileNotFoundException e){
            e.printStackTrace();
        }
        catch(IOException e){
            e.printStackTrace();
        }
       /*connect the DB*/ 
    String url = "jdbc:mysql://"+sa[0]+":"+sa[1]+"/"+sa[2];
    String username = sa[3];
    String password = sa[4];
    Connection conn = null;
    Statement stmt = null;
    try{
        conn = DriverManager.getConnection(url, username, password);  
        stmt = conn.createStatement();  
}catch (SQLException e1) {  
            e1.printStackTrace();  
        } 
    /*put data in DB*/
File file = new File("D:\\HW3\\HW3\\data\\student.txt");  
    FileInputStream fis = null;  
try {  
             fis = new FileInputStream(file);   
 
            InputStreamReader input = new InputStreamReader(fis);  
            BufferedReader br = new BufferedReader(input);  
            String line = null;  
            String sql = null;  
            String info[] = null;  
            String path = file.getAbsolutePath();//得到选择文件的全路径  
            String fileName = path.substring(path.lastIndexOf("\\")+1, path.lastIndexOf("."));//取得所选文件名  
            String province = fileName.substring(0,fileName.length()-2);  
            String cardType = fileName.substring(fileName.length()-2);  
            try {  
                while((line = br.readLine())!= null){  
                    info = line.split(",");  
                    sql = sql = "insert into cc(A,B,C)values('"+ info[0] +"','"+info[1]+"','"+info[2]+"')";  
                    stmt.executeUpdate(sql);  
                }  
            } catch (IOException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            } catch (SQLException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
              
               
        }catch (FileNotFoundException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }finally{  
            if(conn != null){  
                try {   
 
                    conn.close();  
                } catch (SQLException e) {  
                    // TODO Auto-generated catch block  
                    e.printStackTrace();  
                }  
            }  
        } 

    }
    
}


还有就是配置文件路径这个地方有个问题就是我用netbeans能执行的没有问题，可是我把文件拿出来用命令行执行就说我找不到db.properties了，我明明吧程序和db.properties都还有连接驱动都放到一个文件夹下了
[最优解释]

CREATE TABLE `route` (
   `id` INT(11) NOT NULL AUTO_INCREMENT,
   `r1` VARCHAR(255) DEFAULT NULL,
   `r2` VARCHAR(255) DEFAULT NULL,
   `r3` VARCHAR(255) DEFAULT NULL,
   PRIMARY KEY (`id`)
 );
 
 

CREATE TABLE `student` (
   `id` INT(11) NOT NULL AUTO_INCREMENT,
   `st1` VARCHAR(255) DEFAULT NULL,
   `st2` VARCHAR(255) DEFAULT NULL,
   `st3` VARCHAR(255) DEFAULT NULL,
   PRIMARY KEY (`id`)
 ) ;
 
 CREATE TABLE `vehicle` (
   `id` INT(11) NOT NULL AUTO_INCREMENT,
   `v1` VARCHAR(255) DEFAULT NULL,
   `v2` VARCHAR(255) DEFAULT NULL,
   `v3` VARCHAR(255) DEFAULT NULL,
   PRIMARY KEY (`id`)
 ) ;
 
 CREATE TABLE `zone` (
   `id` INT(11) NOT NULL AUTO_INCREMENT,
   `z1` VARCHAR(255) DEFAULT NULL,
   `z2` VARCHAR(255) DEFAULT NULL,
   `z3` VARCHAR(255) DEFAULT NULL,
   `z4` VARCHAR(255) DEFAULT NULL,
   PRIMARY KEY (`id`)
 ) ;
 
 CREATE TABLE `stop` (
   `id` INT(11) NOT NULL AUTO_INCREMENT,
   `s1` VARCHAR(255) DEFAULT NULL,
   `s2` VARCHAR(255) DEFAULT NULL,
   `s3` VARCHAR(255) DEFAULT NULL,
   PRIMARY KEY (`id`)
 );



route.txt内容

r1-1,r1-2,r1-3
r2-1,r2-2,r2-3

stop.txt 内容

s1-1,s1-2,s1-3
s2-1,s2-2,s2-3

student.txt内容

st1-1,st1-2,st1-3
st2-1,st2-2,st2-3

vehicle.txt内容

v1-1,v1-2,v1-3
v2-1,v2-2,v2-3

zone.txt内容（上面几个txt一行3个数据，一行有4个数据）

z1-1,z1-2,z1-3,z1-4
z2-1,z2-2,z2-3,z2-4






import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

public class Populate {
public static void main(String[] args) {
PreparedStatement pstm=null;
Connection conn = null;
try {

File propertiesFile=new File(args[0]);
Properties prop = new Properties();
FileInputStream fis = new FileInputStream(propertiesFile);
prop.load(fis);
String username=prop.getProperty("username");
String password=prop.getProperty("password");
String url = prop.getProperty("url");
File studentFile=new File(args[1]);
    File vehicleFile=new File(args[2]);
File routeFile=new File(args[3]);
    File stopFile=new File(args[4]);
    File zoneFile=new File(args[5]);
    List<File> fileList=new ArrayList<File>();
    fileList.add(studentFile);
    fileList.add(routeFile);
    fileList.add(stopFile);
    fileList.add(vehicleFile);
    fileList.add(zoneFile);
    Class.forName("com.mysql.jdbc.Driver");
    conn = DriverManager.getConnection(url, username, password);  
    
String fileds="";
    String routeFields="r1,r2,r3";
String stopFields="s1,s2,s3";
String studentFields="st1,st2,st3";
String vehicleFields="v1,v2,v3";
String zoneFields="z1,z2,z3,z4";
    for (File file : fileList) {
    String fileName=file.getName();
fileName = fileName.replace(".txt", "");
System.out.println("fileName..."+fileName);
FileReader fr = new FileReader(file);
BufferedReader  bufferedReader=new BufferedReader  (fr);
String str="";
String[] values=null;
//通过文件名称来判断这个表的fileds
if(fileName.equals("route")){
fileds=routeFields;
}else if(fileName.equals("stop")){
fileds=stopFields;
}else if(fileName.equals("student")){
fileds=studentFields;
}else if(fileName.equals("zone")){
fileds=zoneFields;
}else if(fileName.equals("vehicle")){
fileds=vehicleFields;
}
String[] s=fileds.split(",");
int k=s.length;
String val="";
for(int i =0 ;i<k;i++ ){
if(i<k-1){
val+=" ? , ";
}else{
val+=" ? ";
}
}
while ((str=bufferedReader.readLine())!=null) {
values=str.split(",");
String sql="insert into "+fileName+" ( "+ fileds + " ) values ( " +val+ " )";
System.out.println(sql);
pstm =conn.prepareStatement(sql); 
for (int i = 1; i <= k; i++) { 
 
System.out.println("set value.."+values[i-1]);
pstm.setString(i, values[i-1]);//values数组下标从0开始，当pstm设置第一个？的时候 values则是第[0]个

}
pstm.execute();

}



bufferedReader.close();
fr.close();

    }
} catch (Exception e) {
e.printStackTrace();
}finally{
try {
pstm.close();
conn.close();
} catch (Exception e2) {
e2.printStackTrace();
}

}
}
}



在cmd里面执行如下命令
javac Populate.java
java -classpath .;mysql-connector-java-5.1.18-bin.jar Populate db.properties student.txt vehicle.txt route.txt stop.txt zone.txt

[其他解释]
package DB;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class DBUtils {

static {
try {
Class.forName("com.mysql.jdbc.Driver");
}catch(ClassNotFoundException e){
System.out.println("Driver fails to load...");
}
}

public static Connection getConn(){
Connection conn = null;
try {
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/数据库名?useUnicode=true&characterEncoding=GBK","root","root");
} catch(SQLException e){
System.out.println("link failed to database...");
}
return conn;
}

public static PreparedStatement getPstmt(Connection conn, String sql) {
PreparedStatement ps = null;
try{
ps = conn.prepareStatement(sql);
}catch(SQLException e){
System.out.println("预处理失败");
}
return ps;
}

public static void close(ResultSet rs, PreparedStatement ps, Connection conn){
if(rs != null){
try{
rs.close();
}catch(SQLException e){
System.out.println("关闭异常");
}
}
if(ps != null){
try{
ps.close();
}catch(SQLException e){
System.out.println("关闭异常");
}
}
if(conn != null){
try{
conn.close();
}catch(SQLException e){
System.out.println("关闭异常");
}
}
}
}

当你要使用的时候直接:
Connection conn = DBUtils.getConn();
PreparedStatement pstmt = DBUtils.getPstmt();
然后就可以执行pstmt了
[其他解释]
留学僧小妹，偶是来打酱油滴
[其他解释]
可以在properties的文件中加入配置，将需要读的文件与对应的sql按照一定的名称进行配置，然后将读文件那个方法进行修改，获取配置文件中的文件名与sql语句，循环执行。
[其他解释]
你导师的意思是你那些TXT通过main函数的 java里面叫方法是吧。的参数传递进去。即String arg0[]
[其他解释]
引用:
你导师的意思是你那些TXT通过main函数的 java里面叫方法是吧。的参数传递进去。即String arg0[]

BufferedReader in =new BufferedReader(new FileReader("src/db.properties"));



楼主 你上面这句话什么意思哦。 写死了额。 这个不用我解释，自己看得懂吧 还有 这个参数是arg0[] 传进来的 按你的导师的要求。你应该是从传入的字符串数据的第一个位置获取这个值。
[其他解释]
哇塞 中文这么好，哪国的？有图有答案
[其他解释]
应该检查args数组的内容。。。。。
[其他解释]
既然可以导入一个文件那就依葫芦画瓢，将其他的文件也导入
[其他解释]
既然可以导入一个文件那其他的文件也应该会导入了吧

[其他解释]

引用:
既然可以导入一个文件那就依葫芦画瓢，将其他的文件也导入


说是要用PreparedStatement呢，这个我不是很懂....能给讲讲怎么用在这个问题上面吗，难道要重复的去写代码吗...
[其他解释]
引用:
你导师的意思是你那些TXT通过main函数的 java里面叫方法是吧。的参数传递进去。即String arg0[]

是啊，我觉得也是，可是不知道具体怎么把一个文件作为参数哦
[其他解释]
我现在明白是应该利用java的命令行参数来将文件导入...可是查来查去也不知道具体该怎么搞，再一个问题就是把不同的txt文件的内容导入不同名称的表，如何用PreparedStatemente避免重复代码啊。
You are required to implement a Java program Populate.java that gets the names of the
input data files as command line parameters and populate the data contained within them into
your database by executing individual insert statements for each row using JDBC. Note that
you should use the JDBC PreparedStatement construct when executing the same
statement repeatedly.
这个是老师的要求....不晓得大大们会不会嫌英文麻烦...
[其他解释]
引用:
我现在明白是应该利用java的命令行参数来将文件导入...可是查来查去也不知道具体该怎么搞，再一个问题就是把不同的txt文件的内容导入不同名称的表，如何用PreparedStatemente避免重复代码啊。
You are required to implement a Java program Populate.java that gets the names of the
input d……

PreparedStatement用?代替变量.然后加载后setString给赋值.由于PreparedStatement内置了字符过滤
那么就相当于 where name = ' or 1 or '显然没有对应记录.所以数据结果为空.这就体现了PreparedStatement的防注入功能
所以提倡大家只要是动态参数就是用PreparedStatement去代替Statement.况且效率也不错.优化的很好.

感觉 你老师 的意思 是让你去写程序 读一个文件夹，得出文件夹下 所有的文件名字，以参数的形式传入你写功能，再用PreparedStatement 去存入数据库


[其他解释]
引用:
哇塞 中文这么好，哪国的？有图有答案

prepareStatement的使用

conn = DBUtils.getConnection();
          String sql = "select * from users where lastname = ?"; // 这里用问号        
           st = conn.prepareStatement(sql);
          st.setString(1,name); // 这里将问号赋值
            rs = st.executeQuery();


------其他解决方案--------------------


当然如果你的数据库不是mysql的话，就要改变驱动了，还有你的数据库名，以及账号，密码
[其他解释]
路过，lz加油，求学习！
[其他解释]

引用:
引用:我现在明白是应该利用java的命令行参数来将文件导入...可是查来查去也不知道具体该怎么搞，再一个问题就是把不同的txt文件的内容导入不同名称的表，如何用PreparedStatemente避免重复代码啊。
You are required to implement a Java program Populate.java that……

这个哥哥我研究下你的代码发现我这里可以用execute executeUpdate 但是不能用executequery
还有就是能麻烦你看看我刚刚贴出来的代码，里面关于preparestatement的用法对不对吗？
[其他解释]
我现在已经实现了的功能是用命令行参数读入一个配置文件去连接数据库，然后在读一个文件将该文件的内容存入数据库已有的表里。可是我们老师要求的是读五个文件，然后将这五个文件分别存入不同的已存在的表里面？请问我存入数据那块的代码就要重复写五遍吗？ 下面是我全部代码
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.util.List;
import java.util.ArrayList;
import java.io.*;
import java.io.File;
import java.io.FileInputStream;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.SQLException;  
import java.sql.PreparedStatement; 

public class db {
    public static void main(String[]args){
    /*read the properties*/
String s;
int t = 0;
String[] sa=new String[5];
        List data = new ArrayList();
        try{
        BufferedReader in =new BufferedReader(new FileReader(args[0]));
        while((s=in.readLine())!=null){
            sa[t] =s.substring(0);
t++;
        }
        }
        catch(FileNotFoundException e){
            e.printStackTrace();
        }
        catch(IOException e){
            e.printStackTrace();
        }
    /*connect the DB*/ 
    String url = "jdbc:mysql://"+sa[0]+":"+sa[1]+"/"+sa[2];
    String username = sa[3];
    String password = sa[4];
    Connection conn = null;
    PreparedStatement stmt = null;
    try{
        conn = DriverManager.getConnection(url, username, password);  
          
}catch (SQLException e1) {  
            e1.printStackTrace();  
        } 
    /*put data in DB*/
File file = new File(args[1]);  
    FileInputStream fis = null;   
 
try {  
             fis = new FileInputStream(file);  
            InputStreamReader input = new InputStreamReader(fis);  
            BufferedReader br = new BufferedReader(input);  
            String line = null;  
            String sql = null;  
            String info[] = null;  
            String path = file.getAbsolutePath();//得到选择文件的全路径  
            String fileName = path.substring(path.lastIndexOf("\\")+1, path.lastIndexOf("."));//取得所选文件名  
            String province = fileName.substring(0,fileName.length()-2);  
            String cardType = fileName.substring(fileName.length()-2);  
            try {  
                while((line = br.readLine())!= null){  
                    info = line.split(",");  
                    sql = "insert into cc(A,B,C)values('"+ info[0] +"','"+info[1]+"','"+info[2]+"')";  
                    stmt = conn.prepareStatement(sql);
                    stmt.executeUpdate(); 
 }  
            } catch (IOException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            } catch (SQLException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
              
               
        }catch (FileNotFoundException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();   
 
        }finally{  
            if(conn != null){  
                try {  
                    conn.close();  
                } catch (SQLException e) {  
                    // TODO Auto-generated catch block  
                    e.printStackTrace();  
                }  
            }  
        } 

    }
    
}

[其他解释]
海龟挺牛的
[其他解释]
引用:
当然如果你的数据库不是mysql的话，就要改变驱动了，还有你的数据库名，以及账号，密码

请看我新修改的代码，对于preparestatement的用法对吗？

[其他解释]
引用:
引用:这个哥哥我研究下你的代码发现我这里可以用execute executeUpdate 但是不能用executequery
还有就是能麻烦你看看我刚刚贴出来的代码，里面关于preparestatement的用法对不对吗？
preparestatement 应该没有问题 但是不理解 你老师说的一次读5个文件， 是要 多线程 ……

老师要求最后能用这样的命令运行程序 java -classpath .;mysql-connector-java-5.1.18-bin.jar Populate db.properties student.txt vehicle.txt route.txt stop.txt zone.txt

后面就是5个txt文件，可能是我说的不够明白吧，就是把5个文件的数据输入数据库，至于是不是多线程神马的木有做具体的要求，就是导入就可以。 还有就是我这样用preparestatement的方式是不是没有办法防止注入的？谢谢您哈
[其他解释]
引用:
这个哥哥我研究下你的代码发现我这里可以用execute executeUpdate 但是不能用executequery
还有就是能麻烦你看看我刚刚贴出来的代码，里面关于preparestatement的用法对不对吗？

preparestatement 应该没有问题 但是不理解 你老师说的一次读5个文件， 是要 多线程 每个线程读一个？ 还是先写缓存里 在入库就不了解了。
[其他解释]
引用:
海龟挺牛的

小妹还不知道能不能龟呐 毕不了业就海漂了 泪奔
[其他解释]
引用:
引用:这个哥哥我研究下你的代码发现我这里可以用execute executeUpdate 但是不能用executequery
还有就是能麻烦你看看我刚刚贴出来的代码，里面关于preparestatement的用法对不对吗？
preparestatement 应该没有问题 但是不理解 你老师说的一次读5个文件， 是要 多线程 ……

对了..您能不能给解释下那个命令行里面 -classpath .; 是什么意思？ 为啥还有个点和分号呢？
[其他解释]

CREATE TABLE `student`(    
 `id` INT NOT NULL AUTO_INCREMENT ,    
 `filename` VARCHAR(255) ,     `content` VARCHAR(255) ,     PRIMARY KEY (`id`)  ); 
 
 
CREATE TABLE  `route`(     
`id` INT NOT NULL AUTO_INCREMENT ,     
`filename` VARCHAR(255) ,     `content` VARCHAR(255) ,     PRIMARY KEY (`id`)  );

CREATE TABLE  `vehicle`(     
`id` INT NOT NULL AUTO_INCREMENT ,     
`filename` VARCHAR(255) ,     `content` VARCHAR(255) ,     PRIMARY KEY (`id`)  );

CREATE TABLE  `stop`(     
`id` INT NOT NULL AUTO_INCREMENT ,     
`filename` VARCHAR(255) ,     `content` VARCHAR(255) ,     PRIMARY KEY (`id`)  );
CREATE TABLE  `zone`(     
`id` INT NOT NULL AUTO_INCREMENT ,     
`filename` VARCHAR(255) ,     `content` VARCHAR(255) ,     PRIMARY KEY (`id`)  );




package com.test;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;

public class MyTest {
public static void main(String[] args) {
try {
String url = "jdbc:mysql://localhost:3306/users";
String username = "root";
String password = "root"; 
Connection conn = null;
PreparedStatement stmt = null;

File studentFile=new File("D:/dbtest/student.txt");
    File routeFile=new File("D:/dbtest/route.txt");
    File stopFile=new File("D:/dbtest/stop.txt");
    File vehicleFile=new File("D:/dbtest/vehicle.txt");
    File zoneFile=new File("D:/dbtest/zone.txt");
    List<File> fileList=new ArrayList<File>();
    fileList.add(studentFile);
    fileList.add(routeFile);
    fileList.add(stopFile);
    fileList.add(vehicleFile);
    fileList.add(zoneFile);
    Class.forName("com.mysql.jdbc.Driver");
    conn = DriverManager.getConnection(url, username, password);  
    PreparedStatement pstm=null;
    for (File file : fileList) {
    String fileName=file.getName();
fileName = fileName.replace(".txt", "");
System.out.println("fileName..."+fileName);
FileReader fr = new FileReader(file);
BufferedReader  bufferedReader=new BufferedReader  (fr);
String content=bufferedReader.readLine();
String sql="insert into "+fileName+" (filename,content) values (? , ?)";
pstm =conn.prepareStatement(sql); 
pstm.setString(1, fileName);
pstm.setString(2, content); 
 
pstm.execute();
bufferedReader.close();
fr.close();

    }
} catch (Exception e) {
e.printStackTrace();
}
}
}



不知道能否满足？
[其他解释]
目测楼主应该在加拿大
[其他解释]
引用:
目测楼主应该在加拿大

LZ是在美国..
首先感谢这位大大这么耐心啊，不过我们老师要求的程序可以以下面的命令行执行的
java -classpath .;mysql-connector-java-5.1.18-bin.jar Populate db.properties student.txt vehicle.txt route.txt stop.txt zone.txt

您给出的这个配置文件那里肯定是不行的..那个读入txt文件那块是不是把相应的路径名称换成args[]就可以啊..等我再仔细研究下看看，还有就是您能给解释下这个命令里面 classpath是具体是怎么个意思吗？后面的.和;有什么特别的意思吗
[其他解释]

package com.test;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;

public class MyTest {
public static void main(String[] args) {
PreparedStatement pstm=null;
Connection conn = null;
try {
String url = "jdbc:mysql://localhost:3306/users";
String username = "root";
String password = "root"; 
File studentFile=new File("D:/dbtest/student.txt");
    File routeFile=new File("D:/dbtest/route.txt");
    File stopFile=new File("D:/dbtest/stop.txt");
    File vehicleFile=new File("D:/dbtest/vehicle.txt");
    File zoneFile=new File("D:/dbtest/zone.txt");
    List<File> fileList=new ArrayList<File>();
    fileList.add(studentFile);
    fileList.add(routeFile);
    fileList.add(stopFile);
    fileList.add(vehicleFile);
    fileList.add(zoneFile);
    Class.forName("com.mysql.jdbc.Driver");
    conn = DriverManager.getConnection(url, username, password);  
    
    for (File file : fileList) {
    String fileName=file.getName();
fileName = fileName.replace(".txt", "");
System.out.println("fileName..."+fileName);
FileReader fr = new FileReader(file);
BufferedReader  bufferedReader=new BufferedReader  (fr);
String content=bufferedReader.readLine();
String sql="insert into "+fileName+" (filename,content) values (? , ?)";
pstm =conn.prepareStatement(sql); 
pstm.setString(1, fileName);
pstm.setString(2, content);
pstm.execute();
bufferedReader.close();
fr.close();

    }
} catch (Exception e) {
e.printStackTrace();
}finally{
try {
pstm.close();
conn.close();
} catch (Exception e2) {
e2.printStackTrace();
}

} 
 
}
}



忘记关闭资源了
[其他解释]

目录结构如下：




import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

public class Populate{
public static void main(String[] args) {
PreparedStatement pstm=null;
Connection conn = null;
try {

File propertiesFile=new File(args[0]);
Properties prop = new Properties();
FileInputStream fis = new FileInputStream(propertiesFile);
prop.load(fis);
String username=prop.getProperty("username");
String password=prop.getProperty("password");
String url = prop.getProperty("url");
File studentFile=new File(args[1]);
    File vehicleFile=new File(args[2]);
File routeFile=new File(args[3]);
    File stopFile=new File(args[4]);
    File zoneFile=new File(args[5]);
    List<File> fileList=new ArrayList<File>();
    fileList.add(studentFile);
    fileList.add(routeFile);
    fileList.add(stopFile);
    fileList.add(vehicleFile);
    fileList.add(zoneFile);
    Class.forName("com.mysql.jdbc.Driver");
    conn = DriverManager.getConnection(url, username, password);  
    
    for (File file : fileList) {
    String fileName=file.getName();
fileName = fileName.replace(".txt", "");
System.out.println("fileName..."+fileName);
FileReader fr = new FileReader(file);
BufferedReader  bufferedReader=new BufferedReader  (fr);
String content=bufferedReader.readLine();
String sql="insert into "+fileName+" (filename,content) values (? , ?)";
pstm =conn.prepareStatement(sql); 
pstm.setString(1, fileName);
pstm.setString(2, content);
pstm.execute();
bufferedReader.close();
fr.close();

    }
} catch (Exception e) {
e.printStackTrace();
}finally{
try {
pstm.close();
conn.close();
} catch (Exception e2) {
e2.printStackTrace();
}

}
}
}


在cmd里面执行如下命令
javac Populate.java
java -classpath .;mysql-connector-java-5.1.18-bin.jar Populate db.properties student.txt vehicle.txt route.txt stop.txt zone.txt

[其他解释]
java -classpath .;mysql-connector-java-5.1.18-bin.jar
把mysql的jar放到classpath环境变量里面吧
也就是项目中的lib目录，你大概这样理解就可以了
[其他解释]


引用:
我图片中的mysql的jar版本和你的jar的版本不同，我那个命令是改成你的那个版本了


谢谢大大啊~真是好银！！虽然你的代码和我需要的不是很一样，不过帮助我理解了一些问题
但是还是有几个地方不太懂啊
36：： Class.forName("com.mysql.jdbc.Driver");
这句话我是不太明白，不过您看我#17贴的代码里面没有用到这个命令，而且我在您的代码里面删掉这个语句，也是能够正常运行的...能解释下为什么吗？

还有就是您写的那个将5个文件的内容导入数据库的方法是很方便啦，不过我们给的那5个文件都是不一样的，里面的属性是不一样的...有的有3个有的有5个的就像比如

我们作业要做的是空间数据库..所以数据都是些经纬度的东东，像route的话就有好几个
之前我的实现方式是
 while((line = br.readLine())!= null){  
                    info = line.split(",");  
                    sql = "insert into cc(Student,Co,La)values('"+ info[0] +"','"+info[1]+"','"+info[2]+"')";  
                    stmt = conn.prepareStatement(sql);
                    stmt.executeUpdate(); 
 }

可是我发现这样也只是针对一个文件的...下一个文件属性不一样了，又得重新写一个这样的代码
[其他解释]
我图片中的mysql的jar版本和你的jar的版本不同，我那个命令是改成你的那个版本了
[其他解释]
表不一样，txt数据也不一样
那这样的话 你要根据每个txt 做不同的sql语句哦。每个txt对应一条sql吧
那你就要每个File去读取，把每行存都存到相应的表里面的相应的字段里面

Class.forName("com.mysql.jdbc.Driver");是注册驱动。
#32
可是我发现这样也只是针对一个文件的...下一个文件属性不一样了，又得重新写一个这样的代码

关于这个问题。你可以把字段什么的设为一个参数传过去，根据文件名称的不同还传
[其他解释]
引用:
当然如果你的数据库不是mysql的话，就要改变驱动了，还有你的数据库名，以及账号，密码

Connection conn = DBUtils.getConn();
PreparedStatement pstmt = DBUtils.getPstmt();
这里是不是要把相应才 conn和sql作为参数放到getPstmt(conn,sql)?
[其他解释]
怎么这么快就沉了..自顶一下

[其他解释]
引用:
简单写了下 你自己看看 行不行，是不是你要的效果。。。

bufferedReader.readLine(）每一行读到的字符串的结尾有木有/0啊请问，要是有个结束符的话，我倒是想用个循环，在把后面的经纬度组成一个长字符串存起来..
[其他解释]
引用:
简单写了下 你自己看看 行不行，是不是你要的效果。。。

我研究了下，发现这5个文件用循环输入的话太麻烦了，还是一个一个来吧，我已经实现其中3个了，但是前面说的那个问题还是不懂...

[其他解释]
简单写了下 你自己看看 行不行，是不是你要的效果。。。
[其他解释]
引用:
简单写了下 你自己看看 行不行，是不是你要的效果。。。

感谢这位耐心的好大大啊！真是太感动了！！
现在我基本已经可以搞明白了，不过遇到一个新的头疼的问题，就是那5个数据文件里面有一个是route 有一个是zone， 因为是空间数据库的关系，所以那些长串数字要按照经度和纬度搭配输入到一个LINESTRING里面，就是像下面的数据
r1,11,34.031811,-118.290025,34.031839,-118.285539,34.0304,-118.283342
r2,6,34.021592,-118.290083,34.023989,-118.288633,34.022975,-118.287014,34.022292,-118.284772,34.021056,-118.286961,34.020275,-118.287928
r3,7,34.022292,-118.284772,34.022975,-118.287014,34.023989,-118.288633,34.027061,-118.289869,34.029575,-118.289417,34.028975,-118.286039,34.026828,-118.281994
r4,8,34.021056,-118.286961,34.022369,-118.281581,34.022292,-118.284772,34.022975,-118.287014,34.021056,-118.286961,34.020275,-118.287928,34.019303,-118.289136,34.019478,-118.286425


这个测试用的数据一共是4行，r1 r2 r3 r4，然后这个route的表示这个样子的
create table route ( 
RouteID  VARCHAR(20) PRIMARY KEY, 
Num int(20),
rlocation LineString NOT NULL, 
SPATIAL INDEX(rlocation) 
)ENGINE=MyISAM DEFAULT CHARSET=utf8;

拿r1做例子，就是说r1对应RouteID，11对应Num，剩下的数据按照两个一对的格式存入rlocation，
INSERT INTO Points (name, location) VALUES ( 'r1' ,'11' GeomFromText( ' LINESTRING(34.031811 -118.290025,34.031839 -118.285539,34.0304 -118.283342) ' ) )
就是说每一对经纬度之间用逗号隔开， 每一对经度和纬度之间用空格隔开，可是原始数据给的之前的间隔全是逗号...
[其他解释]
When a Driver class is loaded, it should create an instance of itself and register it with the DriverManager.
you are import java.sql.DriverManager;so,
This is the reason why you do not write "Class.forName("com.mysql.jdbc.Driver");",
I think.

对了 妹子 google LG nexus 4 美国炒到多少刀了？ 有现货没？
[其他解释]
我发现 我英文 真是费了，唉~ 其实你可以好好看看 poi 的
[其他解释]
bufferedReader.readLine(); 就是一行一行读取，读取到这一行的结束
你可以用个循环，在把后面的经纬度组成一个长字符串存起来..
后面的我就不写了 你自己写了
[其他解释]
引用:
bufferedReader.readLine(); 就是一行一行读取，读取到这一行的结束
你可以用个循环，在把后面的经纬度组成一个长字符串存起来..
后面的我就不写了 你自己写了

嗯嗯，这个我终于写出来啦！吼吼，之前问你的Class.forName("com.mysql.jdbc.Driver");这个问题，为什么我把这句话删掉也不影响程序运行呢？
[其他解释]
引用:
When a Driver class is loaded, it should create an instance of itself and register it with the DriverManager.
you are import java.sql.DriverManager;so,
This is the reason why you do no……
那就是说Class.forName("com.mysql.jdbc.Driver")没有必要吗？这个注册在我的程序总是报错，说没有声明神马的...但是在另一个就可以，问题是我觉得这俩程序写的差不多，那个可以的也没有特别声明神马
[其他解释]
看来 美国黄牛党 比 中国的黄牛还黑呀

问题的原因不一样 按照道理来说 你只要Implementor—river）的引用时 下面是源码，它是自动帮你注册的

package com.mysql.jdbc    
   
public class Driver extends NonRegisteringDriver implements java.sql.Driver {    
// ~ Static fields/initializers    
// --------------------------------------------- //    
 // Register ourselves with the DriverManager    
 //    
 static {    
    t ry {    
              java.sql.DriverManager.registerDriver(new Driver());    
          } catch (SQLException E) {     
 
              throw new RuntimeException("Can't register driver!");    
          }    
  }    
// ~ Constructors    
 // -----------------------    
/**   
  * Construct a new driver and register it with DriverManager   
  *    
  * @throws SQLException   
  *             if a database error occurs.   
  */   
 public Driver() throws SQLException {    
     // Required for Class.forName().newInstance()    
 }    
}


[其他解释]
引用:
海龟挺牛的


还没有“鬼”好不好。
[其他解释]
引用:
When a Driver class is loaded, it should create an instance of itself and register it with the DriverManager.
you are import java.sql.DriverManager;so,
This is the reason why you do no……

我没关注手机....不过刚刚ebay看了下，都是500左右呢...

读书人网 >J2SE开发

热点推荐

触屏版 | 电脑版

读书人网 m.reader8.net