当前位置:首页 » 编程语言 » java增删改查

java增删改查

发布时间: 2022-01-27 03:32:48

java用接口实现增删改查

// 定义接口 public interface SyUsersService {

/***新增用户*/
public void addSyUser(SyUsers syUsers);

/***根据用户名得到用的注册信息***/
public SyLeaguer isRightPasswordProtect(SyLeaguer syLeaguer);

/***更新用户的密码***/
public void updateSyUserPassword(SyUsers syUsers);

/***用户登录验证***/
public boolean checkSyUserLogin(SyUsers syUsers);
/**
* 更新用户状态 * @param loginName 登录名 * @param state 状态号 0/1
* @return 是否更新成功 true/flase
*/
public boolean updateSyUserState(String loginName,Integer state);
/**
* 分页查询用户信息
* @param pageNo 页号
* @param pageSize 页面大小
* @param hqlQueryRule 查询规则
* @return Page 分页查询对象
*/
public Page querySyUserPage(int pageNo,int pageSize,HqlQueryRule hqlQueryRule);

/**
* 更新用户密码
* @param loginName 登录名 * @param oldPassword 旧的密码
* @param newPassword 新的密码
*/
public void updateSyUserPassword(String loginName,String oldPassword,String newPassword);

/**
* 根据查询规则查询用户
* @see HqlQueryRule
* @param hqlQueryRule 查询规则
* @return 结果集列表 */
public List querySyUser(HqlQueryRule hqlQueryRule);

/**
* 根据登录名获取用户信息 * @param loginName
* @return
*/
public SyUsers getSyUserByLoginName(String loginName);

/**
* 根据登录名获取用户信息
* @param loginName
* @return
*/
public boolean isRepeatUser(String loginName);

/**
* 更新用户
* @param loginName
* @return
*/
public void updateSyUsers(SyUsers syUsers);
}
// 实现接口 public class SyUsersServiceImp extends
org.springframework.orm.hibernate3.support.HibernateDaoSupport
implements SyUsersService {

protected static final Log logger = LogFactory.getLog(SyUsersServiceImp.class); public SyUsersServiceImp() {}

/***用户注册添加用户***/
public void addSyUser(SyUsers syUsers) {
this.getHibernateTemplate().save(syUsers);
Set babySet=syUsers.getSyLeaguer().getSyLeaguerBabies();
if(babySet!=null&&babySet.size()>0){
SyLeaguerBaby baby=(SyLeaguerBaby)babySet.iterator().next();
this.getHibernateTemplate().save(baby);
}
}

/***用户登录***/
public boolean checkSyUserLogin(SyUsers syUsers){
String querysql = "FROM SyUsers WHERE loginName=:username and loginPassword=:password and state=:state and isEmp=:isemp";
Query query = this.getSession().createQuery(querySQL);
query.setString("username", syUsers.getLoginName());
query.setString("password", syUsers.getLoginPassword());
query.setInteger("state", 1);
query.setInteger("isemp", 0);
List list = (List)query.list();
return list.size()>0?true:false;
}

/***密码找回得到注册密保信息***/
public SyLeaguer isRightPasswordProtect(SyLeaguer syLeaguer){
String querySQL = "FROM SyLeaguer WHERE loginName=:loginname";
Query query = this.getSession().createQuery(querySQL);
query.setString("loginname", syLeaguer.getLoginName());
return (SyLeaguer)query.uniqueResult();
}

public void updateSyUserPassword(String loginName,String newPassword){

} public Page querySyUserPage(int pageNo, int pageSize,
HqlQueryRule hqlQueryRule) {
// TODO Auto-generated method stub
// Criteria c=this.getSession().createCriteria(SyUsers.class);
// for(int i=0;restrictList!=null&&i<restrictList.size();i++){
// c=c.add((Criterion) restrictList.get(i));
// }
// for(int i=0;orderList!=null&&i<orderList.size();i++){
// c=c.addOrder((Order) orderList.get(i));
// }
// c.setFirstResult((int)page.getStart());
// c.setMaxResults(page.getPageSize());
// List resultList=c.list();

//HqlQueryRule hqr=new HqlQueryRule();
//hqr.addEqual("id", new Integer(1234));
Page p = new Page();
Page page = null;
String queryPageHQL = "select new map( su.loginName as loginName, su.loginPassword as loginPassword,su.isEmp as isEmp) from SY_RES su where 1=1";
String countHQL = "select count(*) from SyUsers where 1=1 ";// 总记录数
queryPageHQL=queryPageHQL+hqlQueryRule.getHql();

Query query = this.getSession().createQuery(queryPageHQL);
List list = query.list();

PageTool pt=new PageTool(page);
page=pt.getHQLQueryPage(this.getSession(), queryPageHQL,countHQL, null);
return page;
} public boolean updateSyUserState(String loginName, Integer state) {
// TODO Auto-generated method stub
return false;
} public List querySyUser(HqlQueryRule hqlQueryRule) {
// TODO Auto-generated method stub
return null;
} public void updateSyUserPassword(String loginName, String oldPassword,
String newPassword) {
// TODO Auto-generated method stub

} public SyUsers getSyUserByLoginName(String loginName) {
return (SyUsers)this.getSession().get(SyUsers.class, loginName);
}

/***用户名是否重复***/
public boolean isRepeatUser(String loginName){
String querySQL = "FROM SyUsers WHERE loginName=:username";
Query query = this.getSession().createQuery(querySQL);
query.setString("username", loginName);
List list = (List)query.list();
return list.size()>0?true:false;
}

public void updateSyUserPassword(SyUsers syUsers){
this.getSession().update(syUsers);
}

public void updateSyUsers(SyUsers syUsers){
this.getSession().update(syUsers);
}
}
公司的项目的一段

