Android实现与SQL连接

为了实现这个功能，在网上看了很多资料，可是就是下载源码来运行都还是出错，后来通过看代码总结，终于弄明白了一点，

Android与SQL连接，可以通过WebService搭建桥梁实现与SQL的连接，第二种就是通过JDBC实现与SQL连接，

本文主要是实现第二种。首先你需要在服务器建立一个数据库，如下图：

在这个代码的编写前，我们需要导入jtds-1.2.7.jar包：

然后进入代码的正式编写，我们主要是接收从服务器端发来的数据，布局非常的简单，主要用一个listview展示数据，

java代码的编写才是关键，详细如下：

package com.example.androidsql;import java.sql.Connection;  import java.sql.DriverManager;  import java.sql.ResultSet;  import java.sql.Statement;  import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map; import android.app.Activity;  import android.database.SQLException;  import android.os.Bundle;  import android.os.Handler;import android.os.Message;import android.widget.ListView;import android.widget.SimpleAdapter;/* * @author 王能斌 * Android实现与SQL数据访问 */public class MainActivity extends Activity {  private ListView sqlList;private List<Map<String, Object>> listItems ;Map<String, Object> listItem;private Handler handler;    @Override      public void onCreate(Bundle savedInstanceState) {          super.onCreate(savedInstanceState);          setContentView(R.layout.activity_main);                  sqlList = (ListView) this.findViewById(R.id.sql_list);                //此处关键，数据库的连接需放在子线程中操作        //网上的代码基本没放在子线程中，程序运行报错，应该是Android5.0以后耗时操作需放在子线程中        new Thread(new Runnable() {@Overridepublic void run() {String userName = "sa";//用户名          String password = "123456";//密码          Connection con = null;          try {         // 加载驱动程序            Class.forName("net.sourceforge.jtds.jdbc.Driver");              con = DriverManager.getConnection(                      "jdbc:jtds:sqlserver://192.168.0.65:1433/StockManage", userName,                      password);          } catch (ClassNotFoundException e) {              System.out.println("加载驱动程序出错");          } catch (SQLException e) {              System.out.println(e.getMessage());          } catch (Exception e) {              System.out.println(e.getMessage());          }          try {              testConnection(con);//测试数据库连接          } catch (java.sql.SQLException e) {              e.printStackTrace();          }  }}).start();        //接收从子线程发回来的结果进行处理        handler = new Handler(){        public void handleMessage(android.os.Message msg) {        if(msg.what == 0x123){        List<Map<String, Object>> data = (List<Map<String, Object>>) msg.obj;        SimpleAdapter adapter = new SimpleAdapter(MainActivity.this,data,         R.layout.sql_item,         new String[]{"Cno","Cname","Cnum"},        new int[]{R.id.cno,R.id.cname,R.id.cnum});        sqlList.setAdapter(adapter);        }        }        };            }        public void testConnection(Connection con) throws java.sql.SQLException {          try {              String sql = "SELECT * FROM Table_1";//查询表名为“Table_1”的所有内容              Statement stmt = con.createStatement();//创建Statement              ResultSet rs = stmt.executeQuery(sql);//ResultSet类似Cursor             listItems = new ArrayList<Map<String,Object>>();            while (rs.next()) {            listItem = new HashMap<String , Object>();            listItem.put("Cno", rs.getString("Cno"));    listItem.put("Cname",rs.getString("Cname"));    listItem.put("Cnum", rs.getString("Cnum"));    listItems.add(listItem);//                System.out.print(rs.getString("Cno") + " ");//                System.out.print(rs.getString("Cname") + " "); //                System.out.println(rs.getString("Cnum"));              }             rs.close();              stmt.close();             //消息从子线程发回主线程            Message message = new Message();            message.what = 0x123;            message.obj = listItems;            handler.sendMessage(message);        } catch (SQLException e) {              System.out.println(e.getMessage().toString());          } finally {              if (con != null)                  try {                      con.close();  //数据库的关闭                } catch (SQLException e) {              }          }    }  }

最后运行显示的界面：

更多相关文章

随机推荐