记录代码
private static String url_unic = "?useUnicode=true&characterEncoding=utf8";
public static void main(String[] args) throws SQLException {
String path = "E:\\a\\tiku_Zong.txt";
String table = "tiku_zong";
String url = "jdbc:mysql://localhost:3306";
String dataBase = "wuxiandiantiku";
String user = "root";
String pwd = "root";
//将文件数据读入集合
List<String> list = writeToDat(path);
//创建数据库连接,并向数据库中插入数据
insertIntoTable(url, dataBase, user, pwd, table, list);
}
//插入数据
private static void insertIntoTable(String url, String dataBase, String user, String pwd, String table, List<String> list) throws SQLException {
Connection conn = getConnection(url, dataBase, user, pwd);
String sql = "insert into " + table + " values(?,?,?,?,?,?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
for (int i = 0; i < list.size(); ) {
pstmt.setString(1, list.get(i));
pstmt.setString(2, list.get(i + 1));
pstmt.setString(3, list.get(i + 2));
pstmt.setString(4, list.get(i + 3));
pstmt.setString(5, list.get(i + 4));
pstmt.setString(6, list.get(i + 5));
pstmt.executeUpdate();
i += 8;
}
System.out.println("insert success!");
pstmt.close();
conn.close();
}
//读取文本文件
public static List<String> writeToDat(String path) {
File file = new File(path);
List<String> list = new ArrayList<String>();
try {
InputStreamReader isr = new InputStreamReader(new FileInputStream(file), "utf8");
BufferedReader bw = new BufferedReader(isr);
String line = null;
while ((line = bw.readLine()) != null) {
list.add(line);
}
bw.close();
isr.close();
} catch (Exception e) {
e.printStackTrace();
}
return list;
}
//连接数据库
public static Connection getConnection(String url, String dataBase, String user, String pwd) {
Connection conn = null;
try {
Class.forName("com.mysql.jdbc.Driver");
String url_total = url + "/" + dataBase + url_unic;
conn = DriverManager.getConnection(url_total, user, pwd);
System.out.println("connection success!");
} catch (Exception e) {
System.out.println("connection fail!");
e.printStackTrace();
}
return conn;
}
//关闭数据库连接
public static void closeCon(Connection con) {
if (con != null) {
try {
con.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
txt文件格式如下
导入数据库样式如下
数据表最左侧新加了一列作为查询id,之后写后端代码获取题目和答案到页面上