android通过jdbc远程连接SQL Server 并实现增删改查源码 jtds 1.3.1

package com.androidmysqltest;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;

import android.app.Activity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;

import com.androidmysqltest1.R;

public class Androidsql extends Activity
{
private Button m_Button ;
private Connection m_con= null;
@Override
public void onCreate(Bundle savedInstanceState)
{
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
m_Button = (Button)findViewById(R.id.button1);
m_Button.setOnClickListener(new OnClickListener()
{

@Override
public void onClick(View arg0)
{
try {

insert("name","pwd","super");   //上传调用
//delete(8);                        //删除调用
//update("ca","ca",1);            //修改调用
} catch (Exception e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}) ;
}
//添加
public void insert(String a,String b,String c) throws Exception
{
String sql = "INSERT INTO tb_User(UserName,UserPwd,UserRight) VALUES(?,?,?)" ;
PreparedStatement pstmt = null ;
Class.forName("net.sourceforge.jtds.jdbc.Driver");    //加载MYSQL JDBC驱动程序
Log.d("加载驱动", "成功");
//   m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "175.102.4.147" + ":1433/" + "数据名" ,"用户名", "密码");
m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "Sql1001.webweb.com" + ":1433/" + "DB_99D706_ZXSQ" ,"DB_99D706_ZXSQ_admin", "12345678");
if(m_con!=null)
Log.d("sqlserver", "数据库连接成功");
try {
pstmt = m_con.prepareStatement(sql) ;
pstmt.setString(1,a);
pstmt.setString(2,b);
pstmt.setString(3,c);
pstmt.executeUpdate();
pstmt.close() ;
} catch (Exception e)
{
// System.out.println(e) ;
throw new Exception("操作中出现错误！！！") ;
} finally
{
m_con.close() ;
}
}
// 删除操作
public void delete(int id) throws Exception {
String sql = "DELETE FROM tb_InStore WHERE ISID=?" ;
PreparedStatement pstmt = null ;
Class.forName("net.sourceforge.jtds.jdbc.Driver");    //加载MYSQL JDBC驱动程序
Log.d("加载驱动", "成功");
//   m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "175.102.4.147" + ":1433/" + "数据名" ,"用户名", "密码");
m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "Sql1001.webweb.com" + ":1433/" + "DB_99D706_ZXSQ" ,"DB_99D706_ZXSQ_admin", "12345678");
try {
pstmt = m_con.prepareStatement(sql) ;
pstmt.setInt(1,id) ;
pstmt.executeUpdate() ;
pstmt.close() ;
} catch (Exception e) {
throw new Exception("操作中出现错误！！！") ;
} finally {
m_con.close() ;
}
}
//修改
public void update(String a,String b,int d) throws Exception {
String sql = "UPDATE tb_User SET UserName=?,UserPwd=? WHERE UserID=?" ;
PreparedStatement pstmt = null ;
Class.forName("net.sourceforge.jtds.jdbc.Driver");    //加载MYSQL JDBC驱动程序
Log.d("加载驱动", "成功");
//   m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "175.102.4.147" + ":1433/" + "数据名" ,"用户名", "密码");
m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "Sql1001.webweb.com" + ":1433/" + "DB_99D706_ZXSQ" ,"DB_99D706_ZXSQ_admin", "12345678");
try {
pstmt = m_con.prepareStatement(sql) ;
pstmt.setString(1,a) ;
pstmt.setString(2,b) ;
pstmt.setInt(3,d) ;
pstmt.executeUpdate();
pstmt.close() ;
} catch (Exception e) {
throw new Exception("操作中出现错误！！！") ;
} finally {
m_con.close() ;
}
}
}

//查询
public String select(String a) throws Exception
{
String data="";
String sql = "SELECT sqdata FROM sq WHERE phoneid=?" ;
PreparedStatement pstmt = null ;
Class.forName("net.sourceforge.jtds.jdbc.Driver");    //加载sql server JDBC驱动程序
Log.d("sqlserver", "加载驱动成功");
//   m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "175.102.4.147" + ":1433/" + "数据名" ,"用户名", "密码");
m_con =(Connection) DriverManager.getConnection("jdbc:jtds:sqlserver://"+ "Sql1001.webweb.com" + ":1433/" + "DB_99D706_ZXSQ" ,"DB_99D706_ZXSQ_admin", "12345678");
if(m_con!=null)
Log.d("sqlserver", "数据库连接成功");
try {
pstmt = m_con.prepareStatement(sql) ;
pstmt.setString(1,a);
ResultSet rs=pstmt.executeQuery();
while(rs.next()){
data=rs.getString("sqdata");
}
pstmt.close() ;
} catch (Exception e)
{
//System.out.println(e) ;
throw new Exception("操作中出现错误！！！"+e) ;
} finally
{
m_con.close() ;
}
return data;
}