JDBC(Java DataBase Connectivity)是使用 Java 存取数据库系统的标准解决方案，它将不同数据库间各自差异API与标准 SQL语句分开看待，实现数据库无关的 Java操作接口。
JDBC程序访问数据库的步骤
步骤一：加载JDBC驱动程序:Class.forName("com.mysql.jdbc.Driver");Oracle10g：oracle.jdbc.driver.OracleDriver;MySQL5：com.mysql.jdbc.Driver;SQLServer2005：com.microsoft.sqlserver.jdbc.SQLServerDriver
步骤二：提供连接参数:URL,USERNAME, PASSWORD:不同数据库产品的连接URL不同
Oracle10g：jdbc:oracle:thin:@主机名:端口:数据库SID
jdbc:oracle:thin:@localhost:1521:ORCL
MySQL5：jdbc:mysql://主机名:端口/数据库名
jdbc:mysql://localhost:3306/test
SQLServer2005：jdbc:sqlserver://主机名:端口:DatabaseName=库名
jdbc:sqlserver://localhost:1433:DatabaseName=BookDB
步骤三：建立一个数据库的连接:connection=DriverManager.getConnection(URL,USERNAME, PASSWORD);
步骤四：创建一个statement:preparedStatement=connection.prepareStatement(sql);
步骤五：执行SQL语句:result=preparedStatement.executeUpdate();
步骤六：处理结果:flag=result>0?true:false;return flag;
步骤七：关闭JDBC对象:if(resultSet!=null){resultSet.close();}if(preparedStatement!=null){preparedStatement.close();}if(connection!=null){connection.close();}
1 package com.jdbc.dbUtils;
2
3 import java.lang.reflect.Field;
4 import java.sql.Connection;
5 import java.sql.DriverManager;
6 import java.sql.PreparedStatement;
7 import java.sql.ResultSet;
8 import java.sql.ResultSetMetaData;
9 import java.sql.SQLException;
10 import java.util.ArrayList;
11 import java.util.HashMap;
12 import java.util.List;
13 import java.util.Map;
14
15 import com.jdbc.dbUtils.dormain.UserInfo;
16
17
18
19 public class JDBCutils {
20
21 private final String USERNAME="root";
22 private final String PASSWORD="admin";
23 private final String DRIVER="com.mysql.jdbc.Driver";
24 private final String URL="jdbc:mysql://localhost:3306/mydb";
25
26 private Connection connection;
27 private PreparedStatement preparedStatement;
28 private ResultSet resultSet;
29
30 public JDBCutils() {
31 try {
32 Class.forName(DRIVER);//注册驱动
33 System.out.println("成功注册驱动");
34
35 } catch (Exception e) {
36 // TODO: handle exception
37 }
38 }
39
40 public Connection getConnection(){
41 try {
42 connection=DriverManager.getConnection(URL,USERNAME, PASSWORD);
43 } catch (Exception e) {
44 // TODO: handle exception
45 e.printStackTrace();
46 }
47 return connection;
48 }
49 //增删改
50 public boolean updateByPreparedStatement(String sql,List<Object> params)throws SQLException {
51 boolean flag=false;
52 int result=-1;//执行增删改操作的时候所影响的行数
53 int index=1;//占位符的第一个位置
54 preparedStatement=connection.prepareStatement(sql);
55 if(params!=null&&!params.isEmpty()){
56 for (int i = 0; i < params.size(); i++) {
57 preparedStatement.setObject(index++, params.get(i));
58 }
59 }
60 result=preparedStatement.executeUpdate();
61 flag=result>0?true:false;
62 return flag;
63 }
64 //查询 返回单条记录
65 public Map<String,Object> findSimpleResult(String sql,List<Object> params) throws SQLException{
66 Map<String,Object> map=new HashMap<String,Object>();
67 int index=1;//占位符的第一个位置
68 preparedStatement=connection.prepareStatement(sql);
69 if(params!=null&&!params.isEmpty()){
70 for (int i = 0; i < params.size(); i++) {
71 preparedStatement.setObject(index++, params.get(i));
72 }
73 }
74 resultSet=preparedStatement.executeQuery();
75 ResultSetMetaData resultSetMetaData=resultSet.getMetaData();
76 int col_len=resultSetMetaData.getColumnCount();//得到数据库表的列
77 while(resultSet.next()){
78 for (int i = 0; i < col_len; i++) {
79 String col_name=resultSetMetaData.getColumnName(i+1);
80 Object col_val=resultSet.getObject(col_name);
81 if(col_val==null){
82 col_val="";
83 }
84 map.put(col_name,col_val);
85 }
86 }
87 return map;
88
89 }
90 //查询 返回多条记录
91 public List<Map<String,Object>> findMultiResult(String sql,List<Object> params) throws SQLException{
92 List<Map<String,Object>> list=new ArrayList<Map<String,Object>>();
93 int index=1;//占位符的第一个位置
94 preparedStatement=connection.prepareStatement(sql);
95 if(params!=null&&!params.isEmpty()){
96 for (int i = 0; i < params.size(); i++) {
97 preparedStatement.setObject(index++, params.get(i));
98 }
99 }
100 resultSet=preparedStatement.executeQuery();
101 ResultSetMetaData resultSetMetaData=resultSet.getMetaData();
102 int col_len=resultSetMetaData.getColumnCount();//得到数据库表的列名
103 while(resultSet.next()){
104 Map<String,Object>map=new HashMap<String,Object>();
105 for (int i = 0; i < col_len; i++) {
106 String col_name=resultSetMetaData.getColumnName(i+1);
107 Object col_val=resultSet.getObject(col_name);
108 if(col_val==null){
109 col_val="";
110 }
111 map.put(col_name,col_val);
112 }
113 list.add(map);
114 }
115 return list;
116
117 }
118 //jdbc的封装也可以采用反射机制
119 public <T> T findSimpReflectResult(String sql,List<Object> params,Class<T> cls) throws Exception{
120 T resObj=null;
121 int index=1;//占位符的第一个位置
122 preparedStatement=connection.prepareStatement(sql);
123 if(params!=null&&!params.isEmpty()){
124 for (int i = 0; i < params.size(); i++) {
125 preparedStatement.setObject(index++, params.get(i));
126 }
127 }
128 resultSet=preparedStatement.executeQuery();
129 ResultSetMetaData resultSetMetaData=resultSet.getMetaData();
130 int col_len=resultSetMetaData.getColumnCount();//得到数据库表的列名
131 while(resultSet.next()){
132 resObj=cls.newInstance();//通过反射机制创建实例
133 for (int i = 0; i < col_len; i++) {
134 String col_name=resultSetMetaData.getColumnName(i+1);
135 Object col_val=resultSet.getObject(col_name);
136 if(col_val==null){
137 col_val="";
138 }
139 Field field=cls.getDeclaredField(col_name);
140 field.setAccessible(true);//打开访问javabean的私有权限
141 field.set(resObj, col_val);
142 }
143 }
144 return resObj;
145 }
146 public <T> List<T> findMultiReflectResult(String sql,List<Object> params,Class<T> cls) throws Exception{
147 List<T> list=new ArrayList<T>();
148 int index=1;//占位符的第一个位置
149 preparedStatement=connection.prepareStatement(sql);
150 if(params!=null&&!params.isEmpty()){
151 for (int i = 0; i < params.size(); i++) {
152 preparedStatement.setObject(index++, params.get(i));
153 }
154 }
155 resultSet=preparedStatement.executeQuery();
156 ResultSetMetaData resultSetMetaData=resultSet.getMetaData();
157 int col_len=resultSetMetaData.getColumnCount();//得到数据库表的列名
158 while(resultSet.next()){
159 T resObj=cls.newInstance();//通过反射机制创建实例
160 for (int i = 0; i < col_len; i++) {
161 String col_name=resultSetMetaData.getColumnName(i+1);
162 Object col_val=resultSet.getObject(col_name);
163 if(col_val==null){
164 col_val="";
165 }
166 Field field=cls.getDeclaredField(col_name);
167 field.setAccessible(true);//打开访问javabean的私有权限
168 field.set(resObj, col_val);
169 }
170 list.add(resObj);
171 }
172 return list;
173 }
174 public void releaseConnection() throws SQLException{
175 if(resultSet!=null){
176 resultSet.close();
177 }
178 if(preparedStatement!=null){
179 preparedStatement.close();
180 }
181 if(connection!=null){
182 connection.close();
183 }
184 }
185 public static void main(String[] args) throws Exception {
186 // TODO Auto-generated method stub
187 JDBCutils jdbc=new JDBCutils();
188 jdbc.getConnection();
189 List<Object> params=new ArrayList<Object>();
190
191 /* params.add("fjf");
192 params.add("123");
193 params.add("fanjingfang");
194 String sql="insert into userinfo(username,password,realname)values(?,?,?)";
195 boolean flag=jdbc.updateByPreparedStatement(sql, params);
196 System.out.println(flag);
197 params.add(1);
198 String sql="select * from userinfo where id=?";
199 Map<String,Object> m=jdbc.findSimpleResult(sql, params);
200 System.out.println(m);*/
201
202 /*String sql2="select * from userinfo ";
203 List<Map<String,Object>> list=jdbc.findMultiResult(sql2, null);
204 System.out.println(list);*/
205
206 /* params.add(1);
207 String sql3="select * from userinfo where id=? ";
208 UserInfo u=jdbc.findSimpReflectResult(sql3, params,UserInfo.class);
209 System.out.println(u);*/
210
211 String sql4="select * from userinfo ";
212 List<UserInfo> list=jdbc.findMultiReflectResult(sql4, null,UserInfo.class);
213 System.out.println(list);
214 }
215
216 }
时间： 2024-11-24 21:41:20