java jdbc操作数据库通用代码
1.准备工作
1》
新建一个配置文件，名为jdbc.properties将其放入src中
2》在项目中导入jdbc驱动，注意连接不同的数据库，所用到的驱动是不一样的，这些在网上都能找到
具体导入jar的方法，请参照http://blog.csdn.net/mazhaojuan/article/details/21403717
2、代码
1 import java.io.InputStream;2 import java.sql.Connection;
3 import java.sql.DriverManager;
4 import java.sql.ResultSet;
5 import java.sql.SQLException;
6 import java.sql.Statement;
7 import java.util.Properties;
8
9 public class Main {
10 public static void main(String[] args) {
11 DBUtil dbUtil = new DBUtil();
12 dbUtil.R("select * from table");
13 }
14 }
15
16 class DBUtil{
17 /**
18 * 得到数据库连接
19 * @return
20 * @throws Exception
21 */
22 public Connection getConnection() throws Exception{
23 //1.创建配置文件并得到对象输入流
24 InputStream is = this.getClass().getClassLoader().getResourceAsStream("jdbc.properties");
25 //2.创建propetities
26 Properties jdbc = new Properties();
27 jdbc.load(is);
28 //3. 通过key-value 的方式得到对应的值
29 String driver = jdbc.getProperty("driver");
30 String url = jdbc.getProperty("url");
31 String user = jdbc.getProperty("user");
32 String password = jdbc.getProperty("password");
33 //4.加载运行时类对象
34 Class.forName(driver);
35 //5通过DriverManager得到连接
36 Connection connection = DriverManager.getConnection(url,user,password);
37 return connection;
38
39 }
40 /**
41 * 释放资源的方法
42 * @param connection
43 * @param statement
44 * @param resultSet
45 */
46 public void release(Connection connection,Statement statement,ResultSet resultSet){
47 try {
48 if(resultSet!=null){
49 resultSet.close();
50 }
51 } catch (SQLException e) {
52 e.printStackTrace();
53 }
54 try {
55 if(statement!=null){
56 statement.close();
57 }
58 } catch (SQLException e) {
59 e.printStackTrace();
60 }
61 try {
62 if(connection!=null){
63 connection.close();
64 }
65 } catch (SQLException e) {
66 e.printStackTrace();
67 }
68
69 }
70 /**
71 * 查询数据库的方法
72 * @param sql 字符串，要执行的sql语句 如果其中有变量的话，就用 ‘"+变量+"’
73 */
74 public void R(String sql){
75 Connection connection = null;
76 Statement statement = null;
77 ResultSet resultSet = null;
78 try {
79 connection = getConnection();
80 statement = connection.createStatement();
81 resultSet = statement.executeQuery(sql);
82 while(resultSet.next()!=false){
83 //这里可以执行一些其他的操作
84 System.out.println(resultSet.getString(1));
85 }
86 } catch (Exception e) {
87 e.printStackTrace();
88 }finally {
89 release(connection, statement, resultSet);
90 }
91 }
92 /**
93 * 数据库记录增删改的方法
94 * @param sql 字符串，要执行的sql语句 如果其中有变量的话，就用 ‘"+变量+"’
95 */
96 public void CUD(String sql){
97 Connection connection = null;
98 Statement statement = null;
99 int result = 0;
100 try {
101 connection = getConnection();
102 statement = connection.createStatement();
103 result = statement.executeUpdate(sql);
104
105 //这里可以根据返回结果(影响记录的条数) 进行判断，该语句是否执行成功
106 System.out.println(result);
107 } catch (Exception e) {
108 e.printStackTrace();
109 }finally {
110 release(connection, statement, null);
111 }
112 }
113
114 }
3.预处理，其中上面的连接数据库及释放资源的方法不动
代码如下：
1 import java.io.InputStream;2 import java.sql.Connection;
3 import java.sql.DatabaseMetaData;
4 import java.sql.DriverManager;
5 import java.sql.PreparedStatement;
6 import java.sql.ResultSet;
7 import java.sql.ResultSetMetaData;
8 import java.sql.SQLException;
9 import java.sql.Statement;
10 import java.util.Properties;
11
12 public class Main {
13 public static void main(String[] args) {
14
15 }
16 }
17
18 class DBUtil{
19 /**
20 * 得到数据库连接
21 * @return
22 * @throws Exception
23 */
24 public Connection getConnection() throws Exception{
25 //1.创建配置文件并得到对象输入流
26 InputStream is = this.getClass().getClassLoader().getResourceAsStream("jdbc.properties.txt");
27 //2.创建propetities
28 Properties jdbc = new Properties();
29 jdbc.load(is);
30 //3. 通过key-value 的方式得到对应的值
31 String driver = jdbc.getProperty("driver");
32 String url = jdbc.getProperty("url");
33 String user = jdbc.getProperty("user");
34 String password = jdbc.getProperty("password");
35 //4.加载运行时类对象
36 Class.forName(driver);
37 //5通过DriverManager得到连接
38 Connection connection = DriverManager.getConnection(url,user,password);
39 return connection;
40
41 }
42 /**
43 * 释放资源的方法
44 * @param connection
45 * @param statement
46 * @param resultSet
47 */
48 public void release(Connection connection,Statement statement,ResultSet resultSet){
49 try {
50 if(resultSet!=null){
51 resultSet.close();
52 }
53 } catch (SQLException e) {
54 e.printStackTrace();
55 }
56 try {
57 if(statement!=null){
58 statement.close();
59 }
60 } catch (Exception e) {
61 // TODO: handle exception
62 }
63 try{
64 if(connection!=null){
65 connection.close();
66 }
67 } catch (SQLException e) {
68 e.printStackTrace();
69 }
70
71 }
72 /**
73 * 查询数据库的方法
74 * @param sql 字符串，要执行的sql语句 如果其中有变量的话，就用 ‘"+变量+"’
75 */
76 public void R(String sql, Object ...args){
77 Connection connection = null;
78 PreparedStatement preparedStatement = null;
79 ResultSet resultSet = null;
80 try {
81 connection = getConnection();
82 preparedStatement = connection.prepareStatement(sql);
83 for (int i = 0; i < args.length; i++) {
84 preparedStatement.setObject(i+1, args[i]);
85 }
86 resultSet = preparedStatement.executeQuery();
87 ResultSetMetaData resultSetMetaData = resultSet.getMetaData();
88 int columnCount = resultSetMetaData.getColumnCount();
89 while(resultSet.next()!=false){
90 //这里可以执行一些其他的操作
91 for (int i = 1; i <= columnCount; i++) {
92 System.out.println(resultSet.getString(i));
93 }
94 }
95 } catch (Exception e) {
96 e.printStackTrace();
97 }finally {
98 release(connection, preparedStatement, resultSet);
99 }
100 }
101 /**
102 * 数据库记录增删改的方法
103 * @param sql 字符串，要执行的sql语句 如果其中有变量的话，就用 ‘"+变量+"’
104 */
105 public void CUD(String sql, Object ...args){
106 Connection connection = null;
107 PreparedStatement preparedStatement = null;
108 int result = 0;
109 try {
110 connection = getConnection();
111 preparedStatement = connection.prepareStatement(sql);
112 for (int i = 0; i < args.length; i++) {
113 preparedStatement.setObject(i+1, args[i]);
114 }
115 result = preparedStatement.executeUpdate();
116 //这里可以根据返回结果(影响记录的条数)进行判断，该语句是否执行成功
117 System.out.println(result);
118 } catch (Exception e) {
119 e.printStackTrace();
120 }finally {
121 release(connection, preparedStatement, null);
122 }
123 }
124
125 }
在预处理代码第87行使用了元数据获取集合中的列的数量 有关数据库 元数据，请参考文档上的相关接口：
DatabaseMetaData
ResultSetMetaData
注：本文为原创，如需转载请注明出处：http://www.cnblogs.com/zhuchenglin/p/7919803.html
以上是 java jdbc操作数据库通用代码 的全部内容， 来源链接： utcz.com/z/392748.html
