
package com.ww.service; |
import java.lang.reflect.Array; |
import java.sql.Connection; |
import java.sql.ResultSet; |
import java.sql.SQLException; |
import java.util.ArrayList; |
import com.mysql.jdbc.PreparedStatement; |
import com.ww.db.DBHelper; |
import com.ww.entity.Score; |
import com.ww.entity.Student; |
public class SysService { |
DBHelper dbHelper=new DBHelper(); |
//查询所有学生的编号,姓名和分数,并返回 |
public ArrayList<Score> getAllInfo(){ |
String sql="select * from stu s,sco sc where s.stu_id=sc.stu_id"; |
Connection connection=dbHelper.getConnection(); |
ArrayList<Score> scores=new ArrayList<Score>(); |
try { |
PreparedStatement psd=(PreparedStatement)connection.prepareStatement(sql); |
ResultSet resultSet=psd.executeQuery(); |
|
while (resultSet.next()) { |
Student student=new Student(); |
Score score=new Score(); |
student.setId(resultSet.getInt("stu_id")); |
student.setName(resultSet.getString("stu_name")); |
|
score.setId(resultSet.getInt("sco_id")); |
score.setScos(resultSet.getInt("emg_sco")); |
score.setStudent(student); |
scores.add(score); |
} |
} catch (SQLException e) { |
// TODO Auto-generated catch block |
e.printStackTrace(); |
} |
return scores; |
} |
//添加 |
public boolean addInfo(String name,int a){ |
String sql1="insert into stu VALUES(null,?)"; |
String sql2="insert into sco VALUES(null,(select MAX(stu_id) from stu),?)"; |
Connection connection=dbHelper.getConnection(); |
try { |
//执行向主表添加数据 |
PreparedStatement psd1=(PreparedStatement)connection.prepareStatement(sql1); |
//执行向从表中添加数据 |
PreparedStatement psd2=(PreparedStatement)connection.prepareStatement(sql2); |
psd1.setString(1, name); |
int b=psd1.executeUpdate(); |
if (b>0) { |
//向主表中完成添加 |
psd2.setInt(1, a); |
int s=psd2.executeUpdate(); |
if (s>0) { |
return true; |
} |
} |
} catch (SQLException e) { |
// TODO Auto-generated catch block |
e.printStackTrace(); |
} |
return false; |
} |
|
|
//修改 |
public boolean update(int id,String name,int sc) { |
String sql="update stu s,sco sc set s.stu_name=?,sc.emg_sco=? where s.stu_id=sc.stu_id and s.stu_id=?"; |
Connection connection=dbHelper.getConnection(); |
try { |
PreparedStatement psd=(PreparedStatement)connection.prepareStatement(sql); |
psd.setString(1, name); |
psd.setInt(2, sc); |
psd.setInt(3, id); |
if(psd.executeUpdate()>=2){ |
return true; |
} |
} catch (SQLException e) { |
// TODO Auto-generated catch block |
e.printStackTrace(); |
} |
return false; |
} |
|
|
|
|
//删除 |
public boolean deleteInfo(int id){ |
String sql="delete from sco where stu_id=?"; |
Connection connection=dbHelper.getConnection(); |
try { |
PreparedStatement psd=(PreparedStatement)connection.prepareStatement(sql); |
psd.setInt(1, id); |
if(psd.executeUpdate()>0){ |
return true; |
} |
} catch (SQLException e) { |
// TODO Auto-generated catch block |
e.printStackTrace(); |
} |
return false; |
} |
} |




中级程序员
by: 东城 发表于:2016-05-12 09:55:49 顶(0) | 踩(0) 回复
回复评论