Module: MY_SQL

Defined in:
lib/common/socket/my_sql.rb

Overview

Mysql reated methods; context support

Instance Method Summary collapse

Instance Method Details

#db_connect(db, host, port, user, pwd) ⇒ Object

功能

连接数据库

example

db_connect “newfriend”, “127.0.0.1”, 3306, “root”, “root”



16
17
18
19
20
21
22
23
24
25
 
# File 'lib/common/socket/my_sql.rb', line 16

def db_connect db, host, port, user, pwd

	dbh = DBI.connect("DBI:Mysql:#{db}:#{host}:#{port}", user, pwd)

	#Context.set "#{host}.#{db}", dbh
	Context.set :DATABASE, db
	Context.set :DB_HOST, host
	Context.set :DBH, dbh
	return dbh
end

#db_disconnect ⇒ Object

功能

断开数据库连接

example

db_disconnect



31
32
33
34
35
36
37
38
 
# File 'lib/common/socket/my_sql.rb', line 31

def db_disconnect
	#dbh = Context.get "#{host}.#{db}"
	dbh = Context.get :DBH		

	if dbh != nil
		dbh.disconnect
	end
end

#db_do(sql) ⇒ Object

功能

发送数据库操作命令

example

db_do “select * from table1;”



44
45
46
47
48
 
# File 'lib/common/socket/my_sql.rb', line 44

def db_do sql
	dbh = Context.get :DBH
	$log.info "DB=#{$globals[:DATABASE]}_HOST=#{$globals[:DB_HOST]}_SQL=#{sql}"
	dbh.do sql
end

#db_execute(sql) ⇒ Object 



60
61
62
63
64
 
# File 'lib/common/socket/my_sql.rb', line 60

def db_execute sql
	dbh = Context.get :DBH
               $log.info "DB=#{$globals[:DATABASE]}_HOST=#{$globals[:DB_HOST]}_SQL=#{sql}"
	dbh.execute(sql)
end

#db_select_one(sql) ⇒ Object

功能

发送数据库操作命令

example

db_select_one “select * from table1;”



54
55
56
57
58
 
# File 'lib/common/socket/my_sql.rb', line 54

def db_select_one sql
	dbh = Context.get :DBH
	$log.info "DB=#{$globals[:DATABASE]}_HOST=#{$globals[:DB_HOST]}_SQL=#{sql}"
	dbh.select_one sql
end