㈡ java增删改查功能怎么实现

你所说的增删改查是数据库的命令操作。在Java编程中,在Java和数据库完成连接以后,可以调用数据库的select、delete、updata等命令。你也可以把相关的命令变成一个字符串对象,这样调用起来会更简单。

㈢ 用JAVA实现对txt文件文本增删改查

代码就是一种编译器认可的语言,通过在编译器里写代码,编译器就可以把代码翻译成机器码,也就是二进制码,二进制码是由0和1组成的,如:1的二进制码可以表示为:0001,3表示为:0011,二进制码机器(电脑)可以直接识别,代码则不行,需要翻译成机器码。

㈣ Java增删改查是个什么概念

有个表格记录数据 一行是一条记录 对应 java的一个对象

---------------------------------

编号 姓名 年龄

1 张三 21

2 李四 22

---------------------------------

publicclassPerson{
privateintid;//编号
privateStringname;
privateintage;

...
}
//利用jdbc等技术向表中,写入记录,删除记录,修改记录,查看记录就叫增删改查了

㈤ 如何使用java写一个增删改查的通用类,不需要连接数据库

importjava.util.LinkedList;

importjavax.swing.text.html.HTMLDocument.Iterator;

publicclassTestKnow{
publicstaticvoidmain(String[]args){
Students1=newStudent(1,"s1",15);
Students2=newStudent(2,"s2",15);
Students3=newStudent(3,"s3",15);
Gradeg=newGrade(1);
g.add(s1);g.add(s2);g.add(s3);//增
g.delete(s1);//删
Students4=newStudent(4,"s4",12);
g.change(s2,s4);//改
Studentss=g.check(3);//查
System.out.println(ss.name);
}

}
classStudent{
intnum;//学号
Stringname;
intage;
publicStudent(intnum,Stringname,intage){
this.num=num;
this.name=name;
this.age=age;
}
}
classGrade{
intgnum;
LinkedList<Student>grade;
publicGrade(intgnum){
this.gnum=gnum;
grade=newLinkedList<Student>();
}
publicvoidadd(Students){
grade.add(s);
}
publicStudentcheck(intn){
java.util.Iterator<Student>it=grade.iterator();
while(it.hasNext()){
Studenttemp=it.next();
if(temp.num==n)
returntemp;
}
returnnull;
}
publicvoiddelete(Students){
if(grade!=null)
if(check(s.num)!=null)
grade.remove(s);
else
System.out.println("没有此人");
else
System.out.println("班里没人");
}
publicvoidchange(Students1,Students2){
if(grade!=null)
if(check(s1.num)!=null)
{
grade.remove(s1);
grade.add(s2);
}
else
System.out.println("没有要替换的人");
else
System.out.println("班里没人");
}
}

