一，JDBC 简介

JDBC:java database connectivity java数据库连接

常用的数据库mysql oracle sqlserver

sun公司提供了一套jdbc的接口，让数据库厂商实现。

 

二，JDBC使用：

1，JDBC简单使用

    步骤：

       1），导入jar包   

public class JDBCTest {

 

   @Test

   public void jdbcTest() {

       try {

          // [1]注册mysql驱动

           //DriverManager.registerDriver(new Driver());    

           Class.forName("com.mysql.jdbc.Driver");

           

           // [2]连接数据库

           // jdbc:subprotocol:subname

           //  URL 固定格式： jdbc：数据库名字// localhost：3306/ lol （本地数据库地址），用户名，密码

           Connection connection = DriverManager.getConnection(

                   "jdbc:mysql://localhost:3306/lol", "root", "1q2w3e");

 

          // [3]创建一个statement对象 类似 库管

           Statement statement = connection.createStatement();

           // [4]执行查询语句

           ResultSet resultSet = statement.executeQuery("select * from student");

           resultSet.next();

           String name = resultSet.getString(2);

           System.out.println("name = "+name);

           

       } catch (Exception e) {

           // TODO Auto-generated catch block

           e.printStackTrace();

       }

   }

}

2，JDBC类重要的方法：

    【1】DriverManager：注册驱动 告诉当前程序 连接哪个数据库       

            DriverManager.registerDriver(new Driver());

            Class.forName("com.mysql.jdbc.Driver");

            获取连接 ：“ DriverManager.getConnection("jdbc:mysql:///mydb1", "root", "1q2w3e");

    【2】Connection: 连接数据库的对象

            获取一个statement                connection.createStatement()

            获取一个preparedStatement

    【3】Statement： 用来执行sql语句 是一个库管对象

            接口 Statement：用于执行静态 SQL 语句并返回它所生成结果的对象。

            方法：

                executeQuery(String sql)    执行给定的 SQL 语句，该语句返回单个 ResultSet 对象。

    【4】ResultSet: 结果集对象 里面有一个光标 默认在第一行之前 调用next方法 就可以向下移动

            接口 ResultSet： 表示数据库结果集的数据表，通常通过执行查询数据库的语句生成。

            方法：getString(String columnLabel)   以 Java 编程语言中 String 的形式获取此 ResultSet 对象的当前行中指定列的值。

                      executeUpdate(String sql) 执行给定 SQL 语句，该语句可能为 INSERT、UPDATE 或 DELETE 语句，或者不返回任何内容的 SQL 语句（如 SQL DDL 语句）。

 

    为什么使用     Class.forName("com.mysql.jdbc.Driver");创建对象：

    // 本身方法也是new Driver。我们用Class去调用免得重复创建对象 Driver 类里自己静态代码块进行加载了自己

 

3，JDBC简单调用增删改查：

 

public class JDBCSample {

 

    @Test

