RELATEED CONSULTING
相关咨询
选择下列产品马上在线沟通
服务时间:8:30-17:00
你可能遇到了下面的问题
关闭右侧工具栏

新闻中心

这里有您想知道的互联网营销解决方案
java锁数据库的代码 java 数据库锁

java实现oracle数据库写锁

ConnectOracle con = new ConnectOracle();

公司主营业务:成都网站制作、成都网站建设、移动网站开发等业务。帮助企业客户真正实现互联网宣传,提高企业的竞争能力。成都创新互联公司是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化,感谢他们对我们的高要求,感谢他们从不同领域给我们带来的挑战,让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。成都创新互联公司推出兰西免费做网站回馈大家。

Connection connect = con.getConnection();

// 设置手动提交事务

connect.setAutoCommit(false);

Statement stmt = connect.createStatement();

// 锁表

stmt.addBatch("lock table t_symbol_code_fee in exclusive mode");

// 此处打上断点后,执行另一个类,你会发现,执行成功后并没有更改记录,因为表已经被锁定。只有提交事务后,TestOracle中执行的修改才能生效。

stmt.executeBatch();

// 提交后自动解锁,回滚时也会自动解锁

connect.commit();

stmt.close();

connect.close();

Java如何实现对Mysql数据库的行锁

用以下sql语句就可以实现行锁定,前提是innodb模式:

SELECT ... FOR UPDATE

或者

SELECT ... LOCK IN SHARE MODE

java如何给数据库加行锁

与java无关,要用sql语句实现

前提目标表要有索引,查询要开启事物,使用select * from tb with(updlock) where col = xxx将一行数据锁住,其他连接不能再修改表

java程序中如何实现对mysql数据库中表的锁定

方法1:用mysql命令锁住表.

public void test() {  

String sql = "lock tables aa1 write";  

// 或String sql = "lock tables aa1 read";   

// 如果想锁多个表 lock tables aa1 read ,aa2 write , .....   

String sql1 = "select * from aa1 ";  

String sql2 = "unlock tables";  

try {  

this.pstmt = conn.prepareStatement(sql);  

this.pstmt1 = conn.prepareStatement(sql1);  

this.pstmt2 = conn.prepareStatement(sql2);  

pstmt.executeQuery();  

pstmt1.executeQuery();  

pstmt2.executeQuery();  

} catch (Exception e) {  

System.out.println("异常" + e.getMessage());  

}  

}

对于read lock 和 write lock官方说明:

1.如果一个线程获得一个表的READ锁定,该线程(和所有其它线程)只能从该表中读取。

如果一个线程获得一个表的WRITE锁定,只有保持锁定的线程可以对表进行写入。

其它的线程被阻止,直到锁定被释放时为止。

2.当您使用LOCK TABLES时,您必须锁定您打算在查询中使用的所有的表。

虽然使用LOCKTABLES语句获得的锁定仍然有效,但是您不能访问没有被此语句锁定的任何的表。

同时,您不能在一次查询中多次使用一个已锁定的表——使用别名代替,

在此情况下,您必须分别获得对每个别名的锁定。

对与read lock 和 write lock个人说明:

1.read lock 和 write lock 是线程级(表级别).

2.在同一个会话中加了read lock锁. 只能对这个表进行读操作.对这个表以外的任何表都无法进行增、删、改、查的操作.

但是在不同会话中,只能对加了read lock的表进行读操作.但可以对read lock以外的表进行增、删、改、查的操作.

3.在同一个会话中加了write lock锁.只能对这个表进行读、写操作.对这个表以外的任何表都无法进行增、删、改、查的操作.

但是在不同会话中,无法对加了write lock的表进行读、写操作.但可以对write lock以外的表进行增、删、改、查的操作.

4.如果表中使用了别名.(SELECT * FROM aa1 AS byname_table)

在对aa1加锁时,必须把别名加上去(lock tables aa1 as byname_table read)

在同一个会话中.必须使用别名进行查询.

在不同的会话中.可以不需要使用别名进行查询.

5.在多个会话中可以对同一个表进行lock read操作.但不能在多个会话中对同一个表进行lock write操作(这些锁将等待已锁的表释放自身的线程锁)

如果多个会话对同一个表进行lock read操作.那么在这些会话中,也只能对以锁的表进行读操作.

6.如果要你锁住了一个表,需要嵌套查询.你必须使用别名,并且,要锁定别名.

例如.lock table aa1 read ,aa1 as byname_table read;

select * from aa1 where id in (select * from aa1 as xx  where id=2);

7.解锁必须用unlock tables;

另:

在JAVA程序中,要想解锁,需要调用 unlock tables来解锁.

如果没有调用unlock tables.

关闭connection 、程序结束 、调用GC 都能解锁.

