java读取mysql写入xml文件_xml文件怎么读取到数据库

xml文件读取到数据库

第一步&＃xff0c;导包

c3p0&＃xff0c;dom4j&＃xff0c;jaxen&＃xff0c;MySQL-connector

第二步 xml文件&＃xff0c;config文件

第三步 javabean

第四步 c3p0的工具类

第五步 读取xml文件SAXReader中的xpath的方式

首先需要map集合添加别名&＃xff0c;遍历读取到的文件&＃xff0c;

给了list

第六步&＃xff0c;list给了c3p0的连接数据库的类

第一步&＃xff0c;导包

c3p0&＃xff0c;dom4j&＃xff0c;jaxen&＃xff0c;MySQL-connector

第二步 xml文件&＃xff0c;config文件

xml文件&＃xff0c;config文件根据需求具体实现

Xsd的约束

xmlns&＃61;"http://www.w3.org/2001/XMLSchema"

targetNamespace&＃61;"xiaoge"

elementFormDefault&＃61;"qualified">

第三步 javabean

根据需求在具体做

第四步 c3p0的工具类

package com.itheima.util;import java.sql.Connection;

import java.sql.ResultSet;

import java.sql.SQLException;

import java.sql.Statement;

import com.mchange.v2.c3p0.ComboPooledDataSource;

public class C3P0Util {

private static final ComboPooledDataSource DATASOURCE &＃61; new ComboPooledDataSource();

public static Connection getConn(){

try {

return DATASOURCE.getConnection();

} catch (SQLException e) {

e.printStackTrace();

}

return null;

}

public static void release(ResultSet rs, Statement stmt, Connection conn){

if (rs !&＃61; null) {

try {

rs.close();

} catch (SQLException e) {

e.printStackTrace();

}

rs &＃61; null;

}

if (stmt !&＃61; null) {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

stmt &＃61; null;

}

if (conn !&＃61; null) {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

conn &＃61; null;

}

}

}

第五步 读取xml文件SAXReader中的xpath的方式

首先需要map集合添加别名&＃xff0c;遍历读取到的文件&＃xff0c;

给了list

package com.itwjx.xml;import java.sql.Connection;

import java.sql.PreparedStatement;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.dom4j.Document;

import org.dom4j.DocumentException;

import org.dom4j.Element;

import org.dom4j.io.SAXReader;

import org.junit.Test;

import com.itwjx.entity.XMLDomain;

import com.itwjx.util.C3P0Util;/**

* 数据库名称 demo

* 表名userDomain

* 字段&＃xff1a; id int

* name varchar

* birthday date

* hobby char

* &＃64;author WBH

*

*/

public class WrokXmlAns {

&＃64;Test

public void readXMLtoDB(){

try {

//读取XML文件数据

List domains &＃61; readXML("src/aaa.xml");

//将数据保存到数据库

saveXMLDateToDB(domains);

} catch (Exception e) {

e.printStackTrace();

}

}

private List readXML(String path) throws DocumentException, ParseException {

SAXReader read &＃61; new SAXReader();

Document document &＃61; read.read(path);

Map map &＃61; new HashMap();

map.put("wbh", "xiaofan");

read.getDocumentFactory().setXPathNamespaceURIs(map);

List nodes &＃61; document.selectNodes("//wbh:member");

List domains &＃61; new ArrayList();

for (Element element : nodes) {

String id &＃61; element.attributeValue("no");

String name &＃61; element.element("name").getText();

String birthday &＃61; element.element("birthday").getText();

String hobby &＃61; element.element("hobby").getText();

SimpleDateFormat df &＃61; new SimpleDateFormat("yyyy-MM-dd");

Date date &＃61; df.parse(birthday);

XMLDomain domian &＃61; new XMLDomain(

Integer.parseInt(id), name,date, hobby);

domains.add(domian);

}

return domains;

}

private void saveXMLDateToDB(List domains) {

//

Connection conn &＃61; null;

PreparedStatement ps &＃61; null;

try {

conn &＃61; C3P0Util.getConn();

ps &＃61; conn.prepareStatement("insert into userDomain values(?,?,?,?)");

for (XMLDomain user : domains) {

ps.setInt(1, user.getId());

ps.setString(2, user.getName());

ps.setDate(3, new java.sql.Date(user.getBirthday().getTime()));

ps.setString(4, user.getHobby());

ps.addBatch();

}

ps.executeBatch();

} catch (Exception e) {

e.printStackTrace();

} finally {

C3P0Util.release(null, ps, conn);

}

}

}

第六步&＃xff0c;list给了c3p0的连接数据库的类private void saveXMLDateToDB(List domains) {

//

Connection conn &＃61; null;

PreparedStatement ps &＃61; null;

try {

conn &＃61; C3P0Util.getConn();

ps &＃61; conn.prepareStatement("insert into userDomain values(?,?,?,?)");

for (XMLDomain user : domains) {

ps.setInt(1, user.getId());

ps.setString(2, user.getName());

ps.setDate(3, new java.sql.Date(user.getBirthday().getTime()));

ps.setString(4, user.getHobby());

ps.addBatch();

}

ps.executeBatch();

} catch (Exception e) {

e.printStackTrace();

} finally {

C3P0Util.release(null, ps, conn);

}

}