package com.ssh.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public final class JDBCUtils {
private JDBCUtils(){}
private static String url="jdbc:mysql://localhost:3306/zinc";
private static String user="root";
private static String password="p";
static{
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
throw new ExceptionInInitializerError(e);
}
}
public static Connection getConnection() throws SQLException
{
return DriverManager.getConnection(url, user, password);
}
public static void free(ResultSet rs,Statement st,Connection conn)
{
try{
if(rs!=null)
rs.close();
}catch(SQLException e){
e.printStackTrace();
}finally{
try{
if(st!=null)
st.close();
}catch(SQLException e){
e.printStackTrace();
}finally{
try{
if(conn!=null)
conn.close();
}catch(SQLException e){
e.printStackTrace();
}
}
}
}
}
package com.ssh.util;
import java.sql.ResultSet;
import com.mysql.jdbc.Connection;
import com.mysql.jdbc.Statement;
public class WordCensorImport {
public static void main(String[] args) {
try {
WordCensorImport.JDBCUtilsTest();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
public static void JDBCUtilsTest() throws Exception
{
Connection conn=null;
Statement st=null;
ResultSet rs=null;
try{
conn=(Connection) JDBCUtils.getConnection();
String [] wordCensor = textUtil.parser("E://keywords.txt");
String sql="";
for(int i=0; i < wordCensor.length; i++){
//INSERT INTO wordcensor (keyword) values ("aa")
sql = "INSERT INTO wordcensor (keyword) values ('" + wordCensor[i] +"')";
System.out.println(sql);
st=(Statement) conn.createStatement();
st.execute(sql);
st=null;
rs=null;
}
// st=(Statement) conn.createStatement();
// rs=st.executeQuery("select * from test1");
// while(rs.next())
// {
// System.out.println(rs.getObject(1)+"/t"+rs.getObject(2));
// }
}finally{
JDBCUtils.free(rs, st, conn);
}
}
}