From 2573fd407b75832a4f1d9bda6f22dab8e9a6d5f1 Mon Sep 17 00:00:00 2001 From: p10297854 <944423246@qq.com> Date: Fri, 9 Jul 2021 18:12:21 +0800 Subject: [PATCH] ADD file via upload --- back/src/com/Dao/Dao.java | 161 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 161 insertions(+) create mode 100644 back/src/com/Dao/Dao.java diff --git a/back/src/com/Dao/Dao.java b/back/src/com/Dao/Dao.java new file mode 100644 index 0000000..718de80 --- /dev/null +++ b/back/src/com/Dao/Dao.java @@ -0,0 +1,161 @@ +package com.Dao; + +import java.sql.Connection; + +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.ResultSetMetaData; +import java.sql.SQLException; +import java.sql.Statement; +import java.util.ArrayList; + +import com.domain.GetDBConnection; +import com.domain.SqlStr; +import com.domain.TypeFlag; +import com.domain.GetDBConnection; + +import com.domain.Types; +import com.domain.scoreInfo; + +import net.sf.json.JSONObject; +public class Dao { + Connection con = GetDBConnection.connectDB("musicMySQL","root","root"); + Statement sql; + ResultSet rs = null; + public boolean queryUsers(Object object,String typeflag,String sqlstr) + { + boolean flag=false; + ResultSet resultSet; + try { + PreparedStatement preparedStatement; + if(typeflag.equals(TypeFlag.types)) { + preparedStatement = con.prepareStatement(sqlstr); + Types type=new Types(); + type=(Types) object; + preparedStatement.setString(1,type.getUsername()); + preparedStatement.setString(2,type.getPassword()); + resultSet = preparedStatement.executeQuery(); + if(resultSet.next()) { + flag=true; + }else { + flag=false; + } + return flag; + }else if(typeflag.equals(TypeFlag.scores)) { + sql=con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY); + sql.execute("set @mycnt:=0;"); + preparedStatement = con.prepareStatement(sqlstr); + preparedStatement.setString(1, SqlStr.scoreinfo.getUsername()); + resultSet = preparedStatement.executeQuery(); + ResultSetMetaData metaData1 = resultSet.getMetaData(); + int count1 = metaData1.getColumnCount(); + String[] colName1 = new String[count1]; + for (int i = 1; i <= count1; i++) { + colName1[i - 1] = metaData1.getColumnName(i); + } + if(resultSet.next()) { + SqlStr.scoreinfo.setUsername(resultSet.getString("username")); + SqlStr.scoreinfo.setAvgscore(resultSet.getFloat("avg")); + SqlStr.scoreinfo.setMaxscore(resultSet.getFloat("max")); + SqlStr.scoreinfo.setRank(resultSet.getInt("rank")); + flag=true; + return flag; + } + } + + + } + catch (SQLException e) + { + e.printStackTrace(); + return flag; + } + return flag; + + } + public ArrayList queryAllUsers(String sqlstr) + { + ArrayList userlist = new ArrayList<>(); + try { + sql=con.createStatement(); + rs=sql.executeQuery(sqlstr); + while(rs.next()) { + Types type = new Types(); + type.setPassword(rs.getString("password")); + type.setUsername(rs.getString("username")); + userlist.add(type); + } + return userlist; + } + catch (SQLException e) + { + e.printStackTrace(); + } + return userlist; + + } + public boolean addUsers(Object object,String typeflag,String sqlstr) + { + try { + PreparedStatement preparedStatement = con.prepareStatement(sqlstr); + if(typeflag.equals(TypeFlag.types)) { + Types type=new Types(); + type=(Types) object; + preparedStatement.setString(1,type.getUsername()); + preparedStatement.setString(2,type.getPassword()); + }else if(typeflag.equals(TypeFlag.scores)) { + scoreInfo scoreinfo=new scoreInfo(); + scoreinfo=(scoreInfo) object; + preparedStatement.setString(1,scoreinfo.getUsername()); + preparedStatement.setFloat(2,scoreinfo.getScore()); + } + int ok=preparedStatement.executeUpdate(); + return preparedStatement.getUpdateCount() != 0; + } + catch (SQLException e) + { + e.printStackTrace(); + return false; + } + + } + public boolean deleteUsers(Object object,String typeflag,String sqlstr) + { + try { + PreparedStatement preparedStatement = con.prepareStatement(sqlstr); + if(typeflag.equals(TypeFlag.types)) { + Types type=new Types(); + type=(Types) object; + preparedStatement.setString(1,type.getUsername()); + } + preparedStatement.executeUpdate(); + return preparedStatement.getUpdateCount() != 0; + } + catch (SQLException e) + { + e.printStackTrace(); + return false; + } + + } + public boolean updateUsers(Object object,String typeflag,String sqlstr) + { + try { + PreparedStatement preparedStatement = con.prepareStatement(sqlstr); + if(typeflag.equals(TypeFlag.types)) { + Types type=new Types(); + type=(Types) object; + preparedStatement.setString(2,type.getUsername()); + preparedStatement.setString(1,type.getPassword()); + } + preparedStatement.executeUpdate(); + return preparedStatement.getUpdateCount() != 0; + } + catch (SQLException e) + { + e.printStackTrace(); + return false; + } + + } +}