欢迎访问悦橙教程(wld5.com),关注java教程。悦橙教程  java问答|  每日更新
页面导航 : > > 文章正文

JDBC连接MYSQL数据库示例,jdbcmysql示例,JDBC是一种用于执行S

来源: javaer 分享于  点击 35861 次 点评:38

JDBC连接MYSQL数据库示例,jdbcmysql示例,JDBC是一种用于执行S


JDBC是一种用于执行SQL语句的JavaAPI,可以为多种关系数据库提供统一访问,它由一组用JAVA编写的类和接口组成。说白了就和PHP的PDO一样,通过JDBC,JAVA可以使用相同的API接口来链接例如:MYSQL,SQLSERVER等不同类型的数据库。连接MYSQL数据库:```javapackage main;

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

public class Mysql { public static void main(String arg[]) { try { Connection con = null; //定义一个MYSQL链接对象 Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动 con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL System.out.print("yes"); } catch (Exception e) { System.out.print("MYSQL ERROR:" + e.getMessage()); }

}

}

Class.forName("com.mysql.jdbc.Driver").newInstance(); 我们链接的是MYSQL数据库,所以需要一个MYSQL的数据库驱动,如果你的环境中木有安装,可以下载:mysql-connector-java-5.1.17-bin.jar JAR包,然后放进jdk1.6.0_37\jre\lib\ext 重启eclispe 就可以在JRE系统库中看到。con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); 是链接数据库的语句,返回Connection con对象。参数格式:("jdbc:mysql://ip:端口/数据库名称", 用户名,密码) 写入一条数据javapackage main;

import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.Statement;

public class Mysql {

/** * 入口函数 * @param arg */public static void main(String arg[]) {    try {        Connection con = null; //定义一个MYSQL链接对象        Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动        con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL        Statement stmt; //创建声明        stmt = con.createStatement();        //新增一条数据        stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");        ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");        int ret_id;        if (res.next()) {            ret_id = res.getInt(1);            System.out.print(ret_id);        }    } catch (Exception e) {        System.out.print("MYSQL ERROR:" + e.getMessage());    }}

}

stmt.executeUpdate INSERT DELETE UPDATE语句都用executeUpdate函数来操作stmt.executeQuery SELECT语句都用stmt.executeQuery函数来操作ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()"); 查询最后插入数据的ID号,返回ResultSet res对象删除和更新数据javapackage main;

import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.Statement;

public class Mysql {

/** * 入口函数 * @param arg */public static void main(String arg[]) {    try {        Connection con = null; //定义一个MYSQL链接对象        Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动        con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL        Statement stmt; //创建声明        stmt = con.createStatement();        //新增一条数据        stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");        ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");        int ret_id;        if (res.next()) {            ret_id = res.getInt(1);            System.out.print(ret_id);        }        //删除一条数据        String sql = "DELETE FROM user WHERE id = 1";        long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作,如果大于0,则记录删除的条数        System.out.print("DELETE:" + deleteRes);        //更新一条数据        String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";        long updateRes = stmt.executeUpdate(updateSql);        System.out.print("UPDATE:" + updateRes);    } catch (Exception e) {        System.out.print("MYSQL ERROR:" + e.getMessage());    }}

}

删除和更新数据都使用stmt.executeUpdate函数。删除和更新数据都会返回一个Long的结果,如果为0,则删除或者更新失败,如果大于0则是操作的记录数查询语句javapackage main;

import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.ResultSetMetaData;import java.sql.Statement;

public class Mysql {

/** * 入口函数 * @param arg */public static void main(String arg[]) {    try {        Connection con = null; //定义一个MYSQL链接对象        Class.forName("com.mysql.jdbc.Driver").newInstance(); //MYSQL驱动        con = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test", "root", "root"); //链接本地MYSQL        Statement stmt; //创建声明        stmt = con.createStatement();        //新增一条数据        stmt.executeUpdate("INSERT INTO user (username, password) VALUES ('init', '123456')");        ResultSet res = stmt.executeQuery("select LAST_INSERT_ID()");        int ret_id;        if (res.next()) {            ret_id = res.getInt(1);            System.out.print(ret_id);        }        //删除一条数据        String sql = "DELETE FROM user WHERE id = 1";        long deleteRes = stmt.executeUpdate(sql); //如果为0则没有进行删除操作,如果大于0,则记录删除的条数        System.out.print("DELETE:" + deleteRes);        //更新一条数据        String updateSql = "UPDATE user SET username = 'xxxx' WHERE id = 2";        long updateRes = stmt.executeUpdate(updateSql);        System.out.print("UPDATE:" + updateRes);        //查询数据并输出        String selectSql = "SELECT * FROM user";        ResultSet selectRes = stmt.executeQuery(selectSql);        while (selectRes.next()) { //循环输出结果集            String username = selectRes.getString("username");            String password = selectRes.getString("password");            System.out.print("\r\n\r\n");            System.out.print("username:" + username + "password:" + password);        }    } catch (Exception e) {        System.out.print("MYSQL ERROR:" + e.getMessage());    }}

}

```查询语句使用stmt.executeQuery函数rs.absolute() //绝对位置,负数表示从后面数rs.first()第一条rs.last()最后一条rs.previoust()前一条rs.next()后一条rs.beforeFirst()第一条之前rs.afterLast()最后之后rs.isFirst(),rs.isLast(),rs.isBeforeFirst(),rs.isAfterLast

相关栏目:

用户点评