1、開發(fā)中遇到需要android端直接鏈接服務(wù)端sqlserver數(shù)據(jù)庫，并向sqlserver數(shù)據(jù)庫插入數(shù)據(jù)的場(chǎng)景。
2、鏈接到sqlserver數(shù)據(jù)庫，需要用到 jtds 工具包，我使用的是 jtds-1.3.1.jar。點(diǎn)擊百度網(wǎng)盤下載，密碼： fma7
3、下面就是直接鏈接sqlserver數(shù)據(jù)庫的代碼：
package com.mtjsoft.www.myapplication.data;
import android.util.Log;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* @author mtj 2018-4-9 10:00:48
* Created by Administrator on 2018/4/9.
* android 鏈接sqlserver數(shù)據(jù)庫
*/
public class MtjServerDatabaseTools {
private static String user = "數(shù)據(jù)庫用戶名";
private static String password = "數(shù)據(jù)庫密碼";
private static String DatabaseName = "數(shù)據(jù)庫名稱";
private static String IP = "數(shù)據(jù)庫所在的IP地址";
/**
* 連接字符串
*/
private static String connectDB = "jdbc:jtds:sqlserver://" + IP + ":1433/" + DatabaseName + ";useunicode=true;characterEncoding=UTF-8";
private static Connection conn = null;
private static Statement stmt = null;
/**
* 鏈接數(shù)據(jù)庫
*
* @return
*/
private static Connection getSQLConnection() {
Connection con = null;
try {
//加載驅(qū)動(dòng)換成這個(gè)
Class.forName("net.sourceforge.jtds.jdbc.Driver");
//連接數(shù)據(jù)庫對(duì)象
con = DriverManager.getConnection(connectDB, user,
password);
} catch (Exception e) {
}
return con;
}
/**
* 向服務(wù)器數(shù)據(jù)庫插入數(shù)據(jù)
* @tabName 要插入的表名
* @tabTopName 要插入的字段名字符串，例如（name,password,age）
* @values 與tabTopName 中 字段名一一對(duì)應(yīng)的值。一次插入多跳數(shù)據(jù)，可以用逗號(hào)隔開。例如（"張三"，"zhangsan","24"），（"李四"，"lisi","26"）
*/
public static int insertIntoData(String tabName, String tabTopName, String values) {
int i = 0;
try {
if (conn == null) {
conn = getSQLConnection();
stmt = conn.createStatement();
}
if (conn == null || stmt == null) {
return i;
}
String sql = "insert into " + tabName + tabTopName + " values " + values;
i = stmt.executeUpdate(sql);
} catch (SQLException e) {
e.printStackTrace();
Log.i("mtj", "同步數(shù)據(jù)庫表【" + tabName + "】失敗。");
}
return i;
}
/**
* 向服務(wù)器數(shù)據(jù)庫插入數(shù)據(jù)---并返回插入的主鍵id。
* 注意，此方法只能返回最新插入的一條數(shù)據(jù)的id。所以一次插入多跳數(shù)據(jù)時(shí)，只返回最后一個(gè)id。
*/
public static int insertIntoDataReturnId(String tabName, String tabTopName, String values, CallBackImp callBackImp) {
int id = 0;
try {
if (conn == null) {
conn = getSQLConnection();
stmt = conn.createStatement();
}
if (conn == null || stmt == null) {
return id;
}
String sql = "insert into " + tabName + tabTopName + " values " + values;
int i = stmt.executeUpdate(sql);
if (i > 0) {
ResultSet resultSet = stmt.executeQuery("select SCOPE_IDENTITY() as id;");
while (resultSet.next()) {
id = resultSet.getInt(1);
}
} else {
Log.i("mtj", "同步數(shù)據(jù)庫表【" + tabName + "】---->失敗。");
}
} catch (SQLException e) {
e.printStackTrace();
Log.i("mtj", "同步數(shù)據(jù)庫表【" + tabName + "】---->失敗。");
}
return id;
}
/**
* 關(guān)閉數(shù)據(jù)庫鏈接
*/
public static void closeConnect() {
if (stmt != null) {
try {
stmt.close();
stmt = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
if (conn != null) {
try {
conn.close();
conn = null;
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
android端連接sqlserver數(shù)據(jù)庫的方法就完成了，是不是很簡(jiǎn)單。
4、我們模仿一個(gè)場(chǎng)景演示一下。從本地?cái)?shù)據(jù)庫user表中取出所有數(shù)據(jù)，插入到sqlserver數(shù)據(jù)中。
從本地取出所有的user數(shù)據(jù)。轉(zhuǎn)換成上面 insertIntoData（）方法中所需要傳入的字符串。
假設(shè)本地user表和sqlserver中的user表的字段都是一致的。
SQLiteDatabase database = 獲取一個(gè)可讀的就行，這里就不說;
//數(shù)據(jù)庫表的所有字段名稱
StringBuilder tabTopName = new StringBuilder();
//存放數(shù)據(jù)庫表的數(shù)據(jù)
StringBuilder values = new StringBuilder();
//按照表名user，查詢出所有數(shù)據(jù)
Cursor cursor = database.query("user", null, "",
null, null, null, null);
if (cursor != null && cursor.getCount() > 0) {
int column = cursor.getColumnCount();
//拼接所有字段名，例如 （name,password,age）
tabTopName.append("(");
for (int k = 0; k < column; k++) {
String s = cursor.getColumnName(k);
//過濾掉本地?cái)?shù)據(jù)庫的id；因?yàn)閟qlserver有自增的id
if (!"id".equals(s)) {
tabTopName.append(s);
if (k != column - 1) {
tabTopName.append(",");
} else {
tabTopName.append(")");
}
}
}
//拼接所有數(shù)據(jù)
//例如（"張三"，"zhangsan","24"），（"李四"，"lisi","26"）
while (cursor.moveToNext()) {
values.append("(");
for (int k = 0; k < column; k++) {
String s = cursor.getColumnName(k);
//過濾掉本地?cái)?shù)據(jù)庫的id；因?yàn)閟qlserver有自增的id
if (!"id".equals(s)) {
String strValue = cursor.getString(k);
values.append("'");
values.append(strValue);
values.append("'");
if (k != column - 1) {
values.append(",");
} else {
values.append(")");
}
}
}
values.append(",");
}
values.deleteCharAt(values.length() - 1);
cursor.close();
database.close();
//組合成sql語句的格式。向服務(wù)器數(shù)據(jù)庫插入數(shù)據(jù)。
int count = MtjServerDatabaseTools.insertIntoData("user", tabTopName.toString(), values.toString());
if (count > 0) {
//同步數(shù)據(jù)庫表成功
} else {
//同步數(shù)據(jù)庫表失敗
}
}
OK。從android本地?cái)?shù)據(jù)讀取數(shù)據(jù)，并向服務(wù)器sqlserver數(shù)據(jù)庫插入數(shù)據(jù)的場(chǎng)景就完成了，是不是非常的簡(jiǎn)單呢。有空的話，可以自己試一試吧。歡迎批評(píng)指正！
————————————————
版權(quán)聲明：本文為CSDN博主「帥氣的鉛筆」的原創(chuàng)文章，遵循 CC 4.0 BY-SA 版權(quán)協(xié)議，轉(zhuǎn)載請(qǐng)附上原文出處鏈接及本聲明。
原文鏈接：https://blog.csdn.net/qq_28779083/article/details/79986357
