Xfire 实现.net 平台PDA数据交互
2009-02-27 20:34
399 查看
1、数据查询以xml文件格式的字符串进行数据交互，遍历结果集部分代码如下：
/**
* @param ResultSet rs输入的结果集
* @return String 返回XML串
* @exception SQLException
*/
Java代码
public String GetXML(ResultSet rs) throws SQLException, IOException {
final StringBuffer buffer = new StringBuffer(1024 * 4);
buffer.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"); // XML的头部信息
buffer.append("<RowSet>\n");
buffer.append("\t" + GetTableXML(rs, "Table") + "\n");
buffer.append("</RowSet>");
rs.close();
return buffer.toString();
}
/**
* @param ResultSet rs输入的结果集
* @return String 返回XML串
*/
Java代码
public String GetTableXML( ResultSet rs,String TableName) throws SQLException, IOException {
String xml="";
final StringBuffer buffer = new StringBuffer(1024 * 4);
if (rs!=null)
{
ResultSetMetaData rsmd = rs.getMetaData(); //得到结果集的定义结构
int colCount = rsmd.getColumnCount(); // 得到列的总数
for (int id = 0; rs.next(); id++) {
buffer.append("\t<" + TableName + ">\n");
for (int i = 1; i <= colCount; i++) {
int type =rsmd.getColumnType(i); // 获取字段类型
buffer.append("\t\t<" + rsmd.getColumnName(i) + ">");
buffer.append(getValue(rs, i, type));
buffer.append("</" + rsmd.getColumnName(i) + ">\n");
}
buffer.append("\t</" + TableName + ">\n");
xml=buffer.toString();
}
rs.close();
}
else if (rs == null || !rs.next()) {
System.out.println("结果集为空");
}
return xml;
}
/**
* This method gets the value of the specified column
* 通用的读取结果集某一列的值并转化为String表达
* @param ResultSet rs 输入的纪录集
* @param int colNum 第几列
* @param int type 数据类型
*/
//重点
Java代码
private String getValue( ResultSet rs, int colNum, int type) throws SQLException, IOException {
String xml="";
switch (type)
{
case Types.ARRAY:
case Types.BLOB:
case Types.CLOB:
case Types.DISTINCT:
case Types.LONGVARBINARY:
case Types.VARBINARY:
case Types.BINARY:
case Types.REF:
case Types.STRUCT:
BufferedInputStream is = null;
Blob blob=(Blob) rs.getObject(colNum);
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int offset = 0;
int read = 0;
int len = bytes.length;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
BASE64Encoder enc=new BASE64Encoder();
xml=enc.encode(bytes);
is.close();
is = null;
break;
default: {
Object value = rs.getObject(colNum);
if (rs.wasNull() || (value == null)) {
return ("");
} else {
xml=value.toString();
}
}
}
return xml;
}
2、web service 接口类
Java代码
public class OperateImp implements Operate {
// 执行增删改操作
public int ExecuteNonQuery(String executeNoQuery) {
int i = 0;
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
Statement stmtUpdate = con.createStatement();
i = stmtUpdate.executeUpdate(executeNoQuery);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return i;
}
// 查询某结果集首条记录的首字段
public Object ExecuteScalar(String executeScalar) {
Object scalar = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeScalar);
while (rs.next()) {
scalar = rs.getString(1);
}
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return scalar;
}
public String ExecuteDataset(String executeDataset) {
String result = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeDataset);
XMLWriter xml = new XMLWriter();
result = xml.GetXML(rs);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
// 图片入库
public boolean insertXQPIC(String insertXQPIC,byte [] bytes,String pictureId) {
boolean boo=false;
OutputStream outStream=null;
try
{
DataBase db = new DataBase();
Connection con = db.setConnection();
BlobToString bts=new BlobToString();
con.setAutoCommit(false); // 事物由程序员操作
Statement st = con.createStatement();
//插入一个空对象empty_blob()
st.executeQuery(insertXQPIC);
//通过pictureId查询刚刚传入的数据
ResultSet rs = st.executeQuery("select pic from ZKR_XQPIC where picid='"+pictureId+"' for update");
if (rs.next()) {
BLOB blob = (BLOB) rs.getBlob("pic");
outStream = blob.getBinaryOutputStream();
//data是传入的byte数组，定义：byte[] data
outStream.write(bytes, 0, bytes.length);
boo=true;
}
outStream.flush();
outStream.close();
con.commit();
con.close();
}
catch(Exception e)
{
e.printStackTrace();
}
return boo;
}
private byte[] blobToBytes(Blob blob) {
BufferedInputStream is = null;
try {
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int len = bytes.length;
int offset = 0;
int read = 0;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
return bytes;
} catch (Exception e) {
return null;
} finally {
try {
is.close();
is = null;
} catch (IOException e) {
return null;
}
}
}
}
3、客户端调用
Java代码
public class ClientMain {
public static void main(String agp[]) {
Service serviceModel = new ObjectServiceFactory().create(Operate.class);
// Create a proxy for the deployed service
XFire xfire = XFireFactory.newInstance().getXFire();
XFireProxyFactory factory = new XFireProxyFactory(xfire);
String serviceUrl = "http://localhost:8080/PDA/services/OperateService";
Operate client = null;
try
{
client = (Operate) factory.create(serviceModel, serviceUrl);
}
catch (MalformedURLException e) {
}
int serviceResponse =0;
String rs=null;
String scalar=null;
try {
// //增删改操作
// String sql="insert into st_dayev_r values('2','2001-01-01 00:00:00','0','0','222')";
// String sql="insert into ZKR_XQPIC values('00004',empty_blob(),'20081026','','')";
// serviceResponse = client.ExecuteNonQuery(sql);
// System.out.println(serviceResponse);
//查询操作
// String sqlQuery="select * from ZKR_XQPIC where picid='00004' ";
// rs=client.ExecuteDataset(sqlQuery);
// System.out.println(rs);
// //查询单个字段
// String sqlscalar="select * from zkr_sfya where yaid='2009010402' ";
// scalar=(String) client.ExecuteScalar(sqlscalar);
// System.out.println(scalar);
//插入图片
String insertXQPIC="insert into ZKR_XQPIC (picid,pic,refid) values('012',empty_blob(),'20081026')";
byte []bytes=new byte[10];
String pictureId="012";
boolean boo=client.insertXQPIC(insertXQPIC, bytes,pictureId);
System.out.println(boo);
} catch (Exception e) {
System.out.println("出错了");
e.printStackTrace();
}
}
}
/**
* @param ResultSet rs输入的结果集
* @return String 返回XML串
* @exception SQLException
*/
Java代码
public String GetXML(ResultSet rs) throws SQLException, IOException {
final StringBuffer buffer = new StringBuffer(1024 * 4);
buffer.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"); // XML的头部信息
buffer.append("<RowSet>\n");
buffer.append("\t" + GetTableXML(rs, "Table") + "\n");
buffer.append("</RowSet>");
rs.close();
return buffer.toString();
}
public String GetXML(ResultSet rs) throws SQLException, IOException {
final StringBuffer buffer = new StringBuffer(1024 * 4);
buffer.append("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"); // XML的头部信息
buffer.append("<RowSet>\n");
buffer.append("\t" + GetTableXML(rs, "Table") + "\n");
buffer.append("</RowSet>");
rs.close();
return buffer.toString();
}/**
* @param ResultSet rs输入的结果集
* @return String 返回XML串
*/
Java代码
public String GetTableXML( ResultSet rs,String TableName) throws SQLException, IOException {
String xml="";
final StringBuffer buffer = new StringBuffer(1024 * 4);
if (rs!=null)
{
ResultSetMetaData rsmd = rs.getMetaData(); //得到结果集的定义结构
int colCount = rsmd.getColumnCount(); // 得到列的总数
for (int id = 0; rs.next(); id++) {
buffer.append("\t<" + TableName + ">\n");
for (int i = 1; i <= colCount; i++) {
int type =rsmd.getColumnType(i); // 获取字段类型
buffer.append("\t\t<" + rsmd.getColumnName(i) + ">");
buffer.append(getValue(rs, i, type));
buffer.append("</" + rsmd.getColumnName(i) + ">\n");
}
buffer.append("\t</" + TableName + ">\n");
xml=buffer.toString();
}
rs.close();
}
else if (rs == null || !rs.next()) {
System.out.println("结果集为空");
}
return xml;
}
public String GetTableXML( ResultSet rs,String TableName) throws SQLException, IOException {
String xml="";
final StringBuffer buffer = new StringBuffer(1024 * 4);
if (rs!=null)
{
ResultSetMetaData rsmd = rs.getMetaData(); //得到结果集的定义结构
int colCount = rsmd.getColumnCount(); // 得到列的总数
for (int id = 0; rs.next(); id++) {
buffer.append("\t<" + TableName + ">\n");
for (int i = 1; i <= colCount; i++) {
int type =rsmd.getColumnType(i); // 获取字段类型
buffer.append("\t\t<" + rsmd.getColumnName(i) + ">");
buffer.append(getValue(rs, i, type));
buffer.append("</" + rsmd.getColumnName(i) + ">\n");
}
buffer.append("\t</" + TableName + ">\n");
xml=buffer.toString();
}
rs.close();
}
else if (rs == null || !rs.next()) {
System.out.println("结果集为空");
}
return xml;
}/**
* This method gets the value of the specified column
* 通用的读取结果集某一列的值并转化为String表达
* @param ResultSet rs 输入的纪录集
* @param int colNum 第几列
* @param int type 数据类型
*/
//重点
Java代码
private String getValue( ResultSet rs, int colNum, int type) throws SQLException, IOException {
String xml="";
switch (type)
{
case Types.ARRAY:
case Types.BLOB:
case Types.CLOB:
case Types.DISTINCT:
case Types.LONGVARBINARY:
case Types.VARBINARY:
case Types.BINARY:
case Types.REF:
case Types.STRUCT:
BufferedInputStream is = null;
Blob blob=(Blob) rs.getObject(colNum);
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int offset = 0;
int read = 0;
int len = bytes.length;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
BASE64Encoder enc=new BASE64Encoder();
xml=enc.encode(bytes);
is.close();
is = null;
break;
default: {
Object value = rs.getObject(colNum);
if (rs.wasNull() || (value == null)) {
return ("");
} else {
xml=value.toString();
}
}
}
return xml;
}
private String getValue( ResultSet rs, int colNum, int type) throws SQLException, IOException {
String xml="";
switch (type)
{
case Types.ARRAY:
case Types.BLOB:
case Types.CLOB:
case Types.DISTINCT:
case Types.LONGVARBINARY:
case Types.VARBINARY:
case Types.BINARY:
case Types.REF:
case Types.STRUCT:
BufferedInputStream is = null;
Blob blob=(Blob) rs.getObject(colNum);
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int offset = 0;
int read = 0;
int len = bytes.length;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
BASE64Encoder enc=new BASE64Encoder();
xml=enc.encode(bytes);
is.close();
is = null;
break;
default: {
Object value = rs.getObject(colNum);
if (rs.wasNull() || (value == null)) {
return ("");
} else {
xml=value.toString();
}
}
}
return xml;
}2、web service 接口类
Java代码
public class OperateImp implements Operate {
// 执行增删改操作
public int ExecuteNonQuery(String executeNoQuery) {
int i = 0;
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
Statement stmtUpdate = con.createStatement();
i = stmtUpdate.executeUpdate(executeNoQuery);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return i;
}
// 查询某结果集首条记录的首字段
public Object ExecuteScalar(String executeScalar) {
Object scalar = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeScalar);
while (rs.next()) {
scalar = rs.getString(1);
}
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return scalar;
}
public String ExecuteDataset(String executeDataset) {
String result = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeDataset);
XMLWriter xml = new XMLWriter();
result = xml.GetXML(rs);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
// 图片入库
public boolean insertXQPIC(String insertXQPIC,byte [] bytes,String pictureId) {
boolean boo=false;
OutputStream outStream=null;
try
{
DataBase db = new DataBase();
Connection con = db.setConnection();
BlobToString bts=new BlobToString();
con.setAutoCommit(false); // 事物由程序员操作
Statement st = con.createStatement();
//插入一个空对象empty_blob()
st.executeQuery(insertXQPIC);
//通过pictureId查询刚刚传入的数据
ResultSet rs = st.executeQuery("select pic from ZKR_XQPIC where picid='"+pictureId+"' for update");
if (rs.next()) {
BLOB blob = (BLOB) rs.getBlob("pic");
outStream = blob.getBinaryOutputStream();
//data是传入的byte数组，定义：byte[] data
outStream.write(bytes, 0, bytes.length);
boo=true;
}
outStream.flush();
outStream.close();
con.commit();
con.close();
}
catch(Exception e)
{
e.printStackTrace();
}
return boo;
}
private byte[] blobToBytes(Blob blob) {
BufferedInputStream is = null;
try {
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int len = bytes.length;
int offset = 0;
int read = 0;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
return bytes;
} catch (Exception e) {
return null;
} finally {
try {
is.close();
is = null;
} catch (IOException e) {
return null;
}
}
}
}
public class OperateImp implements Operate {
// 执行增删改操作
public int ExecuteNonQuery(String executeNoQuery) {
int i = 0;
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
Statement stmtUpdate = con.createStatement();
i = stmtUpdate.executeUpdate(executeNoQuery);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return i;
}
// 查询某结果集首条记录的首字段
public Object ExecuteScalar(String executeScalar) {
Object scalar = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeScalar);
while (rs.next()) {
scalar = rs.getString(1);
}
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return scalar;
}
public String ExecuteDataset(String executeDataset) {
String result = "";
try {
DataBase db = new DataBase();
Connection con = db.setConnection();
Statement stmt = con.createStatement();
ResultSet rs = stmt.executeQuery(executeDataset);
XMLWriter xml = new XMLWriter();
result = xml.GetXML(rs);
db.cleanup();
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
// 图片入库
public boolean insertXQPIC(String insertXQPIC,byte [] bytes,String pictureId) {
boolean boo=false;
OutputStream outStream=null;
try
{
DataBase db = new DataBase();
Connection con = db.setConnection();
BlobToString bts=new BlobToString();
con.setAutoCommit(false); // 事物由程序员操作
Statement st = con.createStatement();
//插入一个空对象empty_blob()
st.executeQuery(insertXQPIC);
//通过pictureId查询刚刚传入的数据
ResultSet rs = st.executeQuery("select pic from ZKR_XQPIC where picid='"+pictureId+"' for update");
if (rs.next()) {
BLOB blob = (BLOB) rs.getBlob("pic");
outStream = blob.getBinaryOutputStream();
//data是传入的byte数组，定义：byte[] data
outStream.write(bytes, 0, bytes.length);
boo=true;
}
outStream.flush();
outStream.close();
con.commit();
con.close();
}
catch(Exception e)
{
e.printStackTrace();
}
return boo;
}
private byte[] blobToBytes(Blob blob) {
BufferedInputStream is = null;
try {
is = new BufferedInputStream(blob.getBinaryStream());
byte[] bytes = new byte[(int) blob.length()];
int len = bytes.length;
int offset = 0;
int read = 0;
while (offset < len&& (read = is.read(bytes, offset, len - offset)) >= 0) {
offset += read;
}
return bytes;
} catch (Exception e) {
return null;
} finally {
try {
is.close();
is = null;
} catch (IOException e) {
return null;
}
}
}
}3、客户端调用
Java代码
public class ClientMain {
public static void main(String agp[]) {
Service serviceModel = new ObjectServiceFactory().create(Operate.class);
// Create a proxy for the deployed service
XFire xfire = XFireFactory.newInstance().getXFire();
XFireProxyFactory factory = new XFireProxyFactory(xfire);
String serviceUrl = "http://localhost:8080/PDA/services/OperateService";
Operate client = null;
try
{
client = (Operate) factory.create(serviceModel, serviceUrl);
}
catch (MalformedURLException e) {
}
int serviceResponse =0;
String rs=null;
String scalar=null;
try {
// //增删改操作
// String sql="insert into st_dayev_r values('2','2001-01-01 00:00:00','0','0','222')";
// String sql="insert into ZKR_XQPIC values('00004',empty_blob(),'20081026','','')";
// serviceResponse = client.ExecuteNonQuery(sql);
// System.out.println(serviceResponse);
//查询操作
// String sqlQuery="select * from ZKR_XQPIC where picid='00004' ";
// rs=client.ExecuteDataset(sqlQuery);
// System.out.println(rs);
// //查询单个字段
// String sqlscalar="select * from zkr_sfya where yaid='2009010402' ";
// scalar=(String) client.ExecuteScalar(sqlscalar);
// System.out.println(scalar);
//插入图片
String insertXQPIC="insert into ZKR_XQPIC (picid,pic,refid) values('012',empty_blob(),'20081026')";
byte []bytes=new byte[10];
String pictureId="012";
boolean boo=client.insertXQPIC(insertXQPIC, bytes,pictureId);
System.out.println(boo);
} catch (Exception e) {
System.out.println("出错了");
e.printStackTrace();
}
}
}
public class ClientMain {
public static void main(String agp[]) {
Service serviceModel = new ObjectServiceFactory().create(Operate.class);
// Create a proxy for the deployed service
XFire xfire = XFireFactory.newInstance().getXFire();
XFireProxyFactory factory = new XFireProxyFactory(xfire);
String serviceUrl = "http://localhost:8080/PDA/services/OperateService";
Operate client = null;
try
{
client = (Operate) factory.create(serviceModel, serviceUrl);
}
catch (MalformedURLException e) {
}
int serviceResponse =0;
String rs=null;
String scalar=null;
try {
// //增删改操作
// String sql="insert into st_dayev_r values('2','2001-01-01 00:00:00','0','0','222')";
// String sql="insert into ZKR_XQPIC values('00004',empty_blob(),'20081026','','')";
// serviceResponse = client.ExecuteNonQuery(sql);
// System.out.println(serviceResponse);
//查询操作
// String sqlQuery="select * from ZKR_XQPIC where picid='00004' ";
// rs=client.ExecuteDataset(sqlQuery);
// System.out.println(rs);
// //查询单个字段
// String sqlscalar="select * from zkr_sfya where yaid='2009010402' ";
// scalar=(String) client.ExecuteScalar(sqlscalar);
// System.out.println(scalar);
//插入图片
String insertXQPIC="insert into ZKR_XQPIC (picid,pic,refid) values('012',empty_blob(),'20081026')";
byte []bytes=new byte[10];
String pictureId="012";
boolean boo=client.insertXQPIC(insertXQPIC, bytes,pictureId);
System.out.println(boo);
} catch (Exception e) {
System.out.println("出错了");
e.printStackTrace();
}
}
}
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- Xfire 实现.net 平台PDA数据交互
- 利用OFFICE 2003 OWC 绘图控件在.NET平台下实现数据图表的绘制
- Android平台实现与Apache Tomcat服务器数据交互(MySql数据库)
- (转载)利用HttpWebRequest通过POST Json数据在.net后台实现不同平台间的数据传输
- 利用HttpWebRequest通过POST Json数据在.net后台实现不同平台间的数据传输
- 利用Ajax实现前端与.net后端实现数据交互
- .net网站与Winform窗体的数据交互(JS调用Winform后台方法实现)
- Android平台实现与Apache Tomcat服务器数据交互(MySql数据库)
- 【VUE】.NET实现Tree组件双向绑定数据（3）-资源分配
- C#实现Winform间的数据交互的三种方法
- .NET平台下IIS7.5+无后缀名伪静态实现办法
- php +ajax +sql 实现数据交互
- 基于.NET平台的分层架构实战（五）——接口的设计与实现
- 多年一直想完善的自由行政审批流程组件【2002年PHP,2008年.NET,2010年完善数据设计、代码实现】
- 多年一直想完善的自由行政审批流程组件【2002年PHP,2008年.NET,2010年完善数据设计、代码实现】
- 【Android游戏开发之五】游戏注册界面Demo-实现两个Activity之间的切换与数据交互！
- jsonp实现应用的跨域请求进行数据交互
- 使用FusionChart实现数据库的动态数据交互
- .net中Windows窗体间的数据交互
- 通过java代码调取C#应用程序并实现数据交互