该用户从未签到
|
- package s2.jsp.zhangixao.dao;4 g$ \5 O1 ~, Y2 P7 z7 T( p
- # g" \5 f w {0 e F
- import java.sql.Connection;3 T7 S, X5 _* z5 E- z8 g% d7 [% I
- import java.sql.DriverManager;) ]0 |3 Q p7 r* _) `
- import java.sql.PreparedStatement;
1 U0 D+ T+ \$ \0 t - import java.sql.ResultSet;
) b3 s5 y6 ]9 a; f - import java.sql.SQLException;
& ?+ u5 [, {0 J# I; | - /**
) @& k0 |, v" D: U U - * 访问数据库6 J! A5 h$ Z; x1 }. {; u9 I- j# u1 O
- * @author Administrator: @& |( I! M( ~$ ^7 E/ @, u
- *6 `/ T5 l& u: w1 R' a2 t1 C
- *// J8 I( [% g2 @& ~/ I [
- public class MessageBase {; u) F' w" @" e% e/ w* m9 `# r
- private static final String DRIVER="com.microsoft.sqlserver.jdbc.SQLServerDriver";6 v8 r% y5 o6 S$ d; W
- private static final String URL="jdbc:sqlserver://localhost:1433;DataBaseName=messageboard";
% g, x' E: w+ H" Y: z - private static final String DBNAME="sa";
7 a% |9 J$ \3 ]' v V# V - private static final String DBPASS="";
8 V& m' \) K+ A3 m0 A - /**
9 @2 s1 w! v4 ~9 L - * 连接数据库: o# d* j/ w. b9 v9 H. q! s
- * @return
9 c# p8 T5 [ u8 w5 L2 g - */2 z+ Z% K; f7 s
- public static Connection getConnection(){
1 a+ N6 F% g( J% {: F( H+ w q - Connection con=null;
$ H; H7 |; |! ?0 X - try {
5 R9 D( @" _3 D- U$ l - Class.forName(DRIVER);
7 e( m" u' J& h' [! y - con=DriverManager.getConnection(URL,DBNAME,DBPASS);
+ a7 j0 x, N7 U2 Y5 [" b# E0 m - } catch (ClassNotFoundException e) {
3 Y1 @8 d9 |' R/ p - System.out.println("加载驱动出现异常");
# M# H8 }. c% h3 O$ b1 y - e.printStackTrace();
* h0 |1 I- v M - } catch (SQLException e) {" J) [; |4 H o" n. s" p
- System.out.println("数据库连接出现异常");
; v- s; f. C' { - e.printStackTrace();& b" @. N* }! W3 r4 Y0 [' m) n& \! i
- }' |+ ~* I) | E1 r& O0 K
- return con;
6 G9 @$ V& S5 ]- i7 M - }
) W0 r3 y$ w9 C/ h0 h2 } - /**% `9 U& t' M0 K' [ A
- * 关闭数据库
0 n. ]" w4 l$ m" S - * @param con
) P; I, `! X; y - * @param past. S1 ^; G* Q% b
- * @param rs( {3 y1 t+ \6 t- c: X" b7 O. H. O
- */! ^3 k1 d" ^+ R- y
- public static void CloseAll(Connection con,PreparedStatement past,ResultSet rs){/ S9 i7 s. p: S1 P$ W1 o% C" [4 w
-
* b8 v* o. d1 t- [$ H3 Q: B: b$ N - if (rs!=null) {
! h, G0 `% n# U5 T2 g - try {
4 k9 v4 W0 ]( p% u' x% ~ - rs.close();( C3 j! _: x8 [
- } catch (SQLException e) {- O9 A" C& L( _, t; x+ i1 ]0 ~" w" ^
- System.out.println("rs 关闭出现异常");
, S' S2 \$ L/ R5 b# z. X4 F - e.printStackTrace();
. m0 n& z9 P; x4 ~% |$ f4 B' [ - }9 S& E$ ^# v; x2 g
- }
+ e8 V8 N7 j9 v" @ - if (past!=null) {7 e( `2 q( \" S" ^0 j
- try {: @0 o: u* ^) s) ~6 N
- past.close();7 n. z/ E5 Z( i# c8 F0 Z" I
- } catch (SQLException e) {
% p6 t7 T) A" X. k# J+ e9 Y - System.out.println("past 关闭出现异常");
/ J8 h) P" I' B! Z - e.printStackTrace();. T7 Q/ w) _) S5 _4 K0 J# i# A
- }! t0 m# B2 ^& J" I' h0 \5 N
- }8 G d& C" I" k* u5 Q0 T* M
- if (con!=null) {
- E' W3 V. F( [ - try {- [9 n( {$ L/ }- r
- con.close();
8 Q$ i0 `0 M6 U& k! v4 V - } catch (SQLException e) {
# r) L4 F0 y4 q6 |( b - System.out.println("con 关闭出现异常");. q; F/ k( q0 c% s [3 K- r( t
- e.printStackTrace();
; t4 Y6 H9 V7 Z1 E/ L - }
0 c$ F# P2 R0 H, v9 d - }7 O+ \ f6 p" ~9 w
- }
. C2 H2 k, A9 i7 b3 o+ Y- i - /**( N. ~! |' K3 O ]( _9 y
- * 执行数据的增删改操作
8 ]& Y9 j( T: [5 _: N; C - * @param sql
7 Z2 E% s5 C3 I - * @param getValues
" ]5 y0 ]9 |' D! Y: G( P - * @return
, J' K% {0 {: T0 f/ f0 H - */6 H% M3 s; [# E" Q6 q/ D! q
- public static int executeUpdate(String sql,String[]getValues){
. i* ]: T$ Y) ~( q: N - int t=0;: h! @% h: a% b% x0 G& M
- PreparedStatement past=null;
; c' d; c+ W0 a1 z1 s/ E/ s - Connection con=null;
: S4 S ?! T( K K0 X+ z2 X - try {- \8 O9 h- N( c/ u
- con=getConnection();
2 v5 n+ w) P0 _" ~: |6 d - past=con.prepareStatement(sql);8 b+ m V4 g+ T/ F- W" `, T+ C8 \
- if (getValues!=null) {
9 }" U! F4 G0 P& @) ` - for (int i = 0; i < getValues.length; i++) {
) V1 [2 S9 L$ J/ H - past.setString(i+1,getValues[i]);
, r& t# V5 k' [6 O: E# s4 `, V- @ - }
1 r& Q# c1 c1 t) _7 T% F* |, G& G - }4 H( e6 I/ Z) B+ Q. ?/ |. V% Q* I2 j
- t=past.executeUpdate();
$ L% Y6 ^5 Z2 L7 y5 T6 N - } catch (SQLException e) {: n i5 }) i- I& h8 j' Q* t
- System.out.println("执行数据库操作出现异常");
1 P$ B- _4 \$ b. k - e.printStackTrace();
) W) |7 }8 O9 p/ Y! Z -
& E% ?1 p0 h- H, x2 } A9 f - }finally{8 M6 t$ r5 \6 G$ }
- MessageBase.CloseAll(con, past, null);' V$ Q# G S o( Z% z+ e4 X" X( Z
- }
8 f: I/ ^6 j9 R1 ` - return t;2 q; O$ F5 Z. s& v' l( R
- }
' |* \% Y1 Z6 _, q" P# h; O - /**9 S8 T l# y3 w# x
- * 测试连接
' ~& F# A) f2 V5 ~$ f. ~; p - * @param args; f8 H8 [9 L* I+ |
- */ z1 Y4 [! n" l1 q/ L* p
- public static void main(String[] args) {! S( g4 a# ^; Z( k/ S
- Connection conn=getConnection();8 t" T* A& n( P8 b4 L8 l" f
- if(conn!=null){5 A4 n9 V% |6 t+ ~
- System.out.println("连接成功");
/ F8 m+ b |- t - }else{
1 k) E; C1 v, z( {3 K - System.out.println("连接失败"); I1 Z# `9 w4 z
- }& Z& h9 {0 U' r' U9 h# V
- }
$ t8 s9 U) K( U - }
9 x; t* w( g. v" S9 l
复制代码- package s2.jsp.zhangixao.dao;
! O" }. p. U, u% y* b: d7 F: F
/ C5 W5 H/ v4 X: ], X- import java.util.List;3 K; M" b2 M2 ^6 T" B7 l' ^
& o5 G$ T9 v% r9 e* X- import s2.jsp.zhangxiao.entity.Message;: J K2 l, D6 _0 P' A \" r
- , p& ]& ] W2 ?5 _2 @3 l
- /**/ Y% ^7 s5 k8 f
- * 留言板接口
3 z# G# c' A$ `5 D - * @author Administrator7 L! w5 x/ p) G+ p$ E% W; _
- *
, u5 |% \( P/ o M - */
5 l( X! f( }! s0 ] K - public interface MessageDao {: w$ B. d: m! x. ?7 F
- //添加留言
/ I! f/ m" f$ y5 z7 g( }5 p0 a - public int addMessage(Message message);
- U9 ]/ y+ k9 ? - //查询全部留言$ O* c0 H9 f9 ]% q
- public List selcetMessage();
: W1 I9 D7 R. f+ Z; N4 x7 W - }
* q- Q8 [2 T) T b6 D
复制代码 项目源码下载地址: 4 g: k: P/ \( n, r
8 l2 c& ~: I/ F& f& N; w* l2 Y; l$ j& v% g% S& c" w o8 R
- f( z/ {2 k6 z: a1 C0 l( y( m* Z/ m/ u- Z
|
|