該demo實(shí)現(xiàn)的功能有：

1.用戶注冊(cè)：

注冊(cè)時(shí)輸入兩次密碼，若兩次輸入不一致，則注冊(cè)失敗，需要重新輸入。若用戶名被注冊(cè)過，則提示用戶重新輸入用戶名；

2.用戶登錄：

需要驗(yàn)證數(shù)據(jù)庫中是否有對(duì)應(yīng)的用戶名和密碼，若密碼輸錯(cuò)三次，則終止用戶的登錄操作；

3.文件上傳：

從本地上傳文件到文件數(shù)據(jù)庫中

4.文件下載：

從數(shù)據(jù)庫中下載文件到本地

5.文件更新：

根據(jù)id可更新數(shù)據(jù)庫中的文件名

6.文件刪除：

根據(jù)id刪除數(shù)據(jù)庫中某一個(gè)文件

7.看數(shù)據(jù)庫所有文件;

8.查看文件（根據(jù)用戶名）;

9.查看文件（根據(jù)文件id）;

代碼分為如下四個(gè)部分：Entity,Service,Socket,Util

實(shí)體包Entity中主要存放用戶實(shí)體和文件實(shí)體

User類：

package Entity; import java.io.Serializable; /** * 用戶類 * @author Administrator * */ public class User implements Serializable{ //屬性 private int id; private String username; private String password; //方法 //構(gòu)造方法 public User(){ super(); } public User(String username, String password) { super(); this.username = username; this.password = password; } //Getter,Setter方法 public int getId() { return id; } public void setId(int id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } }

文件類：

package Entity; import java.io.Serializable; import java.util.Arrays; /** * 文件實(shí)體類 * @author Administrator * */ public class FileEntity implements Serializable { //屬性 private int fid; private String username;// 用戶名，方便查看某個(gè)用戶上傳的文件 public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } private String fname; private byte[] fcontent; //方法 //構(gòu)造方法 public FileEntity(){ super(); } public FileEntity(String username,String fname, byte[] fcontent) { super(); this.username=username; this.fname = fname; this.fcontent = fcontent; } //Getter,Setter方法 public int getFid() { return fid; } public void setFid(int fid) { this.fid = fid; } public String getFname() { return fname; } public void setFname(String fname) { this.fname = fname; } public byte[] getFcontent() { return fcontent; } public void setFcontent(byte[] fcontent) { this.fcontent = fcontent; } @Override public String toString() { return "FileEntity [fid=" + fid + ", username=" + username + ", fname=" + fname + "]"; } }

Service包:包括用戶服務(wù)類和文件服務(wù)類

UserSevice類包括了與用戶相關(guān)的注冊(cè)和登錄功能相關(guān)的方法

package Service; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import Util.DBUtil; import Entity.User; public class UserService { private Connection conn=null; private PreparedStatement pstmt=null; private ResultSet rs=null; /** * 登陸 */ public boolean login(User user){ String sql="select * from tb_user where username=? and password=?"; try{ conn=DBUtil.getConnection(); pstmt=conn.prepareStatement(sql); pstmt.setString(1, user.getUsername()); pstmt.setString(2, user.getPassword()); rs=pstmt.executeQuery(); if(rs.next()){ return true; } }catch(SQLException e){ e.printStackTrace(); }finally{ DBUtil.CloseAll(rs, pstmt, conn); } return false; } /** * 注冊(cè) */ public void register(User user){ String sql="insert into tb_user(username,password)value(?,?)"; try { conn=DBUtil.getConnection(); pstmt=conn.prepareStatement(sql); pstmt.setString(1, user.getUsername()); pstmt.setString(2, user.getPassword()); pstmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); }finally{ DBUtil.CloseAll(rs, pstmt, conn); } } /** * 查找tb_user,查看用戶是否已經(jīng)注冊(cè)過 */ public boolean queryByUsername(String username){ conn=DBUtil.getConnection(); String sql="select * from tb_user where username=?"; try { pstmt=conn.prepareStatement(sql); pstmt.setString(1, username); rs=pstmt.executeQuery(); if(rs.next()){ //說明已經(jīng)被注冊(cè)過,要求重新填寫用戶名 return true; } } catch (SQLException e) { e.printStackTrace(); } return false; } }

文件服務(wù)類：

package Service; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import java.util.Scanner; import Entity.FileEntity; import Util.DBUtil; public class FileService { private Connection conn=null; private PreparedStatement pstmt=null; private ResultSet rs=null; /** * 保存文件到數(shù)據(jù)庫，類似用戶的注冊(cè)功能 * @param fileEntity */