JDBC增删改数据库的操作
JDBC：Java Database Connection，表示数据库连接（任何数据库都支持JDBC的连接），是一个独立于特定数据库管理系统、通用的sql数据库存取和操作的公共接口。它是java中专门提供的一组用于操作数据库的标准，所有的数据库生产商如果要是想为java提供支持，则必须支持此标准。既然是标准的话，所以说JDBC实际上是一套访问数据库的接口。
2、常用操作类/接口
Connection接口、Statement接口、PreapredStatement接口、ResultSet接口、CallableStatement接口、DriverManager类。
3、JDBC应用步骤
二、驱动程序下载：
根据上一段的定义，我们明白了，java定义JDBC接口，数据库来实现这个接口。不同的厂商对JDBC有不同的实现，所以厂商要提供自己数据库的驱动，让应用程序来访问。而应用程序则只通过自己的一套JDBC接口来访问就行了，然后驱动程序来实现这个接口，从而让驱动来调用数据库。所以我们终于明白了这句话：驱动程序由数据库提供商提供下载。
在Java中，驱动程序是以jar包的形式提供的，MySQL驱动程序的下载地址：http://dev.mysql.com/downloads/
上图中，选择“Connector/J”的版本进行下载，弹出下一个界面，让我们选择平台来下载：如果选择windows平台，界面如下：
如果选择跨平台，界面会变成下面的这个样子：
上图中，第一个版本是Linux平台的压缩包，第二个是Windows平台中的压缩包，那我们选择上图中的红框部分进行下载：
上图中，不用注册，直接下载。下载完成后，解压：
上图中，红框部分的mysql-connector-java-5.1.33-bin.jar就是我们所需要的包。
三、JDBC实现简单增删改操作
1、JDBC操作前的准备工作：
首先创建数据库表：person。字段：id，name，age，description。建表的命令如下：
CREATE TABLE person(id int primary key auto_increment,name varchar(20),age int(2),description varchar(100));
创建的空表如下：
紧接着导入数据库驱动包：
打开eclipse，新建Java工程JDBC01，然后在根目录下新建一个文件夹libs：
然后复制之前下载的驱动包mysql-connector-java-5.1.33-bin.jar，粘贴到libs目录下，然后到了最关键的一步：将该Java包添加到工程的Build path中，操作如下图：
如果生效之后，就会多出一个文件出来：（下图中的箭头处）
2、实现插入操作：
步骤如下：
注：这个步骤是通俗的用法，可以当做模板来用。我们来举个例子。
在工程文件中新建一个java类，作为主程序：
JdbcTest.java完整版代码如下：（注释很详细）
1 package com.vae.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.SQLException; 6 import java.sql.Statement; 7 8 public class JdbcTest { 9 10 /**11 * @param args12 */13 14 //数据库连接地址15 private final static String URL = "jdbc:mysql://localhost:3306/mydb_2";16 //用户名17 public final static String USERNAME = "root";18 //密码19 public final static String PASSWORD = "smyh";20 //加载的驱动程序类（这个类就在我们导入的jar包中）21 public final static String DRIVER = "com.mysql.jdbc.Driver";22 23 public static void main(String[] args) {24 // TODO Auto-generated method stub25 insert();26 } 27 28 29 //方法：插入数据30 public static void insert(){31 try {32 //1、加载数据库驱动程序33 Class.forName(DRIVER);34 35 //2、获取数据库连接36 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);37 38 //3、构造SQL语句（插入具体的数据）39 String sql = "insert into person(name,age,description)values(‘生命壹号‘,22,‘学到哪里，我的博客就写到哪里‘)";40 41 //4、构造一个Statement实例(用来发送SQL语句的载体)42 Statement state = connection.createStatement();43 44 //5、执行SQL语句（其实是向数据库中发送sql语句）45 state.executeUpdate(sql);46 47 //6、关闭连接(释放资源)48 state.close();49 connection.close();50 51 System.out.println("insert success");52 53 54 } catch (ClassNotFoundException e) {55 e.printStackTrace();56 } catch (SQLException e) {57 e.printStackTrace();58 }59 60 } 61 62 }注意程序在导包时，导入的是下面的这些包：
代码解释：
15行的url代表连接接数据库的地址。命名格式统一如下：url = "jdbc:mysql://ip地址:端口号/数据库名字"。如果是本机的话，IP地址可以写成localhost。
17行、19行：指的是数据库的用户名和密码。如果输入错误，会报错如下：
21行：我们所加载的驱动程序类的名字是：com.mysql.jdbc.Driver，其实它就指的就是jar包中的com.mysql/jdbc/Driver.class文件。
程序运行成功后，后台会输出：
我们再去数据库看一下，发现数据真的填充进去了：
终于实现了Java代码与数据库之间的联系，任务完成。
3、实现更新操作：
和上面的插入操作相比，只是sql语句不一样而已（因为插入数据和更新数据其实都是更新嘛）
步骤如下：
更新操作的方法如下：（代码解释请参照上面的代码就懂了）
1 //方法：更新数据 2 public static void update(){ 3 try { 4 Class.forName(DRIVER); 5 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 6 String sql = "update person set age=24 where id=1"; 7 Statement state = connection.createStatement(); 8 state.executeUpdate(sql); 9 state.close();10 connection.close();11 System.out.println("update success");12 } catch (ClassNotFoundException e) {13 e.printStackTrace();14 } catch (SQLException e) {15 e.printStackTrace();16 }17 }核心代码是第6行，我们将之前的22岁改为24岁。程序运行后，数据库里也会对应的进行更新。
4、实现删除操作
同样的道理，和上面的插入操作相比，只是sql语句不一样而已（因为插入数据、更新数据、删除数据其实都是更新嘛）
删除操作的方法如下：
1 //方法：删除操作 2 public static void delete(){ 3 try { 4 Class.forName(DRIVER); 5 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 6 String sql = "delete from person where id=1"; 7 Statement state = connection.createStatement(); 8 state.executeUpdate(sql); 9 state.close();10 connection.close();11 System.out.println("delete success");12 } catch (ClassNotFoundException e) {13 e.printStackTrace();14 } catch (SQLException e) {15 e.printStackTrace();16 }17 }核心代码是第06行和第08行。
5、代码优化（写成工具类）：将字段换成变量
我们上面的增删该的操作都是直接在sql里面放入具体的参数，但是有可能这种参数是外面传进来的，所以一种更方便的写法是把参数换成变量，我们以插入操作为例：
1 //方法：插入数据(代码优化) 2 public static void insert2(){ 3 String name = "生命贰号"; 4 int age = 22; 5 String description = "哈哈，我是优化之后的代码哦"; 6 try { 7 Class.forName(DRIVER); 8 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 9 //拼接SQL语句10 String sql = "insert into person(name,age,description)values(‘"+name+"‘,"+age+",‘"+description+"‘)"; //注意拼接的格式11 Statement state = connection.createStatement();12 state.executeUpdate(sql);13 state.close();14 connection.close();15 System.out.println("success.");16 17 18 } catch (ClassNotFoundException e) {19 e.printStackTrace();20 } catch (SQLException e) {21 e.printStackTrace();22 }23 24 }核心代码是第10行，这里的sql语句是以变量的形式出现的，符合工具类的特性，注意它拼接的格式哦~~~来把它拆开再仔细瞧一瞧：
String sql = "insert into person(name,age,description)values(‘ "+name+" ‘, "+age+", ‘ "+description+" ‘)";
运行之后，效果如下：
其实这种拼接的方式很不好：既麻烦又不安全。数据库的查询操作以及详细解释将在下篇文章中学习到，加油！！！
哦，对了，最后再贴一下上方所有代码的完整版：
1 package com.vae.jdbc; 2 3 import java.sql.Connection; 4 import java.sql.DriverManager; 5 import java.sql.SQLException; 6 import java.sql.Statement; 7 8 public class JdbcTest { 9 10 /** 11 * @param args 12 */ 13 14 //数据库连接地址 15 private final static String URL = "jdbc:mysql://localhost:3306/mydb_2"; 16 //用户名 17 public final static String USERNAME = "root"; 18 //密码 19 public final static String PASSWORD = "smyh"; 20 //加载的驱动程序类（这个类就在我们导入的jar包中） 21 public final static String DRIVER = "com.mysql.jdbc.Driver"; 22 23 public static void main(String[] args) { 24 // TODO Auto-generated method stub 25 insert(); 26 //update(); 27 //delete(); 28 //insert2(); 29 } 30 31 32 //方法：插入数据 33 public static void insert(){ 34 try { 35 //1、加载数据库驱动程序 36 Class.forName(DRIVER); 37 38 //2、获取数据库连接 39 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 40 41 //3、构造SQL语句（插入具体的数据） 42 String sql = "insert into person(name,age,description)values(‘生命壹号‘,22,‘学到哪里，我的博客就写到哪里‘)"; 43 44 //4、构造一个Statement实例(用来发送SQL语句的载体) 45 Statement state = connection.createStatement(); 46 47 //5、执行SQL语句（其实是向数据库中发送sql语句） 48 state.executeUpdate(sql); 49 50 //6、关闭连接(释放资源) 51 state.close(); 52 connection.close(); 53 54 System.out.println("insert success"); 55 56 57 } catch (ClassNotFoundException e) { 58 e.printStackTrace(); 59 } catch (SQLException e) { 60 e.printStackTrace(); 61 } 62 63 } 64 65 66 //方法：插入数据(代码优化) 67 public static void insert2(){ 68 String name = "生命贰号"; 69 int age = 22; 70 String description = "哈哈，我是优化之后的代码哦"; 71 try { 72 Class.forName(DRIVER); 73 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 74 //拼接SQL语句 75 String sql = "insert into person(name,age,description)values(‘"+name+"‘,"+age+",‘"+description+"‘)"; //注意拼接的格式 76 Statement state = connection.createStatement(); 77 state.executeUpdate(sql); 78 state.close(); 79 connection.close(); 80 System.out.println("success."); 81 82 83 } catch (ClassNotFoundException e) { 84 e.printStackTrace(); 85 } catch (SQLException e) { 86 e.printStackTrace(); 87 } 88 89 } 90 91 92 //方法：更新数据 93 public static void update(){ 94 try { 95 Class.forName(DRIVER); 96 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD); 97 String sql = "update person set age=24 where id=1"; 98 Statement state = connection.createStatement(); 99 state.executeUpdate(sql);100 state.close();101 connection.close();102 System.out.println("update success");103 } catch (ClassNotFoundException e) {104 e.printStackTrace();105 } catch (SQLException e) {106 e.printStackTrace();107 }108 }109 110 111 //方法：删除操作112 public static void delete(){113 try {114 Class.forName(DRIVER);115 Connection connection = DriverManager.getConnection(URL, USERNAME, PASSWORD);116 String sql = "delete from person where id=1";117 Statement state = connection.createStatement();118 state.executeUpdate(sql);119 state.close();120 connection.close();121 System.out.println("delete success");122 } catch (ClassNotFoundException e) {123 e.printStackTrace();124 } catch (SQLException e) {125 e.printStackTrace();126 }127 } 128 129 }JDBC增删改数据库的操作
标签：
小编还为您整理了以下内容，可能对您也有帮助：
JDBC连接数据库的步骤都有哪些？
1、首先我们通过数据库可视化工具navicate for mysql，新建一个数据库，名字叫test新建一张表。
2、添加id，name字段，点击【保存】，设置表名称为user。
3、最终数据库及表创建成功。
4、然后我们添加一条数据。
5、下载java mysql connector驱动，通过maven添加依赖即可。
如何使用jdbc对sql server中的表增删改查
简单地说，就是用于执行SQL语句的一类Java API，通过JDBC使得我们可以直接使用Java编程来对关系数据库进行操作。通过封装，可以使开发人员使用纯Java API完成SQL的执行。
一、准备工作（一）：MySQL安装配置和基础学习
使用JDBC操作数据库之前，首先你需要有一个数据库。这里提供了3个链接供读者自学，如果曾有过SQL语言的使用经历（包括在学校中的课堂学习），前两个链接足以上手。
1.安装和配置：mysql安装图解 mysql图文安装教程(详细说明)
2.基本操作：21分钟 MySQL 入门教程
3.简易命令查询 ：一千行MySQL学习笔记
建议边看入门教程，边练习，在练习insert、update、select、delete等基本操作的同时，将后面要用的表建好。
下图是我接下来用于演示的数据库的表。
二、准备工作（二）：下载数据库对应的jar包并导入
使用JDBC需要在工程中导入对应的jar包。数据库与JDBC包的对应关系可以参考各种数据库对应的jar包、驱动类名和URL格式。在Eclipse下的导入方法：
在工程的图标上右击，选择”Properties”，在”Java Bulid Path”中选择”Add External JARs…”，选择下载并解压后获得的jar包。
如果对MySQL进行操作，这时下面的import就不会报错了：
import com.mysql.jdbc.Connection;import com.mysql.jdbc.PreparedStatement;
除此以外，还需要JDBC的包，直接import即可。
import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;
三、JDBC基本操作
为了简单起见，与数据库相关的操作、命令、参数都被硬编码了。有兴趣的读者可以对这些进行探索，降低数据与操作的耦合性。
先看具体代码并实践，本文第五部分对用到的API稍作了研究。
下面的所有方法和数据成员都在public class JDBCOperation内部。
(1)定义记录的类（可选）
这样做主要是为了便于操作和接口定义，是非必须的。
static class Student { private String Id; private String Name; private String Sex; private String Age; Student(String Name, String Sex, String Age) { this.Id = null; //default this.Name = Name; this.Sex = Sex; this.Age = Age; } public String getId() { return Id; } public void setId(String Id) { this.Id = Id; } public String getName() { return Name; } public void setName(String Name) { this.Name = Name; } public String getSex() { return Sex; } public void setSex(String Sex) { this.Sex = Sex; } public String getAge() { return Age; } public void setage(String Age) { this.Age = Age; }}
(2)连接的获取
在操作前必须先获取与数据库的连接。
driver、url的格式同样可以参考各种数据库对应的jar包、驱动类名和URL格式。
private static Connection getConn() { String driver = "com.mysql.jdbc.Driver"; String url = "jdbc:mysql://localhost:3306/samp_db"; String username = "root"; String password = ""; Connection conn = null; try { Class.forName(driver); //classLoader,加载对应驱动 conn = (Connection) DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn;}
(3)insert
private static int insert(Student student) { Connection conn = getConn(); int i = 0; String sql = "insert into students (Name,Sex,Age) values(?,?,?)"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); pstmt.setString(1, student.getName()); pstmt.setString(2, student.getSex()); pstmt.setString(3, student.getAge()); i = pstmt.executeUpdate(); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
(4)update
private static int update(Student student) { Connection conn = getConn(); int i = 0; String sql = "update students set Age=‘" + student.getAge() + "‘ where Name=‘" + student.getName() + "‘"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println("resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
(5)select
以select * from XXX为例。
private static Integer getAll() { Connection conn = getConn(); String sql = "select * from students"; PreparedStatement pstmt; try { pstmt = (PreparedStatement)conn.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); int col = rs.getMetaData().getColumnCount();
System.out.println("============================"); while (rs.next()) { for (int i = 1; i <= col; i++) { System.out.print(rs.getString(i) + ""); if ((i == 2) && (rs.getString(i).length() < 8)) { System.out.print(""); } } System.out.println(""); } System.out.println("============================"); } catch (SQLException e) { e.printStackTrace(); } return null;}
(6)delete
private static int delete(String name) { Connection conn = getConn(); int i = 0; String sql = "delete from students where Name=‘" + name + "‘"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println("resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
四、测试
在测试前，需要在系统中打开对应数据库的服务。MySQL在Windows下的启动命令为
net start mysql
测试代码
public static void main(String args[]) { JDBCOperation.getAll(); JDBCOperation.insert(new Student("Achilles", "Male", "14")); JDBCOperation.getAll(); JDBCOperation.update(new Student("Bean", "", "7")); JDBCOperation.delete("Achilles"); JDBCOperation.getAll();}
Eclipse中的输出
============================1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ========================================================1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 7 Achilles Male 14 ============================resutl: 1resutl: 1============================1 Ender male 8 2 Bean male 7 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ============================
五、代码分析
在上述对数据库进行增删改查的过程中，可以发现其共性部分，即通用的流程：
(1)创建Connection对象、SQL查询命令字符串；
(2)对Connection对象传入SQL查询命令，获得PreparedStatement对象；
(3)对PreparedStatement对象执行executeUpdate()或executeQurey()获得结果；
(4)先后关闭PreparedStatement对象和Connection对象。
可见，使用JDBC时，最常打交道的是Connection、PreparedStatement这两个类，以及select中的ResultSet类。查阅Java API手册可以了解其具体的意义和方法。
下面引用的Java API的资料出自http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/index.html。
Connection
java.sql
接口 Connection
所有超级接口：Wrapperpublic interface Connectionextends Wrapper
与特定数据库的连接（会话）。在连接上下文中执行 SQL 语句并返回结果。
Connection 对象的数据库能够提供描述其表、所支持的 SQL 语法、存储过程、此连接功能等等的信息。此信息是使用 getMetaData 方法获得的。
PreparedStatemnt
java.sql
接口 PreparedStatement
所有超级接口：Statement, Wrapper所有已知子接口：CallableStatementpublic interface PreparedStatementextends Statement
表示预编译的 SQL 语句的对象。
SQL 语句被预编译并存储在 PreparedStatement 对象中。然后可以使用此对象多次高效地执行该语句。
常用方法
boolean execute()
在此 PreparedStatement 对象中执行 SQL 语句，该语句可以是任何种类的 SQL 语句。
ResultSet executeQuery()
在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。
int executeUpdate()
在此 PreparedStatement 对象中执行 SQL 语句，该语句必须是一个 SQL 数据操作语言（Data Manipulation Language，DML）语句，比如 INSERT、UPDATE 或 DELETE 语句；或者是无返回内容的 SQL 语句，比如 DDL 语句。
ResultSet
java.sql
接口 ResultSet
所有超级接口：Wrapper所有已知子接口：CachedRowSet, FilteredRowSet, JdbcRowSet, JoinRowSet, RowSet, SyncResolver, WebRowSetpublic interface ResultSetextends Wrapper
表示数据库结果集的数据表，通常通过执行查询数据库的语句生成。
六、思考问题
1.每次SQL操作都需要建立和关闭连接，这势必会消耗大量的资源开销，如何避免？
分析：可以采用连接池，对连接进行统一维护，不必每次都建立和关闭。事实上这是很多对JDBC进行封装的工具所采用的。
2.Java代码中，传入的数据格式与数据库定义不同怎么办？如把Java的String对象赋值给数据库的tinyint属性。
分析：在执行SQL语句时，数据库会尝试进行转换。根据我的实验，如果用内容为纯字母的String对象传入tinyint的age属性时，会被转化成0。具体转化规则应该和数据库有关。
通过JDBC进行简单的增删改查（以MySQL为例）
标签：pen 数据 get root 问题 sql语句 npe let arch
如何使用jdbc对sql server中的表增删改查
简单地说，就是用于执行SQL语句的一类Java API，通过JDBC使得我们可以直接使用Java编程来对关系数据库进行操作。通过封装，可以使开发人员使用纯Java API完成SQL的执行。
一、准备工作（一）：MySQL安装配置和基础学习
使用JDBC操作数据库之前，首先你需要有一个数据库。这里提供了3个链接供读者自学，如果曾有过SQL语言的使用经历（包括在学校中的课堂学习），前两个链接足以上手。
1.安装和配置：mysql安装图解 mysql图文安装教程(详细说明)
2.基本操作：21分钟 MySQL 入门教程
3.简易命令查询 ：一千行MySQL学习笔记
建议边看入门教程，边练习，在练习insert、update、select、delete等基本操作的同时，将后面要用的表建好。
下图是我接下来用于演示的数据库的表。
二、准备工作（二）：下载数据库对应的jar包并导入
使用JDBC需要在工程中导入对应的jar包。数据库与JDBC包的对应关系可以参考各种数据库对应的jar包、驱动类名和URL格式。在Eclipse下的导入方法：
在工程的图标上右击，选择”Properties”，在”Java Bulid Path”中选择”Add External JARs…”，选择下载并解压后获得的jar包。
如果对MySQL进行操作，这时下面的import就不会报错了：
import com.mysql.jdbc.Connection;import com.mysql.jdbc.PreparedStatement;
除此以外，还需要JDBC的包，直接import即可。
import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;
三、JDBC基本操作
为了简单起见，与数据库相关的操作、命令、参数都被硬编码了。有兴趣的读者可以对这些进行探索，降低数据与操作的耦合性。
先看具体代码并实践，本文第五部分对用到的API稍作了研究。
下面的所有方法和数据成员都在public class JDBCOperation内部。
(1)定义记录的类（可选）
这样做主要是为了便于操作和接口定义，是非必须的。
static class Student { private String Id; private String Name; private String Sex; private String Age; Student(String Name, String Sex, String Age) { this.Id = null; //default this.Name = Name; this.Sex = Sex; this.Age = Age; } public String getId() { return Id; } public void setId(String Id) { this.Id = Id; } public String getName() { return Name; } public void setName(String Name) { this.Name = Name; } public String getSex() { return Sex; } public void setSex(String Sex) { this.Sex = Sex; } public String getAge() { return Age; } public void setage(String Age) { this.Age = Age; }}
(2)连接的获取
在操作前必须先获取与数据库的连接。
driver、url的格式同样可以参考各种数据库对应的jar包、驱动类名和URL格式。
private static Connection getConn() { String driver = "com.mysql.jdbc.Driver"; String url = "jdbc:mysql://localhost:3306/samp_db"; String username = "root"; String password = ""; Connection conn = null; try { Class.forName(driver); //classLoader,加载对应驱动 conn = (Connection) DriverManager.getConnection(url, username, password); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn;}
(3)insert
private static int insert(Student student) { Connection conn = getConn(); int i = 0; String sql = "insert into students (Name,Sex,Age) values(?,?,?)"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); pstmt.setString(1, student.getName()); pstmt.setString(2, student.getSex()); pstmt.setString(3, student.getAge()); i = pstmt.executeUpdate(); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
(4)update
private static int update(Student student) { Connection conn = getConn(); int i = 0; String sql = "update students set Age=‘" + student.getAge() + "‘ where Name=‘" + student.getName() + "‘"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println("resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
(5)select
以select * from XXX为例。
private static Integer getAll() { Connection conn = getConn(); String sql = "select * from students"; PreparedStatement pstmt; try { pstmt = (PreparedStatement)conn.prepareStatement(sql); ResultSet rs = pstmt.executeQuery(); int col = rs.getMetaData().getColumnCount();
System.out.println("============================"); while (rs.next()) { for (int i = 1; i <= col; i++) { System.out.print(rs.getString(i) + ""); if ((i == 2) && (rs.getString(i).length() < 8)) { System.out.print(""); } } System.out.println(""); } System.out.println("============================"); } catch (SQLException e) { e.printStackTrace(); } return null;}
(6)delete
private static int delete(String name) { Connection conn = getConn(); int i = 0; String sql = "delete from students where Name=‘" + name + "‘"; PreparedStatement pstmt; try { pstmt = (PreparedStatement) conn.prepareStatement(sql); i = pstmt.executeUpdate(); System.out.println("resutl: " + i); pstmt.close(); conn.close(); } catch (SQLException e) { e.printStackTrace(); } return i;}
四、测试
在测试前，需要在系统中打开对应数据库的服务。MySQL在Windows下的启动命令为
net start mysql
测试代码
public static void main(String args[]) { JDBCOperation.getAll(); JDBCOperation.insert(new Student("Achilles", "Male", "14")); JDBCOperation.getAll(); JDBCOperation.update(new Student("Bean", "", "7")); JDBCOperation.delete("Achilles"); JDBCOperation.getAll();}
Eclipse中的输出
============================1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ========================================================1 Ender male 8 2 Bean male 6 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 7 Achilles Male 14 ============================resutl: 1resutl: 1============================1 Ender male 8 2 Bean male 7 3 Petra fema 9 4 Peter male 9 5 _Graff male 40 6 GOD fema 255 ============================
五、代码分析
在上述对数据库进行增删改查的过程中，可以发现其共性部分，即通用的流程：
(1)创建Connection对象、SQL查询命令字符串；
(2)对Connection对象传入SQL查询命令，获得PreparedStatement对象；
(3)对PreparedStatement对象执行executeUpdate()或executeQurey()获得结果；
(4)先后关闭PreparedStatement对象和Connection对象。
可见，使用JDBC时，最常打交道的是Connection、PreparedStatement这两个类，以及select中的ResultSet类。查阅Java API手册可以了解其具体的意义和方法。
下面引用的Java API的资料出自http://download.oracle.com/technetwork/java/javase/6/docs/zh/api/index.html。
Connection
java.sql
接口 Connection
所有超级接口：Wrapperpublic interface Connectionextends Wrapper
与特定数据库的连接（会话）。在连接上下文中执行 SQL 语句并返回结果。
Connection 对象的数据库能够提供描述其表、所支持的 SQL 语法、存储过程、此连接功能等等的信息。此信息是使用 getMetaData 方法获得的。
PreparedStatemnt
java.sql
接口 PreparedStatement
所有超级接口：Statement, Wrapper所有已知子接口：CallableStatementpublic interface PreparedStatementextends Statement
表示预编译的 SQL 语句的对象。
SQL 语句被预编译并存储在 PreparedStatement 对象中。然后可以使用此对象多次高效地执行该语句。
常用方法
boolean execute()
在此 PreparedStatement 对象中执行 SQL 语句，该语句可以是任何种类的 SQL 语句。
ResultSet executeQuery()
在此 PreparedStatement 对象中执行 SQL 查询，并返回该查询生成的 ResultSet 对象。
int executeUpdate()
在此 PreparedStatement 对象中执行 SQL 语句，该语句必须是一个 SQL 数据操作语言（Data Manipulation Language，DML）语句，比如 INSERT、UPDATE 或 DELETE 语句；或者是无返回内容的 SQL 语句，比如 DDL 语句。
ResultSet
java.sql
接口 ResultSet
所有超级接口：Wrapper所有已知子接口：CachedRowSet, FilteredRowSet, JdbcRowSet, JoinRowSet, RowSet, SyncResolver, WebRowSetpublic interface ResultSetextends Wrapper
表示数据库结果集的数据表，通常通过执行查询数据库的语句生成。
六、思考问题
1.每次SQL操作都需要建立和关闭连接，这势必会消耗大量的资源开销，如何避免？
分析：可以采用连接池，对连接进行统一维护，不必每次都建立和关闭。事实上这是很多对JDBC进行封装的工具所采用的。
2.Java代码中，传入的数据格式与数据库定义不同怎么办？如把Java的String对象赋值给数据库的tinyint属性。
分析：在执行SQL语句时，数据库会尝试进行转换。根据我的实验，如果用内容为纯字母的String对象传入tinyint的age属性时，会被转化成0。具体转化规则应该和数据库有关。
通过JDBC进行简单的增删改查（以MySQL为例）
标签：pen 数据 get root 问题 sql语句 npe let arch
JavaJDBC连接Oracle实现对数据库增删改变做存储过程调用。 怎么做啊？ 代码是什么啊？
代码都太大了都是一个工程的。15M,
说下思路，写4个class,一个用来画主界面，一个用来处理逻辑操作，一个用来增加，修改界面，一个用来处理增加，修改逻辑。
主界面类用3个panle，北，中，南，上面放查询控件，查询按钮，中间放table,下面放其他按钮。
将主界面类作为逻辑处理操作类的一个属性。让他能访问到主界面类中相应的控件。写上对于的控件事件出来就可以了。
编写一个java程序，通过jdbc访问数据库实现对数据库的插入，删除，修改和查询操作
我刚写了一个只有插入的，望采纳
import java.sql.*;
import java.util.*;
public class TestPre {
public static void main(String[] args) {
int i=0,deptno=0;//i只做while循环使用，deptno是表dept2中的一个属性，类型是int
String dname=null,loc=null;//dname和loc也是表dept2的属性，类型是String
Scanner s=new Scanner(System.in);
System.out.println("请输入3个参数");
while(i<3){
try{
deptno=s.nextInt();
i++;
dname=s.next();
i++;
loc=s.next();
i++;
}catch(InputMismatchException e){
System.out.println("输入的类型不符,退出");
System.exit(-1);
}
}
Connection conn=null;
PreparedStatement pstmt=null;
try {
Class.forName("com.mysql.jdbc.Driver");
conn = DriverManager.getConnection("jdbc:mysql://localhost/mydata?"+ "user=root&password=root");
pstmt=conn.prepareStatement("insert into dept2 values(?,?,?)");
pstmt.setInt(1, deptno);
pstmt.setString(2, dname);
pstmt.setString(3, loc);
pstmt.executeUpdate();
System.out.println("插入完成");
} catch (ClassNotFoundException e) {
System.out.println("连接数据库不成功，程序退出");
System.exit(-1);
} catch (SQLException e) {
System.out.println("连接数据库不成功，程序退出");
System.exit(-1);
}
finally{
try{
if(pstmt!=null){
pstmt.close();
pstmt=null;
}
if(conn!=null){
conn.close();
conn=null;
}
}catch(SQLException e){
e.printStackTrace();
}
}
}
}