executeupdate mysql_executeupdate()

关于

executeupdate()的搜索结果

问题

JFinal 1.4 + druid 0.2.26 model.save()保存怪事?报错

//方法1，用model.save()方式。

private void saveClickNum(Integer type,Long click_pkid,Integer click_num){

…

爱吃鱼的程序员

2020-06-22 16:49:05

0 浏览量

回答数 1

回答

public class DataBase {

private Connection conn = null;

private Statement stmt = null;

private ResultSet rs = null;

public DataBase() {

// oracle 的jdbc 连接

try {

OracleDataSource ds = new OracleDataSource();

ds.setUser(“uamqas02”);

ds.setPassword(“uamqas02”);

ds.setURL(“jdbc:oracle:thin:@localhost:1521:devdb01”);

conn = ds.getConnection();

stmt = conn.createStatement();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

public ResultSet executeQuery(String sql) {

rs = null;

try {

// stmt=conn.createStatement();

rs = stmt.executeQuery(sql);

} catch (SQLException e) {

e.printStackTrace();

System.err.println(“executeQuerty:” + e.getMessage());

}

return rs;

}

// —————————数据库的更新、修改、删除操作————————————————-

public boolean executeUpdate(String sql) // 更新方法(增、删、改)

{

boolean temp = false;

try {

stmt = conn.createStatement();

int i = stmt.executeUpdate(sql);

if (i >= 1)

temp = true;

} catch (SQLException e) {

e.printStackTrace();

System.err.println(“executeUpdate:” + e.getMessage());

}

return temp;

}

public boolean saveOrUpdateCommit(String sql, String sql2) {

boolean temp = true;

try {

conn.setAutoCommit(false);

stmt = conn.createStatement();

stmt.addBatch(sql);

stmt.addBatch(sql2);

stmt.executeBatch();

conn.commit();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

temp = false;

// 回滚

try {

conn.rollback();

} catch (SQLException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

}

try {

conn.commit();

} catch (SQLException e) {

// TODO Auto-generated catch block

temp = false;

e.printStackTrace();

}

return temp;

}

public void closeStmt() {

try {

stmt.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

public void closeConn() {

try {

conn.close();

} catch (SQLException e) {

e.printStackTrace();

}

}

}

蛮大人123

2019-12-02 01:57:48

0 浏览量

回答数 0

回答

query.executeUpdate()也可以执行原生的插入语句。Query query = em.createNativeQuery(“insert into table(column1,column2) values (), (),()”);query.executeUpdate();

小旋风柴进

2019-12-02 01:57:24

0 浏览量

回答数 0

万券齐发助力企业上云，爆款产品低至2.2折起！

限量神券最高减1000，抢完即止！云服务器ECS新用户首购低至0.95折！

回答

第一种Python如果你是用类似sqlalchemy这样的orm数据库

def upload_blob(file_data):

fb = StringIO.StringIO()

file_data.save(fb)

filename = file_data.filename

c_blob_id = None

if filename:

blob = T_Blob()

blob.c_filename = filename

blob.c_blob = fb.getvalue()

db.session.add(blob)

db.session.flush()

c_blob_id = blob.id

return c_blob_id

调用

form = AddFileForm()

if form.validate_on_submit():

user = g.user

c_blob_id = models.upload_blob(form.c_fj.data)

第二种 java jdbc方式插入Oracle

import java.sql.*;

import java.io.*;

import oracle.sql.*;

public class IntoOracle {

public static void main(String[] args) {

try {

DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());

Connection conn = OracleFactory.getOracle();

conn.setAutoCommit(false);

BLOB blob = null;

PreparedStatement pstmt = conn.prepareStatement(“insert into blobtest(id,b) values(?,empty_blob())”);

pstmt.setString(1,”50″);

pstmt.executeUpdate();

pstmt.close();

pstmt = conn.prepareStatement(“select b from blobtest where id= ? for update”);

pstmt.setString(1,”50″);

ResultSet rset = pstmt.executeQuery();

if (rset.next()) blob = (BLOB) rset.getBlob(1);

String fileName = “d:\\bjx.jpg”;

File f = new File(fileName);

FileInputStream fin = new FileInputStream(f);

System.out.println(“file size = ” + fin.available());

pstmt = conn.prepareStatement(“update blobtest set b=? where id=?”);

OutputStream ut = blob.getBinaryOutputStream();

int count = -1, total = 0;

byte[] data = new byte[(int)fin.available()];

fin.read(data);

out.write(data);

fin.close();

out.close();

pstmt.setBlob(1,blob);

pstmt.setString(2,”50″);

pstmt.executeUpdate();

pstmt.close();

conn.commit();

conn.close();

} catch (SQLException e) {

System.err.println(e.getMessage());

e.printStackTrace();

} catch (IOException e) {

System.err.println(e.getMessage());

} catch (Exception e){

e.printStackTrace();

}

}

}

a123456678

2019-12-02 03:03:16

0 浏览量

回答数 0

回答

第一种Python如果你是用类似sqlalchemy这样的orm数据库

def upload_blob(file_data):

fb = StringIO.StringIO()

file_data.save(fb)

filename = file_data.filename

c_blob_id = None

if filename:

blob = T_Blob()

blob.c_filename = filename

blob.c_blob = fb.getvalue()

db.session.add(blob)

db.session.flush()

c_blob_id = blob.id

return c_blob_id

调用

form = AddFileForm()

if form.validate_on_submit():

user = g.user

c_blob_id = models.upload_blob(form.c_fj.data)

第二种 java jdbc方式插入Oracle

import java.sql.*;

import java.io.*;

import oracle.sql.*;

public class IntoOracle {

public static void main(String[] args) {

try {

DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());

Connection conn = OracleFactory.getOracle();

conn.setAutoCommit(false);

BLOB blob = null;

PreparedStatement pstmt = conn.prepareStatement(“insert into blobtest(id,b) values(?,empty_blob())”);

pstmt.setString(1,”50″);

pstmt.executeUpdate();

pstmt.close();

pstmt = conn.prepareStatement(“select b from blobtest where id= ? for update”);

pstmt.setString(1,”50″);

ResultSet rset = pstmt.executeQuery();

if (rset.next()) blob = (BLOB) rset.getBlob(1);

String fileName = “d:\\bjx.jpg”;

File f = new File(fileName);

FileInputStream fin = new FileInputStream(f);

System.out.println(“file size = ” + fin.available());

pstmt = conn.prepareStatement(“update blobtest set b=? where id=?”);

OutputStream ut = blob.getBinaryOutputStream();

int count = -1, total = 0;

byte[] data = new byte[(int)fin.available()];

fin.read(data);

out.write(data);

fin.close();

out.close();

pstmt.setBlob(1,blob);

pstmt.setString(2,”50″);

pstmt.executeUpdate();

pstmt.close();

conn.commit();

conn.close();

} catch (SQLException e) {

System.err.println(e.getMessage());

e.printStackTrace();

} catch (IOException e) {

System.err.println(e.getMessage());

} catch (Exception e){

e.printStackTrace();

}

}

}

以上

a123456678

2019-12-02 03:00:39

0 浏览量

回答数 0

问题

java 怎么多表同时插入到数据库啊？报错

“

public class Add { public void add(String fid,String title,String content){ Connection connection = null; Stat…

因为相信,所以看见。

2020-05-27 10:02:53

8 浏览量

回答数 1

回答

1.去网站下载sqlitejdbc.根据自已需要，下载sqlitejdbc.(sqlitejdbc有两个版本，一种是pure的一种是native的。native的速度快。它放在**-bin.tgz里。我下的就是这种sqlitejdbc-v056-bin.tgz)

下载后解压sqlitejdbc-v056-bin.tg ，有以下几个文件： libsqlitejdbc.so，sqlitejdbc.dll，libsqlitejdbc.jnilib，sqlitejdbc-v056-native.jar。

其中libsqlitejdbc.so是linux下的动态链接库，sqlitejdbc.dll是windows下的动态链接库， libsqlitejdbc.jnilib是Mac下的动态链接库。

3.根据自已的操作系统将sqlitejdbc-v056-native.jar与对应动态链接库放到jdk/jre/lib/ext里。(我的是linux,则将sqlitejdbc-v056-native.jar 与libsqlitejdbc.so 放到jdk/jre/lib/ext中)。

3.如果你只是随便的将sqlitejdbc.jar放在任一目录，并且你又是run in pure-java mode(纯java模式下运行？是这么译吗)请参考https://bitbucket.org/xerial/sqlite-jdbc

4.如果你已看了第三步的网站，以下可以不用看了，下面的介绍只是复述3里面的而已。

5.http://www.xerial.org/trac/Xerial/wiki/SQLiteJDBC 的实例经验证可以运行。

public class Sample

{

public static void main(String[] args) throws ClassNotFoundException

{

// load the sqlite-JDBC driver using the current class loader

Class.forName(“org.sqlite.JDBC”);

Connection connection = null;

try

{

// create a database connection

connection = DriverManager.getConnection(“jdbc:sqlite:sample.db”);

Statement statement = connection.createStatement();

statement.setQueryTimeout(30); // set timeout to 30 sec.

statement.executeUpdate(“drop table if exists person”);

statement.executeUpdate(“create table person (id integer, name string)”);

statement.executeUpdate(“insert into person values(1, ‘leo’)”);

statement.executeUpdate(“insert into person values(2, ‘yui’)”);

ResultSet rs = statement.executeQuery(“select * from person”);

while(rs.next())

{

// read the result set

System.out.println(“name = ” + rs.getString(“name”));

System.out.println(“id = ” + rs.getInt(“id”));

}

}

catch(SQLException e)

{

// if the error message is “out of memory”,

// it probably means no database file is found

System.err.println(e.getMessage());

}

finally

{

try

{

if(connection != null)

connection.close();

}

catch(SQLException e)

{

// connection close failed.

System.err.println(e);

}

}

}

}

蛮大人123

2019-12-02 01:53:02

0 浏览量

回答数 0

回答

String sql=”update emp set ?=? where empno=? “;

try

{

ps=conn.prepareStatement(sql);

ps.setString(1,oldInfo);

ps.setInt(2, infoInt);

ps.setInt(3,empId);

count=ps.executeUpdate();

}

字段不能通过参数方式，改成

String sql=”update emp set “+oldInfo + “=? where empno=? “;

try

{

ps=conn.prepareStatement(sql);

ps.setInt(1, infoInt);

ps.setInt(2,empId);

count=ps.executeUpdate();

}

蛮大人123

2019-12-02 02:09:48

0 浏览量

回答数 0

问题

Spring3+hibernate3 在dao层使用Query的executeUpdate不回滚

Dao层@Overridepublic int updateRetrailState(Integer orsa_id, int srcState, int targetState, String userName) { String hql…

a123456678

2019-12-01 20:23:58

998 浏览量

回答数 1

问题

jdbc连接mysql后数据插不进去，什么问题？

public class test {

public static void main(String[] args) {

try {

String info…

落地花开啦

2019-12-01 20:01:46

1230 浏览量

回答数 2

回答

rs=preStmt.executeUpdate(sql);这句改成rs=preStmt.executeUpdate();executeUpdate(String SQL)执行的静态的SQL语句，其实你是执行了INSERT INTO hr_role (nc_id,name) values (?,?)，就抛出了mysql 语法错误

蛮大人123

2019-12-02 01:53:44

0 浏览量

回答数 0

回答

快照版本这里：http://code.alibabatech.com/mvn/snapshots/com/alibaba/druid/0.2.16-SNAPSHOT

我测试过，问题已经解决了。正式版本下个星期发布。十分感谢！这是postgres-styletypecast表达式，你提问之后，我查文档才懂。下个星期发布版本解决此问题。

createtableTUSER(IDvarchar(36)notnull,CREATEDATETIMEdatetime,MODIFYDATETIMEdatetime,NAMEvarchar(100)notnull,PWDvarchar(32)notnull,primarykey(ID))com.alibaba.druid.sql.parser.ParserException:TODOatcom.alibaba.druid.sql.parser.SQLExprParser.parsePrimaryKey(SQLExprParser.java:1298)atcom.alibaba.druid.sql.parser.SQLCreateTableParser.parseCrateTable(SQLCreateTableParser.java:75)atcom.alibaba.druid.sql.parser.SQLStatementParser.parseCreate(SQLStatementParser.java:556)atcom.alibaba.druid.sql.parser.SQLStatementParser.parseStatementList(SQLStatementParser.java:102)atcom.alibaba.druid.sql.parser.SQLStatementParser.parseStatementList(SQLStatementParser.java:76)atcom.alibaba.druid.sql.visitor.ParameterizedOutputVisitorUtils.parameterize(ParameterizedOutputVisitorUtils.java:42)atcom.alibaba.druid.filter.stat.StatFilter.mergeSql(StatFilter.java:145)atcom.alibaba.druid.filter.stat.StatFilter.createSqlStat(StatFilter.java:629)atcom.alibaba.druid.filter.stat.StatFilter.internalBeforeStatementExecute(StatFilter.java:397)atcom.alibaba.druid.filter.stat.StatFilter.statementExecuteUpdateBefore(StatFilter.java:325)atcom.alibaba.druid.filter.FilterEventAdapter.statement_executeUpdate(FilterEventAdapter.java:324)atcom.alibaba.druid.filter.FilterChainImpl.statement_executeUpdate(FilterChainImpl.java:2373)atcom.alibaba.druid.proxy.jdbc.StatementProxyImpl.executeUpdate(StatementProxyImpl.java:225)atcom.alibaba.druid.pool.DruidPooledStatement.executeUpdate(DruidPooledStatement.java:169)atorg.hibernate.tool.hbm2ddl.SchemaUpdate.execute(SchemaUpdate.java:227)atorg.hibernate.tool.hbm2ddl.SchemaUpdate.execute(SchemaUpdate.java:178)atorg.hibernate.internal.SessionFactoryImpl.(SessionFactoryImpl.java:505)atorg.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1769)atorg.hibernate.cfg.Configuration.buildSessionFactory(Configuration.java:1840)atorg.springframework.orm.hibernate4.LocalSessionFactoryBuilder.buildSessionFactory(LocalSessionFactoryBuilder.java:242)atorg.springframework.orm.hibernate4.LocalSessionFactoryBean.buildSessionFactory(LocalSessionFactoryBean.java:372)atorg.springframework.orm.hibernate4.LocalSessionFactoryBean.afterPropertiesSet(LocalSessionFactoryBean.java:357)atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1514)atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1452)atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:519)atorg.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:456)atorg.springframework.beans.factory.support.AbstractBeanFactory$1.getObject(AbstractBeanFactory.java:294)atorg.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:225)atorg.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:291)atorg.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:193)atorg.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:591)atorg.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:918)atorg.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:469)atorg.springframework.web.context.ContextLoader.configureAndRefreshWebApplicationContext(ContextLoader.java:383)atorg.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:283)atorg.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:111)atorg.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4887)atorg.apache.catalina.core.StandardContext.startInternal(StandardContext.java:5381)atorg.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:150)atorg.apache.catalina.core.ContainerBase.addChildInternal(ContainerBase.java:901)atorg.apache.catalina.core.ContainerBase.addChild(ContainerBase.java:877)atorg.apache.catalina.core.StandardHost.addChild(StandardHost.java:633)atorg.apache.catalina.startup.HostConfig.deployDirectory(HostConfig.java:1113)atorg.apache.catalina.startup.HostConfig$DeployDirectory.run(HostConfig.java:1671)atjava.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441)atjava.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)atjava.util.concurrent.FutureTask.run(FutureTask.java:138)atjava.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)atjava.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)atjava.lang.Thread.run(Thread.java:619)

