- 作業系統環境
Microsoft Window 7(64 bit)
- AppServ (Tomcat + MySQL + phpMyAdmin) 軟體 (包含下載連結網址)
AppServ
- Web Service開發軟體(包含下載連結網址)
Apache Axis2 Release 1.6.2 (Binary Distribution zip)
Apache Tomcat 7.0.54 - 32bit
Eclipse IDE for java EE Developers - 32bit
- Android開發軟體
Eclipse ADT - 64bit實作說明
- 本專案有以下兩種功能
1. 透過Web Service讀取MySQL資料庫的資料
- Android Client發生請求時,Web Service讀取MySQL資料庫的資料,並使用雲端運算功能(轉成byte array資料結構),並將資料回傳前端顯示在Android Client UI
2. 透過Web Service寫入資料到MySQL資料庫
實作步驟
- Android Client UI有三個輸入方框(EditText),並針對這三個輸入方框輸入數值,這三個數值會透過SOAP協議方式傳輸到雲端,透過雲端運算寫入MySQL
1. 建立MySQL資料庫MySQL資料庫設計實作
2. 建立Web Service with java
3. 建立Android Client,並整合Web Service與MySQL
1. 啟動 appserv-win32-2.5.10.exe ,並以系統管理員身分執行
2. 建置MySQL環境-part1
3. 建置MySQL環境-part2
4. 建置MySQL環境-part3 (選擇軟體安裝路徑)
5. 建置MySQL環境-part4
6. 建置MySQL環境-part5
7. 建置MySQL環境-part6(帳號密碼為root)
8. 建置MySQL環境-part7
9. 建置MySQL環境-part8(開啟Browser輸入http://localhost:8088/phpMyAdmin/網址,帳密為root)
11. 建立student表格(下列為SQL語法)
CREATE TABLE student (
id INT NOT NULL AUTO_INCREMENT PRIMARY KEY ,
student_id INT NOT NULL ,
student_name TEXT NOT NULL ,
score DOUBLE NOT NULL
) ENGINE = MYISAM ;
12. 針對表格新增一筆資料(下列為SQL語法)
insert into student(student_id,student_name,score) values(1,'Annie',60);
實作建立Web Service with java
1. 開啟 Eclipse EE
2. 建立Tomcat Server,請點選以下連結
建立Tomcat Server 網址3. 安裝axis2-part1
4. 安裝axis2-part2(點選Browse,選擇axis2解壓縮檔的路徑)
5. 安裝axis2-part3(設定web service與server執行環境)
6.建立 Web Service環境-part1
7. 建立 Web Service環境-part2
8. 建立 Web Service環境-part3
9. 建立 Web Service環境-part4(點選Modify)
10. 建立StudentWSApp.java-part1
11. 建立StudentWSApp.java-part2
12. 建立Student.java-part1
13. 建立Student.java-part2
14. 建立SendStudent.java(這邊的package name必須跟android的package name相同,因為在雲端傳輸的資料必須要序列化)-part1
15. 建立SendStudent.java-part2
16. StudentWSApp.java程式碼
package com.app.studentWS;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.util.ArrayList;
import com.example.webserviceapp.SendStudent;
public class StudentWSApp {
private String url = "jdbc:mysql://localhost/student";
private String driver = "com.mysql.jdbc.Driver";
private String userName = "root";
private String userPassword = "root";
private static Connection conndb;
private String identified_conn_pass = "Connect MS Access 2007 Database",
identified_disconn_pass = "Disconnect MS Access 2007 Database",
identified_wmsdb_pass = "Writer MS Access 2007 Database",
identified_rmsdb_pass = "Read MS Access 2007 Database";
private String sqlInsert = "insert into student(student_id,student_name,score) values(?,?,?)",
sqlSelect = "select * from student order by id";
private static PreparedStatement insertPreparedStatement;
private boolean isCheckConnectionDB = false;
public boolean connectDB(String identified_conn_number) {
if (identified_conn_number.equals(identified_conn_pass)) {
try {
Class.forName(driver);
conndb = DriverManager.getConnection(url, userName,
userPassword);
insertPreparedStatement = conndb.prepareStatement(sqlInsert);
isCheckConnectionDB = true;
} catch (Exception io) {
System.out.println(io.getMessage());
isCheckConnectionDB = false;
}
}
return isCheckConnectionDB;
}
public boolean disconnectDB(String identified_disconn_number) {
boolean isCheckDisConnectionDB = false;
if (identified_disconn_number.equals(identified_disconn_pass)) {
try {
conndb.close();
conndb = null;
isCheckDisConnectionDB = true;
} catch (SQLException e) {
}
}
return isCheckDisConnectionDB;
}
public byte[] readMSAccessDatabase(String readMSDB) {
if (readMSDB.equals(identified_rmsdb_pass)) {
ArrayList<Student> studentArrayList = new ArrayList<Student>();
ObjectOutputStream objectOutputStream = null;
ByteArrayOutputStream byteArrayOutputStream = null;
System.out.println(Thread.currentThread().getName().toString()
+ " size = " + studentArrayList.size());
try {
Statement statement = conndb.createStatement();
ResultSet resultSet = statement.executeQuery(sqlSelect);
while (resultSet.next()) {
Student student = new Student(
resultSet.getString("student_id"),
resultSet.getString("student_name"),
resultSet.getString("score"));
studentArrayList.add(student);
}
byteArrayOutputStream = new ByteArrayOutputStream();
objectOutputStream = new ObjectOutputStream(
byteArrayOutputStream);
objectOutputStream.writeObject(studentArrayList);
} catch (Exception e) {
System.out.println(e.toString());
}
System.out.println(Thread.currentThread().getName().toString()
+ " size = " + studentArrayList.size());
return byteArrayOutputStream.toByteArray();
}
return null;
}
public String writerMSAccessDatabase(String writerMSDB,
byte[] student_byte_array) {
if (writerMSDB.equals(identified_wmsdb_pass)) {
String checkStr = "";
SendStudent sendStudent = null;
ObjectInputStream objectInputStream = null;
ByteArrayInputStream byteArrayInputStream = null;
try {
byteArrayInputStream = new ByteArrayInputStream(
student_byte_array);
objectInputStream = new ObjectInputStream(byteArrayInputStream);
sendStudent = (SendStudent) objectInputStream.readObject();
if (writerMSDB.equals(identified_wmsdb_pass)) {
if (insertPreparedStatement != null) {
insertPreparedStatement.setInt(1,
sendStudent.getStudentId());
insertPreparedStatement.setString(2,
sendStudent.getStudentName());
insertPreparedStatement.setDouble(3,
sendStudent.getStudentScore());
int checkInsert = insertPreparedStatement
.executeUpdate();
if (checkInsert > 0) {
checkStr = "Confirm insert";
}
}
}
} catch (Exception io) {
checkStr = io.toString();
}
return checkStr;
}
return null;
}
}
17. Student.java程式碼
package com.app.studentWS;
import java.io.Serializable;
public class Student implements Serializable {
private static final long serialVersionUID = 4363540466857453349L;
private String student_id;
private String student_name;
private String score;
public Student(String student_id, String student_name, String score) {
this.student_id = student_id;
this.student_name = student_name;
this.score = score;
}
public String getStudentId() {
return student_id;
}
public String getStudentName() {
return student_name;
}
public String getStudentScore() {
return score;
}
}
18. SendStudent .java程式碼
package com.example.webserviceapp;
import java.io.Serializable;
public class SendStudent implements Serializable {
private int student_id;
private String student_name;
private double score;
private static final long serialVersionUID = -13900787737978801L;
public SendStudent(int student_id, String student_name, double score) {
this.student_id = student_id;
this.student_name = student_name;
this.score = score;
}
public int getStudentId() {
return student_id;
}
public String getStudentName() {
return student_name;
}
public double getStudentScore() {
return score;
}
}
19. 針對StudentWSApp建立Web Service並產生wsdl檔-part1
20. 針對StudentWSApp建立Web Service並產生wsdl檔-part2
21. 查詢wsdl檔-part1
22. 查詢wsdl檔-part2
23. 查詢wsdl檔-part3
24. 查詢wsdl檔-part4
25. 上網輸入 http://localhost:8080/StudentWSApp/services/StudentWSApp?wsdl (可更改localhost為你的IP Address,Android會透過wsdl將資料在雲端進行操作)
26. 以下為wsdl檔的模樣
MySQL JDBC Driver Download
28. 匯入MySQL的JDBC Driver-part2
29. 下載完成並安裝,到C:\Program Files (x86)\MySQL\MySQL Connector J目錄下可找到mysql-connector-java-5.1.31-bin.jar
30. 匯入MySQL的JDBC Driver(將mysql-connector-java-5.1.31-bin.jar複製到專案裡的WebContent/WEB-INF/lib)
建立Android Client,並整合Web Service與MySQL
1. 開啟Eclipse ADT
2. 建立專案-part1
3. 建立專案-part2
4. 建立專案-part3(一直按Next到如下畫面)
5.匯入SOAP.jar檔,以下網址有教你如何匯入到專案
匯入SOAP.jar
下列為Android程式碼
1. WebServiceApp .java
package com.example.webserviceapp;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.util.ArrayList;
import org.ksoap2.SoapEnvelope;
import org.ksoap2.serialization.PropertyInfo;
import org.ksoap2.serialization.MarshalBase64;
import org.ksoap2.serialization.SoapObject;
import org.ksoap2.serialization.SoapPrimitive;
import org.ksoap2.serialization.SoapSerializationEnvelope;
import org.ksoap2.transport.HttpTransportSE;
import com.app.studentWS.Student;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.AsyncTask;
import android.os.Bundle;
import android.app.Activity;
import android.app.AlertDialog;
import android.app.ProgressDialog;
import android.content.Context;
import android.content.DialogInterface;
import android.util.Base64;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.inputmethod.InputMethodManager;
import android.widget.Button;
import android.widget.CompoundButton;
import android.widget.CompoundButton.OnCheckedChangeListener;
import android.widget.EditText;
import android.widget.Switch;
import android.widget.Toast;
public class WebServiceApp extends Activity {
private Button read, writer, next, previous;
private EditText id_et, name_et, score_et;
private Switch writer_SWH, conndb_SWH;
private static int WIFI_CONNECTED_STATUS = 0,
MOBILE_INTERNET_CONNECTED_STATUS = 1;
private InternetConnectionDetector internetDB;
private Boolean isConnectionExist = false;
public final static String URL = "http://220.138.114.182:8080/StudentWSApp/services/StudentWSApp?wsdl"; //紅字部分為host的IP Address
public static final String NAMESPACE = "http://studentWS.app.com";
public static final String SOAP_ACTION_CONNDB = "http://studentWS.app.com/connectDB",
SOAP_ACTION_DISCONNDB = "http://studentWS.app.com/disconnectDB",
SOAP_ACTION_RMSDB = "http://studentWS.app.com/readMSAccessDatabase",
SOAP_ACTION_WMSDB = "http://studentWS.app.com/writerMSAccessDatabase";
private static final String CONNDB_METHOD = "connectDB",
DISCONNDB_METHOD = "disconnectDB",
RMSDB_METHOD = "readMSAccessDatabase",
WMSDB_METHOD = "writerMSAccessDatabase";
private static final String identified_conn_pass = "Connect MS Access 2007 Database",
identified_disconn_pass = "Disconnect MS Access 2007 Database",
identified_rmsdb_pass = "Read MS Access 2007 Database",
identified_wmsdb_pass = "Writer MS Access 2007 Database";
private static final String conndb_methodParameter = "identified_conn_number",
disconndb_methodParameter = "identified_disconn_number",
rmsdb_methodParameter = "readMSDB",
wmsdb_student_methodParameter = "student_byte_array",
wmsdb_methodParameter = "writerMSDB";
private static final String taskConnDB = "conndb",
taskDisConnDB = "disconndb";
private int doubleCheck = 0;
private String progressContent;
private ArrayList<Student> arrayListStudent;
private int rowCount;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_web_service_app);
processView();
processControl();
}
public void processView() {
internetDB = new InternetConnectionDetector(getApplicationContext());
read = (Button) this.findViewById(R.id.readBtn);
writer = (Button) this.findViewById(R.id.writerBtn);
next = (Button) this.findViewById(R.id.nextBtn);
previous = (Button) this.findViewById(R.id.preBtn);
id_et = (EditText) this.findViewById(R.id.id_ET);
name_et = (EditText) this.findViewById(R.id.name_ET);
score_et = (EditText) this.findViewById(R.id.score_ET);
writer_SWH = (Switch) this.findViewById(R.id.write_SWH);
conndb_SWH = (Switch) this.findViewById(R.id.conndb_SWH);
writer.setEnabled(false);
}
public void processControl() {
writer_SWH.setOnCheckedChangeListener(new OnCheckedChangeListener() {
@Override
public void onCheckedChanged(CompoundButton compoundBtn,
boolean checked) {
new WebServiceApp.CheckDBConnTask(compoundBtn).execute(checked);
}
});
conndb_SWH.setOnCheckedChangeListener(new OnCheckedChangeListener() {
@Override
public void onCheckedChanged(CompoundButton compoundBtn,
boolean checked) {
if (checked) {
if (isCheckInternetConnect()) {
connectDB();
} else {
doubleCheck = 1;
AlertDialog alertDialog = new AlertDialog.Builder(
WebServiceApp.this).create();
alertDialog.setTitle("No Internet Connection");
// Setting Dialog Message
alertDialog
.setMessage("Your device doesn't have Internet access");
// Setting alert dialog icon
alertDialog.setIcon(android.R.drawable.ic_delete);
alertDialog.setButton("OK",
new DialogInterface.OnClickListener() {
public void onClick(DialogInterface dialog,
int which) {
conndb_SWH.setChecked(false);
}
});
alertDialog.show();
}
} else {
if (doubleCheck == 0) {
disconnectDB();
setRestoreContent(compoundBtn);
}
}
}
});
read.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View view) {
if (conndb_SWH.isChecked()) {
readMSAccessDB();
} else {
Toast.makeText(WebServiceApp.this,
"Please connect Database", Toast.LENGTH_SHORT)
.show();
}
}
});
writer.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View view) {
try {
int student_id = Integer.parseInt(id_et.getText()
.toString());
String student_name = name_et.getText().toString();
double score_name = Double.parseDouble(score_et.getText()
.toString());
SendStudent student = new SendStudent(student_id,
student_name, score_name);
new WebServiceApp.WMSDBTask().execute(student);
} catch (Exception io) {
Toast.makeText(WebServiceApp.this,
"Please input correct format", Toast.LENGTH_SHORT)
.show();
}
}
});
next.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View view) {
if (!id_et.getText().toString().equals("")) {
nextData();
} else {
Toast.makeText(WebServiceApp.this, "Please read data",
Toast.LENGTH_SHORT).show();
}
}
});
previous.setOnClickListener(new OnClickListener() {
@Override
public void onClick(View view) {
if (!id_et.getText().toString().equals("")) {
preData();
} else {
Toast.makeText(WebServiceApp.this, "Please read data",
Toast.LENGTH_SHORT).show();
}
}
});
}
public void readMSAccessDB() {
new WebServiceApp.RMSDBTask().execute(identified_rmsdb_pass);
}
public void setClearContent() {
id_et.setText("");
name_et.setText("");
score_et.setText("");
id_et.setHint("Please input data");
name_et.setHint("Please input data");
score_et.setHint("Please input data");
read.setEnabled(false);
next.setEnabled(false);
previous.setEnabled(false);
writer.setEnabled(true);
id_et.setFocusableInTouchMode(true);
name_et.setFocusableInTouchMode(true);
score_et.setFocusableInTouchMode(true);
}
public void setRestoreContent(View view) {
id_et.setText("");
name_et.setText("");
score_et.setText("");
id_et.setHint("Please read data");
name_et.setHint("Please read data");
score_et.setHint("Please read data");
read.setEnabled(true);
next.setEnabled(true);
previous.setEnabled(true);
writer.setEnabled(false);
id_et.setFocusable(false);
name_et.setFocusable(false);
score_et.setFocusable(false);
InputMethodManager inputMethodManager = (InputMethodManager) getSystemService(INPUT_METHOD_SERVICE);
inputMethodManager.hideSoftInputFromWindow(view.getWindowToken(),
InputMethodManager.HIDE_NOT_ALWAYS);
}
public boolean isCheckInternetConnect() {
isConnectionExist = internetDB.checkMobileInternetConn();
if (isConnectionExist) {
return true;
}
return false;
}
public void connectDB() {
doubleCheck = 0;
new WebServiceApp.DBTask().setProgressContent("CODB");
new WebServiceApp.DBTask().execute(identified_conn_pass,
conndb_methodParameter, SOAP_ACTION_CONNDB, CONNDB_METHOD,
taskConnDB);
}
public void disconnectDB() {
new WebServiceApp.DBTask().setProgressContent("DISCODB");
new WebServiceApp.DBTask().execute(identified_disconn_pass,
disconndb_methodParameter, SOAP_ACTION_DISCONNDB,
DISCONNDB_METHOD, taskDisConnDB);
}
private class InternetConnectionDetector {
private Context context;
public InternetConnectionDetector(Context context) {
this.context = context;
}
public boolean checkMobileInternetConn() {
// Create object for ConnectivityManager class which returns network
// related info
ConnectivityManager connectivity = (ConnectivityManager) context
.getSystemService(Context.CONNECTIVITY_SERVICE);
// If connectivity object is not null
if (connectivity != null) {
// Get network info - WIFI internet access
NetworkInfo[] internetInfo = {
connectivity
.getNetworkInfo(ConnectivityManager.TYPE_WIFI),
connectivity
.getNetworkInfo(ConnectivityManager.TYPE_MOBILE) };
if (internetInfo[WIFI_CONNECTED_STATUS] != null
|| internetInfo[MOBILE_INTERNET_CONNECTED_STATUS] != null) {
// Look for whether device is currently connected to WIFI
// network
if (internetInfo[WIFI_CONNECTED_STATUS].isConnected()
|| internetInfo[MOBILE_INTERNET_CONNECTED_STATUS]
.isConnected()) {
return true;
}
}
}
return false;
}
}
private class CheckDBConnTask extends AsyncTask<Boolean, Integer, Boolean> {
private View view;
public CheckDBConnTask(View view) {
this.view = view;
}
@Override
protected void onPreExecute() {
}
@Override
protected Boolean doInBackground(Boolean... isConnCheck) {
return isConnCheck[0];
}
@Override
protected void onPostExecute(Boolean result) {
if (conndb_SWH.isChecked()) {
if (result) {
setClearContent();
} else {
setRestoreContent(view);
}
} else {
writer_SWH.setChecked(false);
Toast.makeText(WebServiceApp.this,
"Please connection database", Toast.LENGTH_SHORT)
.show();
}
}
}
private class DBTask extends AsyncTask<String, Integer, String> {
private ProgressDialog progresslog;
private String chooseTost;
public void setProgressContent(String content) {
progressContent = content;
}
@Override
protected void onPreExecute() {
progresslog = new ProgressDialog(WebServiceApp.this, 1);
progresslog.setCancelable(false);
if (progressContent.equals("CODB")) {
progresslog.setMessage("Connect Database...");
} else if (progressContent.equals("DISCODB")) {
progresslog.setMessage("DisConnect Database...");
}
progresslog.setProgressStyle(ProgressDialog.STYLE_SPINNER);
progresslog.show();
}
@Override
protected String doInBackground(String... connStr) {
chooseTost = connStr[4];
boolean isCheckedConn = false;
SoapObject requestWS = new SoapObject(NAMESPACE, connStr[3]);
PropertyInfo connInfoP = new PropertyInfo();
connInfoP.setName(connStr[1]);// Define the variable
// name in the web
// service method
connInfoP.setValue(connStr[0]); // Define value for
// identified_number variable
connInfoP.setType(String.class); // Define the type of the variable
requestWS.addProperty(connInfoP);
SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(
SoapEnvelope.VER11);
envelope.setOutputSoapObject(requestWS);
HttpTransportSE androidHttpTransport = new HttpTransportSE(URL);
try {
androidHttpTransport.call(connStr[2], envelope);
SoapPrimitive response = (SoapPrimitive) envelope.getResponse();
isCheckedConn = Boolean.parseBoolean(response.toString());
} catch (Exception io) {
Log.e("error", io.toString());
}
return String.valueOf(isCheckedConn);
}
@Override
protected void onPostExecute(String result) {
boolean isConnect = Boolean.valueOf(result);
if (isConnect) {
if (chooseTost.equals(taskConnDB)) {
Toast.makeText(WebServiceApp.this,
"Connection Database with success",
Toast.LENGTH_SHORT).show();
} else if (chooseTost.equals(taskDisConnDB)) {
Toast.makeText(WebServiceApp.this,
"Database with success disconnect",
Toast.LENGTH_SHORT).show();
writer_SWH.setChecked(false);
rowCount = 0;
}
} else {
if (chooseTost.equals(taskConnDB)) {
doubleCheck = 1;
Toast.makeText(WebServiceApp.this,
"Connection Database with failure",
Toast.LENGTH_SHORT).show();
conndb_SWH.setChecked(false);
} else if (chooseTost.equals(taskDisConnDB)) {
Toast.makeText(WebServiceApp.this,
"Database already disconnect", Toast.LENGTH_SHORT)
.show();
writer_SWH.setChecked(false);
rowCount = 0;
}
}
progresslog.dismiss();
}
}
private class WMSDBTask extends AsyncTask<SendStudent, Integer, String> {
private ProgressDialog progresslog;
@Override
protected void onPreExecute() {
progresslog = new ProgressDialog(WebServiceApp.this, 1);
progresslog.setCancelable(false);
progresslog.setMessage("Write data to database...");
progresslog.setProgressStyle(ProgressDialog.STYLE_SPINNER);
progresslog.show();
}
@Override
protected String doInBackground(SendStudent... receiveObj) {
String receiveStr = "";
SoapObject requestWS = new SoapObject(NAMESPACE, WMSDB_METHOD);
ObjectOutputStream objectOutputStream = null;
ByteArrayOutputStream byteArrayOutputStream = null;
try {
byteArrayOutputStream = new ByteArrayOutputStream();
objectOutputStream = new ObjectOutputStream(
byteArrayOutputStream);
objectOutputStream.writeObject(receiveObj[0]);
PropertyInfo writerStudentIP = new PropertyInfo();
writerStudentIP.setName(wmsdb_methodParameter);
writerStudentIP.setValue(identified_wmsdb_pass);
writerStudentIP.setType(String.class);
requestWS.addProperty(writerStudentIP);
PropertyInfo writerStudentBP = new PropertyInfo();
writerStudentBP.setName(wmsdb_student_methodParameter);
writerStudentBP.setValue(byteArrayOutputStream.toByteArray());
writerStudentBP.setType(byte[].class);
requestWS.addProperty(writerStudentBP);
SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(
SoapEnvelope.VER11);
new MarshalBase64().register(envelope);
envelope.setOutputSoapObject(requestWS);
HttpTransportSE androidHttpTransport = new HttpTransportSE(URL);
androidHttpTransport.call(SOAP_ACTION_WMSDB, envelope);
SoapPrimitive response = (SoapPrimitive) envelope.getResponse();
receiveStr = response.toString();
} catch (Exception io) {
receiveStr = io.toString();
}
return receiveStr;
}
@Override
protected void onPostExecute(String result) {
progresslog.dismiss();
if (result.equals("Confirm insert")) {
Toast.makeText(WebServiceApp.this, "Insert success",
Toast.LENGTH_LONG).show();
} else {
Toast.makeText(WebServiceApp.this,
"Database already disconnect", Toast.LENGTH_SHORT)
.show();
}
}
}
private class RMSDBTask extends
AsyncTask<String, Integer, ArrayList<Student>> {
private ProgressDialog progresslog;
@Override
protected void onPreExecute() {
progresslog = new ProgressDialog(WebServiceApp.this, 1);
progresslog.setCancelable(false);
progresslog.setMessage("Read data of Database...");
progresslog.setProgressStyle(ProgressDialog.STYLE_SPINNER);
progresslog.setCancelable(false);
progresslog.show();
}
@Override
protected ArrayList<Student> doInBackground(String... connStr) {
ArrayList<Student> soapList = null;
SoapObject requestRWSDB = new SoapObject(NAMESPACE, RMSDB_METHOD);
PropertyInfo rwsdbInfo = new PropertyInfo();
rwsdbInfo.setName(rmsdb_methodParameter);
rwsdbInfo.setValue(connStr[0]);
rwsdbInfo.setType(String.class);
requestRWSDB.addProperty(rwsdbInfo);
SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(
SoapEnvelope.VER11);
envelope.setOutputSoapObject(requestRWSDB);
HttpTransportSE androidHttpTransport = new HttpTransportSE(URL);
try {
androidHttpTransport.call(SOAP_ACTION_RMSDB, envelope);
SoapPrimitive soapPrimitive = (SoapPrimitive) envelope
.getResponse();
soapList = handleSoapPrimitiveConvertArrayList(soapPrimitive);
} catch (Exception io) {
Log.e("doInBackground", io.toString());
}
return soapList;
}
@Override
protected void onPostExecute(ArrayList<Student> result) {
try {
rowCount = 0;
initArrayListStudent(result);
showData(0);
progresslog.dismiss();
} catch (Exception io) {
Log.e("onPostExecute", io.toString());
}
}
private ArrayList<Student> handleSoapPrimitiveConvertArrayList(
SoapPrimitive soapPrimitive) {
try {
byte[] information = Base64.decode(soapPrimitive.toString()
.getBytes(), Base64.DEFAULT);
ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(
information);
ObjectInputStream objectInputStream = new ObjectInputStream(
byteArrayInputStream);
ArrayList<Student> arraylist_student = (ArrayList<Student>) objectInputStream
.readObject();
return arraylist_student;
} catch (Exception io) {
return null;
}
}
}
public void initArrayListStudent(ArrayList<Student> result) {
if (arrayListStudent != null) {
arrayListStudent.clear();
}
arrayListStudent = result;
// Log.e("Size", arrayListStudent.size() + "");
}
public void showData(int index) {
if (arrayListStudent != null) {
if (arrayListStudent.size() > 0) {
id_et.setText(arrayListStudent.get(index).getStudentId() + "");
name_et.setText(arrayListStudent.get(index).getStudentName());
score_et.setText(arrayListStudent.get(index).getStudentScore()
+ "");
} else {
Toast.makeText(this, "Please insert data", Toast.LENGTH_SHORT)
.show();
}
} else {
Toast.makeText(this, "Database already disconnection",
Toast.LENGTH_SHORT).show();
}
}
public void nextData() {
if (arrayListStudent != null) {
rowCount++;
if (rowCount >= arrayListStudent.size()) {
rowCount = 0;
}
showData(rowCount);
} else {
Toast.makeText(this, "Database already disconnection",
Toast.LENGTH_SHORT).show();
}
}
public void preData() {
if (arrayListStudent != null) {
rowCount--;
if (rowCount < 0) {
rowCount = arrayListStudent.size() - 1;
}
showData(rowCount);
} else {
Toast.makeText(this, "Database already disconnection",
Toast.LENGTH_SHORT).show();
}
}
}
2. Student.java(這邊的package name與web service的student的package name相同)
package com.app.studentWS;
import java.io.Serializable;
public class Student implements Serializable {
private String student_id, student_name, score;
private static final long serialVersionUID = 4363540466857453349L;
public Student(String student_id, String student_name, String score) {
this.student_id = student_id;
this.student_name = student_name;
this.score = score;
}
public String getStudentId() {
return student_id;
}
public String getStudentName() {
return student_name;
}
public String getStudentScore() {
return score;
}
}
3. SendStudent.java
package com.example.webserviceapp;
import java.io.Serializable;
public class SendStudent implements Serializable {
private static final long serialVersionUID = -13900787737978801L;
private int student_id;
private String student_name;
private double score;
public SendStudent(int student_id, String student_name, double score) {
this.student_id = student_id;
this.student_name = student_name;
this.score = score;
}
}
4. activity_web_service_app.xml
<?xml version="1.0"?>
<LinearLayout xmlns:tools="http://schemas.android.com/tools"
xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="match_parent"
android:layout_height="match_parent"
android:orientation="vertical"
tools:context=".WebServiceApp" >
<TextView
android:id="@+id/id_TV"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Id : "
android:textColor="@android:color/black"
android:textSize="20sp" />
<EditText
android:id="@+id/id_ET"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:ems="10"
android:focusable="false"
android:hint="Please read data" >
<requestFocus />
</EditText>
<TextView
android:id="@+id/name_TV"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Name : "
android:textColor="@android:color/black"
android:textSize="20sp" />
<EditText
android:id="@+id/name_ET"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:ems="10"
android:focusable="false"
android:hint="Please read data" />
<TextView
android:id="@+id/score_TV"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Score : "
android:textColor="@android:color/black"
android:textSize="20sp" />
<EditText
android:id="@+id/score_ET"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:ems="10"
android:focusable="false"
android:hint="Please read data" />
<RelativeLayout
android:layout_width="match_parent"
android:layout_height="wrap_content" >
<Button
android:id="@+id/readBtn"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Read" />
<Button
android:id="@+id/writerBtn"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_alignParentTop="true"
android:layout_toRightOf="@+id/readBtn"
android:text="Writer" />
<Button
android:id="@+id/preBtn"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_alignParentTop="true"
android:layout_toRightOf="@+id/writerBtn"
android:text="Previous" />
<Button
android:id="@+id/nextBtn"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:layout_alignParentTop="true"
android:layout_toRightOf="@+id/preBtn"
android:text="Next" />
</RelativeLayout>
<Switch
android:id="@+id/write_SWH"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Writer Data" />
<Switch
android:id="@+id/conndb_SWH"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Connect Database" />
</LinearLayout>
5. AndroidManifest.xml(重點程式碼)
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
<uses-permission android:name="android.permission.INTERNET" />
沒有留言:
張貼留言