ADD file via upload

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<Types> queryAllUsers(String sqlstr)
+    {
+        ArrayList<Types> 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;
+        }
+        
+    }
+}