方法2:用记录锁锁表.

public void test() {  

String sql = "select * from aa1 for update";   

// select * from aa1 lock in share mode;   

try {  

conn.setAutoCommit(false);  

this.pstmt = conn.prepareStatement(sql);  

pstmt.executeQuery();  

} catch (Exception e) {  

System.out.println("异常" + e.getMessage());  

}  

}

1.for update 与 lock in share mode 属于行级锁和页级锁

2.for update 排它锁,lock in share mode 共享锁

3.对于记录锁.必须开启事务.

4.行级锁定事实上是索引记录的锁定.只要是用索引扫描的行(或没索引全表扫描的行),都将被锁住.

5.在不同的隔离级别下还会使用next-key locking算法.即所扫描的行之间的“间隙”也会也锁住(在Repeatable read和Serializable隔离级别下有间隙锁).

6.在mysql中共享锁的含义是:在被共享锁锁住的行,即使内容被修改且并没有提交.在另一个会话中依然看到最新修改的信息.

在同一会话中加上了共享锁.可以对这个表以及这个表以外的所有表进行增、删、改、查的操作.

在不同的会话中.可以查到共享锁锁住行的最新消息.但是在Read Uncommitted隔离级别下不能对锁住的表进行删,

改操作.(需要等待锁释放才能操作...)

在Read Committed隔离级别下不能对锁住的表进行删,改操作.(需要等待锁释放才能操作...)

在Repeatable read隔离级别下不能对锁住行进行增、删、改操作.(需要等待锁释放才能操作...)

在Serializable隔离级别下不能对锁住行进行增、删、改操作.  (需要等待锁释放才能操作...)

7.在mysql中排他锁的含义是:在被排它锁锁住的行,内容修改并没提交,在另一个会话中不会看到最新修改的信息。

在不同的会话中.可以查到共享锁锁住行的最新消息.但是Read Uncommitted隔离级别下不能对锁住的表进行删,

改操作.(需要等待锁释放才能操作...)

在Read Committed隔离级别下不能对锁住的表进行删,改操作.(需要等待锁释放才能操作...)

在Repeatable read隔离级别下不能对锁住行进行增、删、改操作.(需要等待锁释放才能操作...)

在Serializable隔离级别下不能对锁住行进行增、删、改操作. (需要等待锁释放才能操作...)

8.在同一个会话中的可以叠加多个共享锁和排他锁.在多个会话中,需要等待锁的释放.

9.SQL中的update 与 for update是一样的原理.

10.等待超时的参数设置:innodb_lock_wait_timeout=50 (单位秒).

11.任何可以触发事务提交的命令,都可以关闭共享锁和排它锁.

java处理高并发时,使用synchronized代码锁防止同时对数据库某一数据的问题。

首先synchronized不可能做到对某条数据库的数据加锁。它能做到的只是对象锁。

比如数据表table_a中coloum_b的数据是临界数据,也就是你说的要保持一致的数据。你可以定义一个类,该类中定义两个方法read()和write()(注意,所有有关该临界资源的操作都定义在这个类中),再定义一个静态变量作为锁就可以了。

public static final String LOCK = "table_a_b_lock";

public int read(){

synchronized LOCK{

System.out.println("read data...");

}

}

public void write(String data){

synchronized LOCK{

System.out.println("write data:" + data);

}

}

另外,还可以在数据库级别加上锁。数据库本来就支持不同的隔离级别。

求:用Java连接数据库和简单的数据库操作代码

以上的代码都不如哥的 且看哥是怎么写条理清晰的代码的!!!

package dbconnection //java 中不存在没有包的类(讲解详细因为项目需要)

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.Statement;//引入sql数据库包

public class DBConnection{

private Connection conn=null;

private Statement stmt=null;

private Result rs=null;

private String jdbc="com.microsoft.sqlserver.jdbc.SQLServerDriver";

private String driverManager="jdbc:sqlserver://localhost:1433;databasename=HcitPos";

private String user="admin";

private int password="admin";

public DBConnection{

try{

Class.forName("jdbc");

conn.getConnection("driverManager");

}

catch(Exception e){}

}

public selectMethod(String sql){

stmt=conn.createStatement();

rs=stmt.extcuteQuery("sql");

while(rs.next()){

String title=rs.getString("title");//利用javaBean获得数据库中的属性

String name=rs.getString("name");

.......

System.out.println("title");

System.out.println("name");

......

//当然数据库的操作有很多 这里简单介绍下功能的实现

}

}

public void closeDB(){

if(rs != null) rs.close();

if(stmt != null) stmt.close();

if(conn != null) conn.close();

}

}


网页名称:java锁数据库的代码 java 数据库锁
链接URL:http://cqwzjz.cn/article/hjceci.html