    public void add() {

        //插入语句

        try {

            //注册驱动

            Class.forName("com.mysql.jdbc.Driver");

            //链接数据库

            Connection connection = DriverManager.getConnection(

                    "jdbc:mysql://localhost:3306/lol", "root", "1q2w3e");

            //申请对象类似于库管

            Statement statement = connection.createStatement();

            

            int result = statement

                    .executeUpdate("insert into student values(30,'zhaoyun',99,100)");

            if (result > 0) {

                System.out.println("插入成功");

            } else {

                System.out.println("插入失败");

            }

 

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

 

    @Test

    public void remove() {

        //删除语句

        try {

            Class.forName("com.mysql.jdbc.Driver");

            Connection connection = DriverManager.getConnection(

                    "jdbc:mysql://localhost:3306/lol", "root", "1q2w3e");

            Statement statement = connection.createStatement();

            int result = statement

                    .executeUpdate("delete from student where id > 20");

            if (result > 0) {

                System.out.println("删除成功" + result);

            } else {

                System.out.println("删除失败" + result);

            }

 

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

 

    @Test

    public void update() {

        //更新语句

        try {

            Class.forName("com.mysql.jdbc.Driver");

            Connection connection = DriverManager.getConnection(

                    "jdbc:mysql://localhost:3306/lol", "root", "1q2w3e");

            Statement statement = connection.createStatement();

 

            int result = statement

                    .executeUpdate("update student set english = 100 where id = 30");

            if (result > 0) {

                System.out.println("更新成功" + result);

            } else {

                System.out.println("更新失败" + result);

            }

 

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

 

    }

 

    @Test

    public void query() {

        //查询语句

        try {

            Class.forName("com.mysql.jdbc.Driver");

            Connection connection = DriverManager.getConnection(

                    "jdbc:mysql://localhost:3306/lol", "root", "1q2w3e");

            Statement statement = connection.createStatement();

            ResultSet resultSet = statement

                    .executeQuery("select * from student");

 

            while (resultSet.next()) {

                String id = resultSet.getString(1);

                String name = resultSet.getString(2);

                String english = resultSet.getString(3);

                String math = resultSet.getString(4);

                

                System.out.println("id = "+id +" name = "+name + " english = "+english +" math = "+math);

            }

 

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

}

 

 

4，JDBC的封装：

    [1]创建配置文件：db.properties 存放路径，帐号，密码。

className:com.mysql.jdbc.Driver

url:jdbc:mysql://localhost:3306/lol

name:root

pwd:1q2w3e

    [2] 创建Utils getConnection获取对数据库的链接

public class JDBCUtils {

 

    private static String className;

    private static String url;

    private static String name;

    private static String pwd;

 

    static {

        try {

            //保存本地配置

            Properties properties = new Properties();

            properties.load(new FileInputStream("db.properties"));

            //获取properties 中的字段

            className = properties.getProperty("className");

            url = properties.getProperty("url");

            name = properties.getProperty("name");

            pwd = properties.getProperty("pwd");

 

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

    //获取

    public static Connection getConnection() throws Exception {

        Class.forName(className);

        return DriverManager.getConnection(url, name, pwd);

    }

}

    [3] 写SQL语句

public class JDBCUtilsTest {

 

    @Test

    public void add() {

        try {

            Connection connection = JDBCUtils.getConnection();

            Statement statement = connection.createStatement();

            int result = statement.executeUpdate("insert into student values(30,'machao',99,99)");

            System.out.println("result = "+result);

            

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        };

    }

 

    @Test

    public void remove() {

        try {

            Connection connection = JDBCUtils.getConnection();

            Statement statement = connection.createStatement();

            int result = statement.executeUpdate("delete from student where id = 30");

            System.out.println("result = "+result);

            

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        };

    }

 

    @Test

    public void update() {

        try {

            Connection connection = JDBCUtils.getConnection();

            Statement statement = connection.createStatement();

            int result = statement.executeUpdate("update student set english = 100 where id =20");

            System.out.println("result = "+result);

            

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        };

        

    }

 

    @Test

    public void query() {

        try {

            Connection connection = JDBCUtils.getConnection();

            Statement statement = connection.createStatement();

            

            ResultSet resultSet = statement.executeQuery("select * from student");

            

            while(resultSet.next()){

                String id = resultSet.getString(1);

                String name = resultSet.getString(2);

                String english = resultSet.getString(3);

                String math = resultSet.getString(4);

                System.out.println("id = "+id +" name = "+name + " english = "+english  +" math = "+math);

            }

            

            

            

        } catch (Exception e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

        

    }

}

 

5，login登陆查询数据库

 

    *BUG，预编译。占位符。进行编译转义。

 

有朋友问我怎么做物联网的app,我说一个方式可以直连，另一个用web服务器来跟数据库连接，最后他们决定直连数据库。

第二天，朋友说遇到了各种问题，我想不对啊，我以前大二17年的时候很简单就连上了，所以打算给做一个demo。

结果真的遇到了问题，花了4个小时查原因，最后解决了。上网找信息结果都是一些错误的比如android 不能直连数据库什么的说法。这些我也不评价了。

这次我用的是android studio。

1.首先新建项目,helloword就行了。

2.第二步下载JDBC驱动

百度查mysql connector java一般第一个就是了

或者这个链接https://dev.mysql.com/downloads/connector/j/

下载这个就好了

问你是否登个录，你有oracle的账号想登就等吧，懒得登就no thanks。

下载后打开zip

里面的jar包就是编译好的驱动程序了

3.导入驱动进工程

project视图下能看到libs 拖进去就行了

然后加入dependencies

项目视图->项目名->右键->open modle setting(f4)

选择你拖进来的jar包

4.加载驱动并使用

驱动是5.1版本，用的是JAVA JDK1.8

所以要在项目视图->项目名->右键->open modle setting(f4)

设置

并且添加jackOption

本来是直接

Class.forName("com.mysql.jdbc.Driver");//加载驱动
java.sql.Connection cn= DriverManager.getConnection("jdbc:mysql://IP:端口/数据库名","用户","密码");//连接
String sql="select * from a";
Statement st=(Statement)cn.createStatement();
ResultSet rs=st.executeQuery(sql);

结果怎么也连不上

排除了防火墙，端口不对，用户远程权限还是无法连接

下面的一个webview是用来测试网络连接的，那时候怀疑是网络问题。

private TextView text1;
private WebView webView;
private String ip="192.168.31.148";
private Connection connection;

protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    //初始化空间
    TextView text1=(TextView)findViewById(R.id.text1);
    webView = (WebView)findViewById(R.id.web);//new WebView(this);
    webView.loadUrl("http://"+ip);          //调用loadUrl方法为WebView加入链接
    //setContentView(webView);
    webView.setWebViewClient(new WebViewClient(){
        @Override
        public boolean shouldOverrideUrlLoading(WebView view, String url) {

            webView.loadUrl(url);
            //返回值为true的时候控制网页在WebView中打开，为false时调用系统浏览器呀第三方浏览器
            return false;
        }
    });
    //启用支持JavaScript
    WebSettings settings=webView.getSettings();
    settings.setJavaScriptEnabled(true);
    //WebView加载页面优先使用缓存加载
    settings.setCacheMode(WebSettings.LOAD_CACHE_ELSE_NETWORK);
    try {
        Class.forName("com.mysql.jdbc.Driver");
        connection = DriverManager.getConnection("jdbc:mysql://192.168.31.168:3306/test?useUnicode=true&characterEncoding=gbk","test","1234");
        //connection = DriverManager.getConnection("jdbc:mysql://192.168.31.168:3306;DatabaseName=test" + "?user=test&password=1234");
        //connection = DriverManager.getConnection("jdbc:mysql://192.168.31.168:3306/test?user=test&password=1234");
        if (connection!=null) {
            try {
                String sql = "select * from user";        //查询表名为“user”的所有内容
                Statement stmt = connection.createStatement();        //创建Statement
                ResultSet rs = stmt.executeQuery(sql);          //ResultSet类似Cursor

                //<code>ResultSet</code>最初指向第一行
                Bundle bundle = new Bundle();
                while (rs.next()) {
                    bundle.clear();
                    text1.setText(rs.getString("username"));
                }

                rs.close();
                stmt.close();
            } catch (SQLException e) {

            } finally {
                if (connection != null)
                    try {
                        connection.close();
                    } catch (SQLException e) {
                    }
            }
        }
    } catch (ClassNotFoundException e1) {
        text1.setText("驱动初始化失败"+e1);
    } catch (SQLException e1) {
        text1.setText("数据库链接失败"+e1);
    }
}

网络访问正常，但是JDBC连接不成功，差点我就怀疑官方BUG了，查官方的JDBC驱动包

最后 发现要使用多线程才能连接上，好像是从某个API版本后直连就不支持了，需要用子线程进行连接

code:

private TextView text1;//即hello word那行的
@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
    text1=(TextView)findViewById(R.id.test1);//获取控件

    new Thread(new Runnable() {//新建线程
        @Override
        public void run() {
            try {
                Log.v("tag","run");//调试信息
                Class.forName("com.mysql.jdbc.Driver");//加载驱动
                java.sql.Connection cn= DriverManager.getConnection("jdbc:mysql://192.168.31.168:3306/test","test","1234");//连接
                String sql="select * from a";//准备语句
                Statement st=(Statement)cn.createStatement();
                ResultSet rs=st.executeQuery(sql);//执行

                while(rs.next()){//遍历结果
                    final String mybook=rs.getString("name");//查找字段
                    Log.v("tag",mybook+"");//调试信息
                    text1.post(new Runnable() {//子线程post方法更新UI，否则会FALUT抛出
                        @Override public void run() {
                            text1.setText(""+mybook);//更新textview
                        }
                    });

                    Log.i("Mainactivity",mybook);
                }
                cn.close();//记得关闭 不然内存泄漏
                st.close();
                rs.close();
                Log.v("tag","end");
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
                text1.setText("驱动初始化失败"+e);
            } catch (SQLException e) {
                e.printStackTrace();
                text1.setText("数据库链接失败"+e);
            }
        }
    }).start();//执行线程

表里的数据就一个1，用来测试的

完成了，网上很多直连文章都过时了，或者是错误的，也可能是工具原因。

因为本人目前并不写android和java，但是涉略较广，所以一些理解还是比较浅的，欢迎指正。