mvc操作数据库
⑴ spring mvc可以连接数据库吗
spring mvc 可以连接数据库,用spring的spring template。简化数据库操作。
⑵ java的SpringMVC框架操作数据库,一定要建立对应的实体类吗,能不能通过直接嵌入sql命令方式操作数据库
springmvc只是视图层控制容器不能直接操作数据库,要通过持久层hibernate或者mybatis等框架对数据库操作。可以不用实体,使用jdbc直接查询数据库也行,查出来转换成json字符串
⑶ MVC中,Controller如何从数据库调用单个数据给一个变量
package com.kiwwor.qq.beans;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
* 数据库操作的JavaBean类,用于对数据库的查询与更新的实现;
* 该类默认的连接的数据库为本地数据库,连接数据库为"qq";
* 该类主要为用户一系列的数据操作提供底层服务。
* @author kiwwor
* @see UserBean
*/
public class Access {
//驱动程序类
private String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
//连接数据库url
private String connectionUrl="jdbc:sqlserver://localhost:1433;DatabaseName=qq";
//用户名
private String user = "qq";
//用户密码
private String password = "123258741";
//数据库连接对象
private Connection connection = null;
//数据库对象
private Statement statement = null;
//数据集对象
private ResultSet resultSet = null;
public String getDriver() {
return driver;
}
public void setDriver(String driver) {
this.driver = driver;
}
public String getConnectionUrl() {
return connectionUrl;
}
public void setConnectionUrl(String connectionUrl) {
this.connectionUrl = connectionUrl;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public Connection getConnection() {
return connection;
}
public void setConnection(Connection connection) {
this.connection = connection;
}
public Statement getStatement() {
return statement;
}
public void setStatement(Statement statement) {
this.statement = statement;
}
public ResultSet getResultSet() {
return resultSet;
}
public void setResultSet(ResultSet resultSet) {
this.resultSet = resultSet;
}
/**
* 获取一个连接对象,默认连接对象本地数据库qq。
* @return 连接是否成功
*/
public boolean createConnection() {
boolean b = false;
try {
Class.forName(driver);
connection = DriverManager.getConnection(connectionUrl, user, password);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 更新数据库
* @param sql 更新的sql语句
* @return 更新是否成功
*/
public boolean update(String sql) {
boolean b =false;
try {
statement = connection.createStatement();
statement.execute(sql);
b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 执行查询,将查询的结果集给resultmentSet。
* @param sql 查询的sql语句
*/
public void query(String sql) {
try {
statement = connection.createStatement();
resultSet = statement.executeQuery(sql);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 检测结果集是否为空
* @return true为存在记录
*/
public boolean next() {
boolean b = false;
try {
if (resultSet.next()) b = true;
} catch (Exception e) {
e.printStackTrace();
}
return b;
}
/**
* 获得结果集中当前行columnLabel的记录
* @param columnLabel
* @return 值记录
*/
public String getValue(String columnLabel) {
String value = null;
try {
if (resultSet != null) value = resultSet.getString(columnLabel);
} catch (Exception e) {
e.printStackTrace();
}
return value;
}
/**
* 关闭连接对象
*/
public void closeConnection() {
try {
if (connection != null) connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据库对象
*/
public void closeStatement() {
try {
if (statement != null) statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭结果集
*/
public void closeResultSet() {
try {
if (resultSet != null) resultSet.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
/**
* 关闭数据连接对象,数据库对象和数据结果集对象。
*/
public void closeAll() {
closeResultSet();
closeStatement();
closeConnection();
}
/**
* 测试该类函数。
* @param args
*/
public static void main(String[] args) {
Access db = new Access();
if (db.createConnection()) {
System.out.println("测试数据库连接成功.");
String sql = "select id from [user]";
db.query(sql);
int i = 1;
while (db.next()) {
String s = db.getValue("id");
System.out.println("查询用户" + i + ": " + s);
i++;
}
db.closeResultSet();
db.closeStatement();
db.closeConnection();
}
}
}
第二个:
package com.kiwwor.qq.beans;
/**
* 这是一个对用户的数据查询和更新的JavaBean类;
* 该类提供了对用户的密码认证,用户注册等方法。
* @author kiwwor
* @see Access
*/
public class UserBean {
/**
* 对用户的登录认证
* @param id 用户名
* @param password 密码
* @return 认证结果
*/
public boolean isValid(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id +"and password=" + password;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 用来查询该用户在服务器中是否存在
* @param id 用户名
* @return 确认是否存在
*/
public boolean isExit(String id) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "select * from [user] where id=" + id;
db.query(sql);
if (db.next()) {
b = true;
}
}
db.closeAll();
return b;
}
/**
* 添加用户,该方法必须在<code>isExit(String id)</code>确认的前提下使用,否则可能出现异常
* @param id 新增用户名
* @param password 密码
* @return 确认添加是否成功
*/
public boolean add(String id, String password) {
boolean b = false;
Access db =new Access();
if (db.createConnection()) {
String sql = "insert into [user] (id, password) values (" + id + "," + password + ")";
b = db.update(sql);
}
db.closeAll();
return b;
}
}
⑷ springmvc+mybatis怎么使用线程进行数据库操作
首先,你的确定数据的主键是否可以使用序列自增。
如果可以那么你可以在插入数据的时候获取序列里的值,这样数据就不会重复了。
其次,可以创建一个公共方法,进行数据的插入操作,并且方法类型声明为 static synchronized
类型,这样基本上就不会出现数据重复的现象了
最后,要看你是怎么获得待插入源数据了,这个获得数据源的方法也做成static synchronized的公
共方法。
⑸ 如何通过MVC向数据库中添加数据
循环遍历实体,逐个添加实体到数据库就行了啊。
⑹ Spring MVC中怎么实现数据库的增删改查
spring中提供了 一个spring-jdbc,就是对jdbc的使用简化和扩展,增加一些开发效率。如果要了解更详细,可以搜索spring-jdbc使用详情。
具体spring-jdbc使用前,要导入相应的jar包,在applicationContext.xml中配置dataSource和jdbcTemplate就可以使用它了。
添删查改操作:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
public void add(User user){
jdbcTemplate.update("INSERT INTO USER VALUES('"
+ user.getId() + "', '"
+ user.getName() + "', '"
+ user.getSex() + "', '"
+ user.getAge() + "')");
}
public void edit(User user){
jdbcTemplate.update("UPDATE USER SET name = ? WHERE user_id = ?", new Object[] {name, id});
}
public int queryCount(){
int count = jdbcTemplate.queryForInt("SELECT COUNT(*) FROM USER");
}
⑺ mvc 数据库操作放哪层
mvc数据操作model层就是数据逻辑层v就是界面显示层c就是控制器负责strurtsaction调用跳转
⑻ 有没有大神给我讲一下springmvc操作数据库
一直用的是ssh,因为公司要用到SpringMVC,以前也没接触过,所以今天来和大家一起学习一下这个框架,以便工作需要。
例子大家可以到我上传的资源处http://download.csdn.net/download/tjcyjd/4251483下载。
首先我们先来了解一下什么是模式,模式就是解决某一类问题的方法论,把解决这类问题的解决方法归总到理论的高度,这就是模式。模式是一种指导,在一个良好的指导下,有助于开发人员完成任务。做出一个优秀的设计方案,能达到事半功倍的效果。而且会得到解决问题的最佳办法。
mvc模式起源于Smalltalk语言,mvc是Model-View-Controller的简写。mvc减弱了业务逻辑接口和数据接口之间的耦合。使用MVC模式的好处有很多,可靠性强,高重用和可适应性,较低的生命周期成本,快速的部署,可维护性强等。里面的细节在这儿就不作过多的讲解。
SpringMVC的特点:
1、清晰的角色划分,Spring在Model、View和Controller方面提供了一个非常清晰的划分,这3个方面真正是各司其职,各负其责。
2、灵活的配置功能,因为Spring的核心是IOC,同样在实现MVC上,也可以把各种类当做Bean来通过XML进行配置。
3、提供了大量的控制器接口和实现类,这样开发人员可以使用Spring提供的控制器实现类,也可以自己实现控制器接口。
4、SpringMVC是真正的View层实现无关的,它不会强制开发员使用JSP,我们可以使用其他View技术,比如Velocity,Xskt等。
5、国际化支持,Spring的ApplicationContext提供了对国际化的支持,在这里可以很方便的使用。
6、面向接口编程,其实这不仅是springMVC的特点,整个Spring来看,这个特点都是很明显的,因为它使开发人员对程序易于进行测试,并且很方便的进行管理。
7、Spring提供了Web应用开发的一整套流程,而不仅仅是MVC,他们之间可以很方便的结合在一起。下面有一个自己做得例子,做完这个例子后真的体会到了SpringMVC的强大。
下面开始配置我们的Springmvc工程:
首先我们配置WEB-INF目录下的web.xml:
<?xml version="1.0" encoding="UTF-8"?>
<web-app version="2.5"
xmlns="http://java.sun.com/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
<servlet>
<!--springmvc的核心是DispatcherServlet,它负责控制整个页面的请求路径-->
<servlet-name>dispatcherServlet</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<!--初始化参数>/WEB-INF/classes/相当于src目录-->
<init-param>
<!-- 这个param-name必须是contextConfigLocation-->
<param-name>contextConfigLocation</param-name>
<param-value>/WEB-INF/classes/applicationContext.xml</param-value>
</init-param>
<load-on-startup>2</load-on-startup>
</servlet>
<!--拦截所有以do结尾的请求-->
<servlet-mapping>
<servlet-name>dispatcherServlet</servlet-name>
<url-pattern>*.do</url-pattern>
</servlet-mapping>
<!--处理从页面传递中文到后台而出现的中文乱码问题-->
<filter>
<filter-name>encodingFilter</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>UTF-8</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>encodingFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
</web-app>
每次配置好一个文件后建议先启动服务器看看是否产生异常,不然到后期会很难调试和找到异常所在。
WEB.XML配置好以后我们还需要在SRC目录下创建一个db-config.properties文件来存放我们的数据源配置信息:
内容如下:
db.url= jdbc:mysql:///springmvcdb?useUnicode=true&characterEncoding=utf8
db.username=root
db.password=root
db.dirverClass= com.mysql.jdbc.Driver
db-config.properties配置好以后就开始配置applicationContext.xml文件:
<?xml version="1.0"encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
<!-- 定义个缺省的控制适配器 -->
<bean
class="org.springframework.web.servlet.mvc."/>
<!-- 获取配置文件 -->
<bean id="config"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="locations">
<list>
<value>classpath:db-config.properties</value>
</list>
</property>
</bean>
<!-- 获取数据源 -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName">
<value>${db.dirverClass}</value>
</property>
<property name="url">
<value>${db.url}</value>
</property>
<property name="username">
<value>${db.username}</value>
</property>
<property name="password">
<value>${db.password}</value>
</property>
</bean>
<!--
URL到处理器的映射列表可以配置多个
mappings属性健值为URL程序文件地址,而值为处理器的Bean名字,URL程序文件地址可采用路径匹配的模式,如:
com/mvc/t?st.jsp:匹配com/mvc/test.jsp、com/mvc/tast.jsp等 com/mvc /*.jsp
:匹配所有com/mvc/下带jsp后缀的URL com/mvc
/**/test.jsp:匹配所有在com/mvc路径下或子孙路径下的test.jsp com/mvc
/**/*.jsp:匹配所有com/mvc路径下或子孙路径下带.jsp后缀的URL cn/**/web/bla.jsp:匹配
cn/option/web/dog.jsp cn/option/test/web/dog.jsp cn/web/dog.jsp的请求
-->
<bean class="org.springframework.web.servlet.handler.SimpleUrlHandlerMapping">
<property name="mappings">
<value>
user.do=userAction
</value>
</property>
</bean>
<!--定义视图通过internalResourceView来表示使用的是Servlet/jsp技术-->
<bean id="viewResolver"
class="org.springframework成都erp系统软件开发公司http://www.yingtaow.com/erp/?web.servlet.view.InternalResourceViewResolver">
<property name="viewClass">
<value>org.springframework.web.servlet.view.InternalResourceView
</value>
</property>
<!--jsp存放的目录-->
<property name="prefix">
<value>/jsp/</value>
</property>
<!--jsp文件的后缀-->
<property name="suffix">
<value>.jsp</value>
</property>
</bean>
<bean id="userDao" class="com.yjde.springmvc.UserDao">
<property name="dataSource"ref="dataSource"></property>
</bean>
<!--定义控制器-->
<bean id="userAction" class="com.yjde.springmvc.UserController">
<property name="">
<ref bean="userDao"/>
</property>
<property name="commandClass">
<value>com.yjde.springmvc.UserDao</value>
</property>
<property name="viewpage">
<value>userInfo</value>
</property>
</bean>
</beans>
ApplicationContext.xml文件配置好以后我们开始编写具体的JAVA类,我们需要一个Dao类,一个controller类和一个PO
我们在MySql中创建了一张USERMBO表,里面有三个字段 USERID,USERNAME,USERAGE
UserDao类:
package com.yjde.springmvc;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Collection;
import java.util.List;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
@SuppressWarnings("all")
public class UserDao extends JdbcDaoSupport {
private String msg;
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
// 此方法把USEMBO表对应的字段查询出来依次放入userPO中
public Collection<UserPO> doquery() {
String sql = "SELECT T.USERID,T.USERNAME,T.USERAGE FROM USERMBO T";
return super.getJdbcTemplate().query(sql, new RowMapper() {
public Object mapRow(ResultSet rs, int num) throws SQLException {
UserPO user = new UserPO();
user.setUserId(rs.getInt("USERID"));
user.setUserName(rs.getString("USERNAME"));
user.setUserAge(rs.getInt("USERAGE"));
return user;
}
});
}
}
JdbcTemplate是core包的核心类。它替我们完成了资源的创建以及释放工作,从而简化了我们对JDBC的使用。它还可以帮助我们避免一些常见的错误,比如忘记关闭数据库连接。具体请参阅API
Controller类:
package com.yjde.springmvc;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.validation.BindException;
import org.springframework.web.servlet.ModelAndView;
import org.springframework.web.servlet.mvc.SimpleFormController;
@SuppressWarnings("all")
// SimpleFormController是spring提供的表单控制器,把页面中Form中的元素名称设定为和bean中的一样,当传入的时候Spring会自动抓取form中和Bean名称一样的元素值,把它转换成一个bean,使得开发人员可以很方便的使用。
public class UserController extends SimpleFormController {
private String viewpage;
private UserDao ;
public String getViewpage() {
return viewpage;
}
public void setViewpage(String viewpage) {
this.viewpage = viewpage;
}
@Override
protected ModelAndView onSubmit(HttpServletRequest request,
HttpServletResponse response, Object command, BindException errors)
throws Exception {
UserDao tmp = (UserDao) command;
Collection<UserPO> list = .doquery();
List<UserPO> users = new ArrayList<UserPO>();
UserPO user;
for (UserPO userPO : list) {
user = new UserPO();
user.setUserId(userPO.getUserId());
user.setUserName(userPO.getUserName());
user.setUserAge(userPO.getUserAge());
users.add(user);
}
Map mp = new HashMap();
mp.put("list", users);
return new ModelAndView(getViewpage(), mp);
}
public void setDao(UserDao ) {
this. = ;
}
}
UserPO类:
package com.yjde.springmvc;
public class UserPO {
private Integer userId;
private String userName;
private Integer userAge;
public Integer getUserId() {
return userId;
}
public void setUserId(Integer userId) {
this.userId = userId;
}
public String getUserName() {
return userName;
}
public void setUserName(String userName) {
this.userName = userName;
}
public Integer getUserAge() {
return userAge;
}
public void setUserAge(Integer userAge) {
this.userAge = userAge;
}
}
类创建完成以后我们编写两个JSP进行测试:
Index.jsp:
<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
<head>
<base href="<%=basePath%>">
<title>My JSP 'index.jsp' starting page</title>
<meta http-equiv="pragma" content="no-cache">
<meta http-equiv="cache-control" content="no-cache">
<meta http-equiv="expires" content="0">
<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
<meta http-equiv="description" content="This is my page">
<!--
<link rel="stylesheet" type="text/css" href="styles.css">
-->
</head>
<body>
<form action="user.do" method="post">
请输入<input name="msg" type="text" />
<input type="submit" value="提交">
</form>
</body>
</html>