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