㈥ java增删改查代码问题

首先你得确定你的数据库连接是通过什么形式连接的,hibernate还是原生态的jdbc 还是spring;
如果是只有hibernate,那么你得通过加载配置文件得到sessionFactory,然后得到session
如果spring,那么同样也需要注入sessionfactory到你的
如果是jdbc方式,那么你就按照原生态jdbc写法
总之,在你构造DAO时,得有数据源。这样才能操纵你的数据库

㈦ java MVC 实现增删改查

AddServlet类实现了servlet控制器的功能,但你这里只有一个add功能并不能体现控制器需要其他功能了就使用request对象获取请求资源路径针对不同的路径找到不同的Servelt实现控制器功能即MVC中的C;
packageservlet;

importjava.io.IOException;


importjavax.servlet.ServletException;
importjavax.servlet.http.HttpServlet;
importjavax.servlet.http.HttpServletRequest;
importjavax.servlet.http.HttpServletResponse;

{
protectedvoiddoGet(HttpServletRequestreq,HttpServletResponseresp)throwsServletException,IOException{
req.setCharacterEncoding("utf-8");
resp.setCharacterEncoding("utf-8");
Stringname=req.getParameter("name");
Stringdescription=req.getParameter("description");
Stringbaseprice=req.getParameter("baseprice");
Stringwriter=req.getParameter("writer");
Stringpublish=req.getParameter("publish");
Stringpages=req.getParameter("pages");
Stringimages=req.getParameter("images");
Stringstock=req.getParameter("stock");
Proctp=newProct();
ProctDaoDao=newProctDao();


p.setName(name);
p.setDescription(description);
p.setBaseprice(baseprice);
p.setWriter(writer);
p.setPublish(publish);
p.setPages(pages);
p.setImages(images);
p.setStock(stock);
intresult=0;
try{
result=Dao.save(p);
}catch(Exceptione){
e.printStackTrace();
}
resp.setContentType("text/html");
if(result==1){
resp.sendRedirect("ok.jsp");
}else{
resp.sendRedirect("error.jsp");
}

}
}
ProctDao类实现了使用对象想数据库中添加记录的功能;
实现了MVC中的M模型
packageservlet;

importjava.sql.Connection;
importjava.sql.PreparedStatement;

publicclassProctDao{
publicintsave(Proctp)throwsException{
Connectionconn=null;
PreparedStatementprep=null;
try{
conn=DBUtil.getConnection();
Stringsql="insertintoproctvalues(0,?,?,?,?,?,?,?,?)";
prep=conn.prepareStatement(sql);
prep.setObject(1,p.getName());
prep.setObject(2,p.getDescription());
prep.setObject(3,p.getBaseprice());
prep.setObject(4,p.getWriter());
prep.setObject(5,p.getPublish());
prep.setObject(6,p.getPages());
prep.setObject(7,p.getImages());
prep.setObject(8,p.getStock());
intnum=prep.executeUpdate();
returnnum;
}catch(Exceptione1){
e1.printStackTrace();
throwe1;
}finally{
DBUtil.close(conn);
}
}

}
Proct类根据数据库的字段声明类的属性根据表名命名类名;
packageservlet;

publicclassProct{
privateObjectname;
privateObjectdescription;
privateObjectbaseprice;
privateObjectwriter;
privateObjectpublish;
privateObjectpages;
privateObjectimages;
privateObjectstock;
publicObjectgetName(){
returnname;
}
publicvoidsetName(Objectname){
this.name=name;
}
publicObjectgetDescription(){
returndescription;
}
publicvoidsetDescription(Objectdescription){
this.description=description;
}
publicObjectgetBaseprice(){
returnbaseprice;
}
publicvoidsetBaseprice(Objectbaseprice){
this.baseprice=baseprice;
}
publicObjectgetWriter(){
returnwriter;
}
publicvoidsetWriter(Objectwriter){
this.writer=writer;
}
publicObjectgetPublish(){
returnpublish;
}
publicvoidsetPublish(Objectpublish){
this.publish=publish;
}
publicObjectgetPages(){
returnpages;
}
publicvoidsetPages(Objectpages){
this.pages=pages;
}
publicObjectgetImages(){
returnimages;
}
publicvoidsetImages(Objectimages){
this.images=images;
}
publicObjectgetStock(){
returnstock;
}
publicvoidsetStock(Objectstock){
this.stock=stock;
}

}
DBUtil类封装的是对数据库的连接:
packageservlet;

