자바 는 데 이 터 를 Mysql 데이터베이스 에 조목조목 삽입 합 니 다.

3291 단어 자바
1.데이터베이스 에 표를 만 들 고 필드 형식 에 주의 하 십시오.기 록 된 데이터 형식 은 표 에 있 는 필드 의 데이터 필드 와 대응 해 야 합 니 다.
2.자바 연결 my sql 연결 클래스 쓰기
package Standardize;
import java.sql.*;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class Connect{
	Connection con;	
	public static final String url="jdbc:mysql://localhost:3306/lunwen";
	public static final String name="com.mysql.jdbc.Driver";
	public static final String user="root";
	public static final String password="1234";
	
	
	
	
	public Connection getConnection(){
		try{
			Class.forName(name);
			con=DriverManager.getConnection(url,user,password);
			
		}catch(Exception e){
			e.printStackTrace();
		}
		return con;
	}
	
	}
	


3.sql 구문:여러 개 를 기록 할 때 연결 을 닫 고'Too'가 나타 나 지 않도록 주의 하 십시오. many connections"물론 인터넷 에서 프로필 을 직접 수정 하 는 방법 이 있 습 니 다.그러나 저 는 커서 가 근본 적 이지 않다 고 생각 합 니 다.프로필 을 수정 하려 고 하지만 my.ini 를 찾 지 못 하면 댓 글 에서 질문 할 수 있 습 니 다.
package Standardize;

import java.io.*;
import java.sql.*;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.LinkedList;
import java.util.Queue;

import com.csvreader.CsvReader;

import Standardize.Connect;

public class fenlie {
	

	static Connection con;
	static PreparedStatement sql;
	static ResultSet ret1=null;
	Connect c=new Connect();
	
	
	
	public void importfile() {
		
		String filePath="src\\file\\train1.csv";
		
		try {
			CsvReader csvReader = new CsvReader(filePath);
			csvReader.readHeaders();
			Queue queue = new LinkedList();
		
			while (csvReader.readRecord()) {
				con=c.getConnection();
				
				
					 try{
						 sql=con.prepareStatement("insert into gps_data"+"("+"TRIP_ID,"+"TIMESTAMP,"+"Longitude,"+"Latitude,"
                                                 +"SN"+")values("+"?"+","+"?"+","+"?"+","+"?"+","+"?"+")");			
					        
					for (int x = 0; x < result.length; x++) {
						
							  sql.setString(1,csvReader.get(1));
							  sql.setInt(2,csvReader.get(2));
							  sql.setString(3,csvReader.get(3));
							  sql.setString(4,csvReader.get(4));
							  sql.setInt(5,csvReader.get(5));
							  sql.executeUpdate();
					        	}
						  
					}
					 catch(SQLException e){
				        	e.printStackTrace();
				        }
					 finally
						{
							if(sql!= null)
								try {
									sql.close();
								} catch (SQLException e) {
									// TODO Auto-generated catch block
									e.printStackTrace();
								} 		
							if(con!= null)
								try {
									con.close();
								} catch (SQLException e) {
									// TODO Auto-generated catch block
									e.printStackTrace();
								} 
						}
				
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}
 
  
 
  
 
 

좋은 웹페이지 즐겨찾기