sqlserver也报错啊

爱吃鱼的程序员

2020-06-22 20:42:32

0 浏览量

回答数 0

问题

javaweb工程的一个功能无法实现请求帮忙

在写一个类似于校园图书馆的网页工程，在还书功能那里遇到麻烦了用的是mysql5.6+myeclipse10 其他功能都运行良好在DAO层/还书/

public void backBook(int bkid, int stid) throws…

a123456678

2019-12-01 20:15:35

820 浏览量

回答数 1

问题

mysql 插入繁体字报错?报错

@jfinal程序插入繁体字mysql的时候报错，数据库设置了utf8，但是依然报错，数据库，表，字段，都设置了utf8。请问大家有什么办法吗

…

爱吃鱼的程序员

2020-06-22 14:09:16

0 浏览量

回答数 1

问题

省略的catch方法应该怎么写？

public class UsersDAO { private Connection con; private PreparedStatement pt; private ResultSet rs; public boolean findU…

蛮大人123

2019-12-01 20:01:36

969 浏览量

回答数 1

问题

有没有办法从准备好的语句中检索自动增量ID?mysql

使用带有预准备语句的Java查询时，是否有一种方法可以从数据库查询中检索自动生成的键。

例如，我知道AutoGeneratedKeys可以按以下方式工作。

stmt = conn.createStat…

保持可爱mmm

2020-05-17 10:05:44

1 浏览量

回答数 1

问题

向mysql数据库中插入数据时报错的问题

下面是我的代码

public class categorydao {

public static void save(category c) throws SQLException{

Connection conn=…

落地花开啦

2019-12-01 19:47:44

2300 浏览量

回答数 3

问题

dbcp 导致oracle存在很多incative session

往oracle数据库里插入数据，Connection 是从DBCP里拿到的，在插入后对Connection和PreparedStament都有作finally{.close()}处理，但是发现oracle中v$session 存在很多ina…

蛮大人123

2019-12-01 19:54:34

1363 浏览量

回答数 1

回答

`connection.setAutoCommit(false); stmt = connection.prepareStatement(sql,Statement.RETURN_GENERATED_KEYS); stmt.executeUpdate(); ResultSet keys = stmt.getGeneratedKeys(); if(keys.next()){key = keys.getLong(1);} connection.commit();`

落地花开啦

2019-12-02 01:44:15

0 浏览量

回答数 0

问题

将截断字符串或二进制数据问题

public void actionPerformed(ActionEvent e) {

if(e.getSource()==jb1){

Connection ct=null;

Statement stm=null;

PreparedSt…

蛮大人123

2019-12-01 19:36:20

1941 浏览量

回答数 1

问题

更新ORACLE数据库DATE类型的字段时报错：报错

@JFinal 你好，想跟你请教个问题：

Jfinal通过Druid操作Oracle数据库，更新日期类型(DATE类型)的字段失败以下是代码

Test test…

kun坤

2020-06-20 13:28:20

1 浏览量

回答数 1

问题

更新ORACLE数据库DATE类型的字段时报错?报错

@JFinal 你好，想跟你请教个问题：

Jfinal通过Druid操作Oracle数据库，更新日期类型(DATE类型)的字段失败以下是代码

Test test…

爱吃鱼的程序员

2020-06-12 10:31:34

0 浏览量

回答数 1

问题

更新ORACLE数据库DATE类型的字段时报错 配置报错

@JFinal 你好，想跟你请教个问题：     Jfinal通过Druid操作Oracle数据库，更新日期类型(DATE类型)的字段失败以下是代码

Test test= Test…

kun坤

2020-05-30 23:33:31

0 浏览量

回答数 1

问题

关于 Hibernate 中 update 不执行，不报错 求解！

最近调试的时候，发现 之前写好的 项目出了问题。

就是在执行 update、delete 的时候， 不执行，但是也不报错。

配置输出 SQL语句的时候，看不到 SQL语句。数据库中也没有任何变化。

爬文了两天没有结果， 但是发现 如果使…

爵霸

2019-12-01 20:06:20

1626 浏览量

回答数 1

问题

我从txt文本中读取中文文本然后存到mysql数据库中，中文变成了乱码！

public static void JD() throws IOException{

File input =new File(“/Users/huboqin/Downloads/网页1/京东/jd450.html”);

…

爵霸

2019-12-01 19:54:27

1013 浏览量

回答数 1

问题

jdbc报错

PreparedStatement preStmt=null;

int rs=0;

String sql = “INSERT INTO hr_role (nc_id,name) values (?,?)”; …

蛮大人123

2019-12-01 20:02:15

995 浏览量

回答数 1

问题

java的DriverManager.getConnection返回同一个connection报错

我启动了十个线程去测试一个业务方法，但有时候会报出连接已经关闭，无法继续操作的异常。直接上代码了：首先是测试代码：

public class Test {

public st…

因为相信,所以看见。

2020-05-27 10:04:26

7 浏览量

回答数 1

回答

如果需求变化不大！mybatis也是个不错的选择######既然是SSH，那么就交给Spring来管理你的hibernate的sessionFactory， 然后通过sessionFactory来进行相应的数据操作。 Spring和Hibernate的集成，google下，应该有很多标准的配置。######可以看下springside里面的dao，封装的不错######我用ssh做一个增删改查的小案例,用的很模糊,各位朋友可否指导一下呢,小弟谢过了.######

/** 写一段给你，希望对你有帮助 * / import java.io.Serializable; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; import java.util.; import org.hibernate.; import org.hibernate.type.Type; import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

public class BaseHibernateDao extends HibernateDaoSupport {

public BaseHibernateDao()

{

}

public void delete(Object entity)

{

getHibernateTemplate().delete(entity);

}

public void delete(Serializable id, Class clazz)

{

delete(getEntity(id, clazz));

}

public void deleteAll(Collection c)

{

for (Iterator iter = c.iterator(); iter.hasNext(); delete(iter.next()));

}

public void evict(Object entity)

{

getHibernateTemplate().evict(entity);

}

public void executeSql(String sql)

{

Connection con;

Session session = getSession();

con = session.connection();

PreparedStatement pst = null;

try {

pst = con.prepareStatement(sql);

pst.execute();

pst.close();

} catch (Exception e) {

throw new BusinessException(“执行SQL语句时出错！”, e);

} finally {

if (pst != null)

try {

pst.close();

} catch (SQLException e) {

throw new BusinessException(“执行SQL语句时出错！”, e);

}

}

}

public void flush()

{

getHibernateTemplate().flush();

}

private Query genQuery(String hql, Object conditionValues[])

{

Query query = genQuery(hql);

setQueryConditionValue(hql, conditionValues, query);

return query;

}

private Query genQuery(String hql)

{

return getSession().createQuery(hql);

}

public List getEntities(String hql, Object conditionValues[])

{

Query query = genQuery(hql, conditionValues);

return query.list();

}

public List getEntities(String hql)

{

Query query = genQuery(hql);

return query.list();

}

public List getEntities(String hql, Object conditionNames[], Object conditionValues[])

{

Query query = getQuery(hql, conditionNames, conditionValues);

return query.list();

}

public Query getQuery(String hql, Object conditionNames[], Object conditionValues[])

{

if (conditionNames.length != conditionValues.length)

throw new BusinessException(“参数和值的数组长度不匹配，长度必需相等！”);

getHibernateTemplate().setCacheQueries(true);

Query query = getSession().createQuery(hql);

if (conditionValues != null)

{

for (int i = 0; i < conditionValues.length; i++)

{

Object param = conditionValues[i];

if (param == null)

throw new BusinessException((new StringBuilder(“执行HQL为：”)).append(hql).append(” 查询的时候验证参数出错，第 “).append(i + 1).append(” 个参数值为null！”).toString());

if (param instanceof Object[])

query.setParameterList((String)conditionNames[i], (Object[])param);

else

if (param instanceof Collection)

query.setParameterList((String)conditionNames[i], (Collection)param);

else

query.setParameter((String)conditionNames[i], param);

}

}

return query;

}

public List getEntitiesByNativeSql(String nativeSql, String kids[], Class clazzs[], Object conditionValues[])

{

SQLQuery query = getSession().createSQLQuery(nativeSql);

if (kids.length != clazzs.length)

throw new BusinessException(“参数和值的数组长度不匹配，长度必需相等！”);

if (clazzs != null)

{

for (int i = 0; i < clazzs.length; i++)

query.addEntity(kids[i], clazzs[i]);

}

if (conditionValues != null)

{

for (int i = 0; i < conditionValues.length; i++)

{

Object param = conditionValues[i];

if (param == null)

throw new BusinessException((new StringBuilder(“执行原生SQL为：”)).append(nativeSql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为null！”).toString());

if (param instanceof Object[])

throw new BusinessException((new StringBuilder(“执行原生SQL为：”)).append(nativeSql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为数组！”).toString());

if (param instanceof Collection)

throw new BusinessException((new StringBuilder(“执行原生SQL为：”)).append(nativeSql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为列表！”).toString());

query.setParameter(i, param);

}

}

return query.list();

}

public List getEntitiesByNativeSql(String nativeSql, String kids[], Class clazzs[], Object conditionValues[], String scalars[], Type types[])

{

SQLQuery query = getSession().createSQLQuery(nativeSql);

if (clazzs != null)

{

for (int i = 0; i < clazzs.length; i++)

query.addEntity(kids[i], clazzs[i]);

}

return null;

}

public List getEntitiesByNativeSql(String nativeSql, String kids[], Class clazzs[])

{

SQLQuery query = getSession().createSQLQuery(nativeSql);

if (clazzs != null)

{

for (int i = 0; i < clazzs.length; i++)

query.addEntity(kids[i], clazzs[i]);

}

return query.list();

}

public List getEntitiesByNativeSql(String nativeSql, String kids[], Class clazzs[], String as[], Type atype[])

{

return null;

}

public Object getEntity(Serializable id, Class clazz)

{

Object entity = getHibernateTemplate().get(clazz, id);

return entity != null ? entity : BeanUtil.newInstance(clazz);

}

public Object insert(Object entity)

{

getHibernateTemplate().save(entity);

return entity;

}

public Object loadEntity(Serializable id, Class clazz)

{

Object entity = getHibernateTemplate().load(clazz, id);

return entity != null ? entity : BeanUtil.newInstance(clazz);

}

public Object save(Object entity)

{

if (LogUtil.getIdentify(entity) == null)

getHibernateTemplate().save(entity);

else

getHibernateTemplate().saveOrUpdate(entity);

return entity;

}

private void setQueryConditionValue(String hql, Object conditionValues[], Query query)

{

if (conditionValues != null)

{

for (int i = 0; i < conditionValues.length; i++)

{

Object param = conditionValues[i];

if (param == null)

throw new BusinessException((new StringBuilder(“执行HQL为：”)).append(hql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为null！”).toString());

if (param instanceof Object[])

throw new BusinessException((new StringBuilder(“执行HQL为：”)).append(hql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为数组！”).toString());

if (param instanceof Collection)

throw new BusinessException((new StringBuilder(“执行HQL为：”)).append(hql).append(” 验证参数时出错，第 “).append(i + 1).append(” 个参数值为列表！”).toString());

query.setParameter(i, param);

}

}

}

public Object uniqueResult(String hql, Object conditionValues[])

{

Query query = genQuery(hql, conditionValues);

return query.uniqueResult();

}

public Object update(Object entity)

{

getHibernateTemplate().update(entity);

return entity;

}

public void updateOrDelete(String hql)

{

Session session = getSession();

Query query = session.createQuery(hql);

query.executeUpdate();

session.flush();

session.clear();

}

public void updateOrDelete(String hql, Object conditionValues[])

{

Session session = getSession();

Query query = session.createQuery(hql);

setQueryConditionValue(hql, conditionValues, query);

query.executeUpdate();

session.flush();

session.clear();

}

public void updateOrDetete(String hql, Map map)

{

Query query = getQuery(hql, map.keySet().toArray(), map.values().toArray());

query.executeUpdate();

getSession().flush();

getSession().clear();

}

public List getAllEntitys(Class clazz, String sort[])

{

StringBuffer hql = new StringBuffer(“select o from “);

hql.append(clazz.getName()).append(” o “);

String as[];

int j = (as = sort).length;

for (int i = 0; i < j; i++)

{

String sor = as[i];

if (sor != null && !””.equals(sor))

hql.append(” order by “).append(sor);

}

return getEntities(hql.toString());

}

public PageInfo getEntities_Page(String hql, Object conditionNames[], Object conditionValues[], PageInfo page)

{

Long totalCount = getTotalCount(hql, conditionNames, conditionValues);

Long totalPages = new Long((new Double(Math.ceil(totalCount.longValue() / page.getPageSize().longValue()))).intValue());

totalPages = Long.valueOf(totalCount.longValue() % page.getPageSize().longValue() != 0L ? totalPages.longValue() + (new Long(1L)).longValue() : totalPages.longValue());

PageInfo pageInfo = new PageInfo();

pageInfo.setPageSize(page.getPageSize());

pageInfo.setPage(page.getPage());

pageInfo.setTotalSize(totalCount);

pageInfo.setPageCount(totalPages);

Query query = getQuery(hql, conditionNames, conditionValues);

query.setFirstResult((page.getPage().intValue() – 1) * page.getPageSize().intValue());

query.setMaxResults(page.getPageSize().intValue());

List list = query.list();

pageInfo.setData(list);

return pageInfo;

}

private Long getTotalCount(String hql, Object conditionNames[], Object conditionValues[])

{

Long totalCount = new Long(0L);

String lowerhql = hql.toLowerCase();

String totalHql = new String(“”);

int fIndex = lowerhql.indexOf(” from “);

if (fIndex < 0)

fIndex = 0;

else

fIndex++;

int orderLastIndex = lowerhql.lastIndexOf(” order by “);

if (orderLastIndex > 0)

totalHql = (new StringBuilder(“select count(*) “)).append(hql.substring(fIndex, orderLastIndex)).append(” “).toString();

else

totalHql = (new StringBuilder(“select count(*) “)).append(hql.substring(fIndex)).append(” “).toString();

List list = getEntities(totalHql, conditionNames, conditionValues);

Number num = (Number)list.get(0);

totalCount = new Long(num.longValue());

return totalCount;

}

protected User getOper()

{

User oper = (User)SingleThreadImpl.getInstance().get(“user_context”);

return oper;

}

}######O(∩_∩)O谢谢,非常有用.######批量删除建议修改下,效率太慢.

kun坤

2020-06-09 11:45:32

0 浏览量

回答数 0

问题

JDBC sqlite一直报错？?报错

Class.forName(“org.sqlite.JDBC”);         Connection conn = DriverManager.getConnection(“jdbc:sqlite:t…

爱吃鱼的程序员

2020-06-14 20:53:50

0 浏览量

回答数 1

问题

Spring3+hibernate3 在dao层使用Query的executeU?400报错

Spring3+hibernate3 在dao层使用Query的executeUpdate不回滚? 400 报错

Dao层

@Override public int updateRetrailState(Inte…

爱吃鱼的程序员

2020-05-31 00:40:57

0 浏览量

回答数 1