该用户从未签到
|
- package s2.jsp.zhangxiao.dao;' U8 _: e4 A2 t. q
7 `) `0 o6 z: U: @ u/ v! a! x- import java.util.List;
) Z7 X `: h% S4 i0 n
/ K) ~! H% ~9 f' m* f( v2 {- import s2.jsp.zhangxiao.entity.Photo;1 O5 h% i0 f7 H' d/ j
* |2 @+ V8 L9 L* u! }$ J- /**, b/ B1 {" f- x3 x7 _6 O, b8 J/ o
- * 照片信息的操作所需要的接口
" u; z9 c2 b% @* L) A* L. b! e - * @author Administrator) Z7 S3 K$ M( S9 ^' Z. f! n- G
- *
3 N& V$ j# ], O) K) ~# C; D - */) l, Q! k6 ?" t/ M; t! S
- public interface PhotoInfo {
! D4 N$ r0 u D5 r- H( H - //增加照片信息
, ]. _( A1 ~9 @4 f, Z: ^ - public int photoInfoAdd(Photo photo);
) _' Q7 ?" f) w# ~* \, q - //查询所有照片信息
4 B/ ` p+ L% ^0 t7 c - public List photoListAll();# c/ j$ B# I+ }* r) w, [
- }
& Z9 ]( [2 _; l6 S f
复制代码- package s2.jsp.zhangxiao.dao;) j4 h% E4 S7 X0 ^1 w
- import java.sql.ResultSet;# d& x+ Z" K d' S& F# u
- import java.sql.PreparedStatement;$ ?! O0 z7 M9 G$ [) d$ J
- import java.sql.DriverManager;
, @7 i( h( v+ e0 w t- M - import java.sql.SQLException;
* U, y7 o! |9 Z7 [3 m% V* N - import java.sql.Connection;/ C" ^" h# p$ |
- 0 l6 }0 F) J" N3 W) t7 A+ o6 M
- & W1 D" C2 `0 j2 v3 F
- /**
6 N/ \; C; }: ]& X& A& A - * 连接数据库
$ K% V+ S. C5 K% h1 h1 D - * @author Administrator/ Y( U1 v6 f% a
- *
* I8 y" q- O; W7 k7 n - */
0 o: i$ K9 t& }/ d, B - public class PhotoInfoBase {
# u- D4 i8 A" { - //链接数据库 W4 A, T7 W" h/ Z" {$ X1 X
- private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";
& f1 B5 V5 \( j" G) d. [ - private static final String URL="jdbc:sqlserver://localhost:1433;DataBaseName=pictureDB";
4 S' D8 h8 m5 l/ z - private static final String DBNAME="sa";2 K: {- P/ c, D; s2 K; u; ]
- private static final String DBPASS="1234";8 F P8 y8 n0 }! Q' T
- /**
5 y2 Y6 V0 A- \- G4 R* j! E: K - * 打开数据库连接
8 r9 Z6 W9 n1 m( S; X - * @return8 Q( q0 U3 X8 V" c3 A' g, a
- */4 Y$ C* w; x p K2 G! U: R
- public static Connection GetConnection()4 q n) T; J1 ~: J5 Y2 T6 w
- {
8 r/ j c8 O! \5 y; Y( I/ E% [ [ -
@$ Z" S; N1 X( }% R% D9 H( f - Connection con=null;
I- N, A1 A# u9 [ - try {- r/ h0 Q" D& d0 W2 C* r1 u
- Class.forName(DRIVER);
4 Q2 E I3 Z: g+ g: e$ G - con=DriverManager.getConnection(URL, DBNAME, DBPASS);
! J# B+ T! [4 Y+ j1 K1 h. v F - } catch (ClassNotFoundException e) {
( I0 ` S. n3 e1 g - System.out.println("加载驱动出现异常");
. w* D" ^, p4 F0 x1 G9 F0 {6 }/ W - e.printStackTrace();
' B& g! L2 }6 {% h - } catch (SQLException e) {2 q/ N9 k! X( s- |# {8 c' W1 H
- System.out.println("数据库连接出现异常");
4 i4 c& J" R- J/ N( x! D" B$ a - e.printStackTrace();4 K2 F {* C' C$ a; U- R- L5 { c
- }
% d, w1 R. j4 S/ e - return con;
6 t, d) u# M- l* ]% d, a; h - , k( q' x$ |! Q8 L0 z8 D' L i
- }% s8 Z; S6 {7 e# s! Q
- /**; e: K9 D$ H/ z7 `
- * 关闭数据库% f7 }6 Q0 x; T+ d% h; n) O# g
- * @param con
1 f2 Q( F8 I5 T' j" d9 ] - * @param past% J9 C) x+ W$ G0 [: F! K0 @
- * @param res
5 Q! K& C0 ^# ` R ]* t - */
; D9 G( L. v$ E3 B& h- b0 j - public static void CloseAll(Connection con,PreparedStatement past,ResultSet rs)
; b9 d3 n; Z. j - {: Q" p# f, J9 i" b) C& T
- if (rs!=null) {
. f6 J [2 z# P: Y2 E/ G4 \: { - try {
% j9 M1 Z1 L5 L+ n - rs.close();8 U! J" U$ {: c
- } catch (SQLException e) {' v/ l& P% c% ~1 {% T
- System.out.println("rs 关闭出现异常");
3 p( u ^& R$ Z+ q& ?, u# B% v+ b6 d0 S2 p - e.printStackTrace();
' G3 q" _5 M% j e$ f - }
) I l" O: d+ Q4 ]4 j- r2 V( s: Q6 { - if (past!=null) {
3 y2 v5 j x! D; T9 y5 p# Z. Z2 {+ g' j - try {& G* ~9 i% j! [7 _7 d6 u( N
- past.close();2 I$ [7 e. o3 f
- } catch (SQLException e) {
: p) N" L3 h5 p: R: Y7 ]" h - System.out.println("past 关闭出现异常");
" T: X7 X* d/ J4 x2 y - e.printStackTrace();
+ a. T1 u8 N I7 I% e- {! s: C6 p - }: G6 ~: n8 o6 n1 O* {9 C
- }6 W* r; |8 s: b8 h) u1 @* ^+ w
- if (con!=null) {, S" z' `5 q6 _+ n$ D* B: Z/ b
- try {& l0 b0 }- a+ Y* S9 a
- con.close();
M3 @& W$ R# c; K z. W l - } catch (SQLException e) {
6 f4 L7 c1 [' k) ` - System.out.println("con 关闭出现异常");
" T& R5 D! s# [4 R% q - e.printStackTrace();
& V0 ^+ P+ `9 x3 \ - }! i% B4 l' Q/ i3 x; G
- }% g! a8 l; _/ r4 Z, ?5 v: g# ~% u
- }
' g6 Y8 D: b( O+ ` - }
' O* }" W5 w6 o$ B5 ?, O' M! R/ | - /**0 J! F" q" |0 |0 B l& @
- * 数据的增删改
4 y2 T" q, J1 T4 A - * @return
3 h: I+ ^. i' j6 v0 i0 g* t9 z9 A - */
/ Z8 s1 f2 j4 K* u! s( t - public static int ExecuteUpdate(String sql,String[] getValues)# ]3 z. W1 p7 i2 u5 |
- {3 G5 s! O K/ D7 G" d
- int i=0;
1 K- I+ E! d: T7 B - PreparedStatement past=null;& R& O3 L" P4 l7 Q1 P' W' Z. X
- Connection con=null;
, f m& @- }3 M - //连接数据库
" E& m/ D+ P4 e - con=GetConnection();' D' R; \: S2 V" [
- try {
6 b; Z+ B5 ~4 ^* s - past=con.prepareStatement(sql);
) ] D. F- ~' R. V' @ - if (getValues!=null) {2 p5 R8 q# j$ }! I; G) I2 F3 ~
- for (int j = 0; j < getValues.length; j++) {3 `& P1 R# ?6 x! `. r
- past.setString(j+1, getValues[j]);
) ^8 q! M4 B1 N) t. u2 ]; S! { - }
( d/ g7 M6 S+ G - }
/ E: s" m: x' A9 O- L* Y - i=past.executeUpdate();
4 ?2 ~0 s% B( C5 s - } catch (SQLException e) {9 G8 K2 e) N5 w7 E# v) h
- System.out.println("执行增删改语句发生异常");2 P% b* Z1 [; v- W% Q' L
- e.printStackTrace();
' J! l5 s6 k2 k; c1 ? - }finally{& ]9 B% M8 w- }% L9 h
- CloseAll(con,past,null);
1 J) e4 S7 A6 d# t" n5 q - }6 Z& g u9 d( D- A
- return i;
0 j. d( i& s8 h7 b, U -
( @4 w% c. ]' t# Q9 S - }# U$ B. B; C' T+ a8 ~
- /** ^# m9 T- u6 J; J
- * 测试数据库连接
5 X/ v- }% P, y8 Z0 l( F - * @param args
* E! d6 h: s- \( p - */
6 K0 p5 l0 d0 w& }; |* I4 |1 j - /**7 K r: k2 s3 A. n& F% k2 A
- * 测试连接
; X, c1 l8 Z. t2 L; m% g* \ - * @param args
/ P5 u2 D" P) q: t G9 J - */
0 Y5 C! y' D3 J& G1 `7 J - public static void main(String[] args) {
$ e" q6 p' M5 N+ L4 q - Connection conn=GetConnection();- E# p% B+ W; R6 H/ u2 K$ g+ ]4 V
- if(conn!=null){
7 Y) i6 p( e: Y3 H! {1 N - System.out.println("连接成功");3 a9 E l9 Q1 f) f
- }else{
3 p/ W3 e7 K* V& n - System.out.println("连接失败");+ x% R. u w1 f8 l" k+ x7 x+ Q1 M
- }
; S5 N; j. K1 m# q" `( t - }
( G, ~* n$ E7 D; h/ l, Q( c8 C/ f - : o3 C( s P/ T2 G) A
- } i/ ]( {& w- a
复制代码 源码下载地址: 点击下载 提取码 - g2 K5 {! s" ?) n2 Z
9 I4 l ^7 E1 h9 z9 O3 P! q9 \2 r( H! Y/ V" j+ s/ U3 f
|
|