JDBC连接MYSQL数据库示例
发布时间:2020-12-15 00:22:46 所属栏目:Java 来源:网络整理
导读:今天PHP站长网 52php.cn把收集自互联网的代码分享给大家,仅供参考。 JDBC是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用JAVA编写的类和接口组成。说白了就和PHP的PDO一样,通过JDBC,J
以下代码由PHP站长网 52php.cn收集自互联网 现在PHP站长网小编把它分享给大家,仅供参考
JDBC是一种用于执行SQL语句的Java API,可以为多种关系数据库提供统一访问,它由一组用JAVA编写的类和接口组成。说白了就和PHP的PDO一样,通过JDBC,JAVA可以使用相同 的API接口来链接例如:MYSQL,SQLSERVER等不同类型的数据库。 连接MYSQL数据库:
package 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_37jrelibext?重启eclispe?就可以在JRE系统库中看到。 con?=?DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/test",?"root",?"root");??是链接数据库的语句,返回Connection?con对象。参数格式:("jdbc:mysql://ip:端口/数据库名称",?用户名,密码) ?写入一条数据 package 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"); //链接本地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对象 删除和更新数据 package 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",'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则是操作的记录数 查询语句 package 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",'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("rnrn"); 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 以上内容由PHP站长网【52php.cn】收集整理供大家参考研究 如果以上内容对您有帮助,欢迎收藏、点赞、推荐、分享。 (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |