利用SAX解析读取XML文件

王朝other·作者佚名  2006-11-24
窄屏简体版  字體: |||超大  

这是我的第一个BLOG,今天在看《J2EE应用开发详解》一书,书中讲到XML编程,于是就按照书中的步骤自己测试了起来,可是怎么测试都不成功,后来自己查看了一遍源码,发现在读取XML文件的位置时有误,于是进行了更改,还真行了,心中涌出一中成就感,现将源码贴出来与给位分享:

使用XML文件连接MYSQL数据库,database.conf.xml文件如下:

<database-conf>

<datasource>

<driver>com.mysql.jdbc.Driver</driver>

<url>jdbc:mysql://127.0.0.1:3306/j2ee14</url>

<user>bn</user>

<password>bn</password>

</datasource>

</database-conf>

新建一个Handler,用来解析该XML配置(ConfigParser.java) :

package com.j2ee14.ch4;

import org.xml.sax.Attributes;

import org.xml.sax.helpers.DefaultHandler;

import org.xml.sax.SAXException;

import java.util.Properties;

/**

*ConfigParser扩展了DefaultHandler,它用于获得数据库的连接属性

*/

public class ConfigParser extends DefaultHandler

{

//定义一个Properties 用来存放属性值

private Properties props;

private String currentName;

private StringBuffer currentValue =new StringBuffer();

//构建器初始化props

public ConfigParser()

{

this.props=new Properties();

}

public Properties getProps()

{

return this.props;

}

//定义开始解析元素的方法. 这里是将<xxx>中的名称xxx提取出来

public void startElement(String uri,String localName,String qName,Attributes attributes)throws SAXException

{

currentValue.delete(0,currentValue.length());

this.currentName=qName;

}

//这里是将<xxx></xxx>之间的值加入到currentValue

public void characters(char[] ch, int start, int length) throws SAXException {

currentValue.append(ch, start, length);

}

/**

*把XML配置文件的中相关的属性保存到Properties对象中

*/

public void endElement(String uri,String localName,String qName)throws SAXException

{

props.put(qName.toLowerCase(),currentValue.toString().trim());

}

}

用来解析XML的类,其他程序通过这个类来获得数据库的连接属性(ParseDatabaseConfig

.java):

package com.j2ee14.ch4;

import java.util.Properties;

import javax.xml.parsers.SAXParser;

import javax.xml.parsers.SAXParserFactory;

/**

*其它程序通过ParseDatabaseConfig来获得数据库的配置信息,

*这样使得类之间的耦合松散

*/

public class ParseDatabaseConfig

{

//定义一个Properties 用来存放属性值

private Properties props;

public Properties getProps()

{

return this.props;

}

/**

*解析XML配置文件,把属性保存起来

*/

public void parse(String filename)throws Exception

{

//将我们的解析器对象化

ConfigParser handler=new ConfigParser();

//获取SAX工厂对象

SAXParserFactory factory=SAXParserFactory.newInstance();

factory.setNamespaceAware(false);

factory.setValidating(false);

//获取SAX解析

SAXParser parser=factory.newSAXParser();

try

{

//将解析器和解析对象xml联系起来,开始解析

parser.parse(filename,handler);

//获取解析成功后的属性

props=handler.getProps();

}

finally

{

factory=null;

parser=null;

handler=null;

}

}

}

最后是一个数据库应用(MyDatabaseApplication

.java):

package com.j2ee14.ch4;

import java.util.Properties;

import java.sql.*;

/**

*MyDatabaseApplication是一个示例应用,它通过ParseDatabaseConfig

*来获得数据库的连接属性以连接数据库

*/

public class MyDatabaseApplication

{

private Connection con;

Properties dbProps;

/**

*构造方法,获得数据库的连接属性

*/

public MyDatabaseApplication()throws Exception

{

ParseDatabaseConfig databaseConfig=new ParseDatabaseConfig();

databaseConfig.parse("database.conf.xml");

this.dbProps=databaseConfig.getProps();

}

public Connection getConnection()throws java.sql.SQLException

{

try

{

Class.forName(dbProps.getProperty("driver"));

}

catch(java.lang.ClassNotFoundException e)

{

System.err.println("Not Found Driver:"+dbProps.getProperty("driver"));

}

//使用配置的属性创建一个连接。

return java.sql.DriverManager.getConnection(

dbProps.getProperty("url"),

dbProps.getProperty("user"),

dbProps.getProperty("password"));

}

/**

*测试方法

*/

public void doBusiness()

{

try

{

con=getConnection();

Statement stmt=con.createStatement();

System.out.println("创建一个表...");

stmt.execute("create table testconfig(id int not null,name varchar(20),constraint pk_testconfig primary key(id))");

System.out.println("在表中添加数据...");

stmt.execute("insert into testconfig values('001','hellking')");

ResultSet rst=stmt.executeQuery("select * from testconfig");

System.out.println("读取表中的数据...");

while(rst.next())

{

System.out.println("id:"+rst.getInt("id"));

System.out.println("name:"+rst.getString("name"));

}

rst.close();

stmt.execute("drop table testconfig");

con.close();

}

catch(java.sql.SQLException se)

{

System.err.println("连接数据库或者操作发生错误");

se.printStackTrace(System.err);

}

finally

{

try

{

con.close();

}

catch(Exception e){}

}

}

public static void main(String[] args)

{

System.out.println("使用XML作为数据库的配置。\n");

try

{

MyDatabaseApplication app=new MyDatabaseApplication();

app.doBusiness();

}

catch(Exception e)

{

System.err.println("发生异常");

}

}

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航