importjava.sql.Connection;
importjava.sql.DriverManager;
importjava.sql.SQLException;

/**
*JDBC工具类:
* 提供了获得连接,关闭连接的相关的方法。
*
*/
publicclassDBUtil{
privatestaticStringurl="jdbc:mysql://localhost:3306/ecport";
()throwsException{
Connectionconn=null;
try{
Class.forName("com.mysql.jdbc.Driver");
conn=DriverManager.
getConnection(url,"root","");
}catch(Exceptione){
e.printStackTrace();
throwe;
}
returnconn;
}
publicstaticvoidclose(Connectionconn){
if(conn!=null){
try{
conn.close();
}catch(SQLExceptione){
e.printStackTrace();
}
}
}

/**
*@paramargs
*@throwsException
*/
publicstaticvoidmain(String[]args)throwsException{
Connectionconn=
getConnection();
System.out.println(conn);
}

}
最后是MVC中的视图,实现的shiMVC中的V视图,在AddServlet中根据不同的结果受用重定向跳转到指定的页面中,表明是否添加成功。

成功页面:

<%@page pageEncoding="utf-8"

contentType="text/html;charset=utf-8" %>

<html>

<body>

<h3 style='color:red'>恭喜你,新增图书成功!!!</h3>

</body>

</html>

失败页面:

<%@page pageEncoding="utf-8"

contentType="text/html;charset=utf-8" %>

<html>新增失败</html>

㈧ java数据库中这样实现增删改查

提取单条记录
//import java.sql.*;
Connection con=null;
Statement stmt=null;
ResultSet %%6=null;
try {
Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
String url="jdbc:odbc:"+%%1;
con=DriverManager.getConnection(url,%%2,%%3);
stmt=con.createStatement();
stmt.executeUpdate(%%4);
%%6=stmt.executeQuery(%%5);
%%7
}catch(Exception e){
e.printStackTrace();
}finally{
try {
try {
stmt.close();
con.close();
} catch (SQLException e) {
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}

㈨ java io 简单实现对数据的增删改查

Java IO输入信息到文件中,再从文件中取出,就可以增。删。改。查了

㈩ 关于java 连接数据库实现增删改查的具体功能代码。

  1. 首先你得确定你的数据库连接是通过什么形式连接的,hibernate还是原生态的jdbc 还是spring;

    如果是只有hibernate,那么你得通过加载配置文件得到sessionFactory,然后得到session

    如果spring,那么同样也需要注入sessionfactory到你的

    如果是jdbc方式,那么你就按照原生态jdbc写法

    总之,在你构造DAO时,得有数据源。这样才能操纵你的数据库

  2. 如果搞懂了这些问题,那么你的第一个,第三个问题就迎刃而解了。至于第二问题,我没明白你什么意思!

热点内容
phpxml转换 发布:2024-11-16 05:47:10 浏览:955
内网服务器搭建什么公司做 发布:2024-11-16 05:36:24 浏览:594
如何利用map做本地缓存 发布:2024-11-16 05:34:37 浏览:539
w7恢复出厂设置密码是多少 发布:2024-11-16 05:23:49 浏览:791
方周编译器 发布:2024-11-16 05:23:12 浏览:660
数据库监控工具 发布:2024-11-16 05:23:07 浏览:958
存储器题型 发布:2024-11-16 05:23:06 浏览:86
怎么设置电脑配置信息 发布:2024-11-16 05:04:26 浏览:981
推荐系统php 发布:2024-11-16 05:03:42 浏览:12
加密mp3文件 发布:2024-11-16 04:43:04 浏览:843