- 浏览: 13203 次
- 性别:
- 来自: 南京
文章分类
最新评论
package com.linewell.modeldesgin.proxy
import com.linewell.modeldesgin.dao.AccessDAO
import scala.collection.mutable.ArrayBuffer
/**
* 代理模式
* Created by ctao on 2015/8/29.
*/
/**
* 抽象主题类:查询特质
*/
trait Searcher {
def doSearch(id: String, pass: String, keyword: String): String
}
/**
* 身份验证业务单例对象
*/
object AccessValidator {
/**
* 验证方法
* @param id 查询的id
* @param pass 用户名
* @return 用户是否合法
*/
def validate(id: String, pass: String): Boolean = {
println(s"数据库验证$id 是否为合法用户")
val params = new ArrayBuffer[Any]()
params += id
val result = AccessDAO.checkUser(params)
/**
* 判断result.head获取第一个元素的name和result.head获取第一个元素的pass和传入的id和pass是否一致
* 一致返回true,否则返回false
*/
if (result.head.getOrElse("name", "null") == id && result.head.getOrElse("pass", "null").toString == pass) {
println("登录成功")
true
} else {
println("登录失败")
false
}
}
}
/**
* 日志记录类
*/
object Logger {
/**
* 记录日志
* @param id 登录id
*/
def log(id: String): Unit = {
val params = new ArrayBuffer[Any]()
params += id
val row = AccessDAO.insertLog(params)
if (row > 0) {
println(s"记录$id 到数据库")
} else {
println("出现异常")
}
}
}
/**
* 真实主题类:具体查询类
*/
object RealSearcher extends Searcher {
/**
* 复写查询方法
* @param id 用户id
* @param pass pass
* @param keyword 关键字
* @return 查询内容
*/
override def doSearch(id: String, pass: String, keyword: String): String = {
println(s"用户:$id 使用关键字$keyword 查询商务信息!")
"具体内容"
}
}
/**
* 代理主题类:代理查询类
*/
object ProxySearcher extends Searcher {
/**
* 真实查询对象
*/
private val realSearcher = RealSearcher
/**
* 身份验证对象
*/
private val accessValidator = AccessValidator
/**
* 日志对象
*/
private val logger = Logger
/**
* 复写查询
* @param id 用户id
* @param pass 密码
* @param keyword 关键字
* @return 查询结果
*/
override def doSearch(id: String, pass: String, keyword: String): String = {
/**
* 判断是否登录成功,如果登录成功则记录到数据库中,并执行真实查询类的查询方法
*/
if (validate(id, pass)) {
log(id)
realSearcher.doSearch(id, pass, keyword)
} else {
null
}
}
/**
* 日志方法,使用日志对象的日志方法
* @param id 用户id
*/
def log(id: String): Unit = logger.log(id)
/**
* 身份验证类
* @param id 用户id
* @param pass 密码
* @return 是否验证成功
*/
def validate(id: String, pass: String): Boolean = accessValidator.validate(id, pass)
}
package com.linewell.modeldesgin.dao
import com.linewell.modeldesgin.DBUtil.MySQLDBConn
import scala.collection.mutable.ArrayBuffer
/**
* 代理帐号操作数据库对象
* Created by ctao on 2015/8/29.
*/
object AccessDAO {
/**
* 查询sql
*/
private val sqlSelect = "select name,pass from user where name = ?"
/**
* 查询
* @param params 参数列表
* @return ArrayBuffer
*/
def checkUser(params: ArrayBuffer[Any]) = MySQLDBConn.Result(sqlSelect, params)
/**
* 插入日志列表sql
*/
private val sqlInsert = "insert into log(userid) values(?)"
/**
* 插入操作
* @param params 参数
* @return 受影响行数
*/
def insertLog(params: ArrayBuffer[Any]) = MySQLDBConn.updateRow(sqlInsert, params)
}
package com.linewell.modeldesgin.DBUtil
import java.sql._
import scala.collection.mutable
import scala.collection.mutable.ArrayBuffer
/**
* Mysql数据库连接
* Created by ctao on 2015/8/29.
*/
object MySQLDBConn {
try {
/**
* 加载驱动
*/
classOf[com.mysql.jdbc.Driver]
} catch {
case e: ClassNotFoundException => e.printStackTrace()
}
/**
* 获取数据库连接
* @return 数据库连接
*/
def connection(): Connection = DriverManager.getConnection(DBUtil.url, DBUtil.username, DBUtil.pass)
/**
* 返回查询的结果保存成ArrayBuffer
* @param sql 执行sql语句
* @param params 参数
* @return ArrayBuffer
*/
def Result(sql: String, params: ArrayBuffer[Any]): ArrayBuffer[mutable.HashMap[Any, Any]] = {
var arrayBuffer = new ArrayBuffer[mutable.HashMap[Any, Any]]()
var conn: Connection = null
var prepare: PreparedStatement = null
var rs: ResultSet = null
try {
conn = connection()
prepare = conn.prepareStatement(sql)
var i = 0
if (params != null) {
if (params.nonEmpty) {
for (s <- params) {
prepare.setObject(i + 1, s)
i += 1
}
}
}
rs = prepare.executeQuery()
while (rs.next()) {
val md = rs.getMetaData
val column = md.getColumnCount
var rowData = new mutable.HashMap[Any, Any]()
for (i <- 1 to column) {
rowData.put(md.getColumnName(i), rs.getObject(i))
}
arrayBuffer += rowData
}
} catch {
case sql: SQLException => sql.printStackTrace()
} finally {
closeAll(conn, prepare, rs)
}
arrayBuffer
}
/**
* 更新受影响行数
* @param sql sql语句
* @param params 参数
* @return 受影响行数
*/
def updateRow(sql: String, params: ArrayBuffer[Any]): Int = {
var conn: Connection = null
var prepare: PreparedStatement = null
try {
conn = connection()
prepare = conn.prepareStatement(sql)
var i = 0
if (params != null) {
if (params.nonEmpty) {
for (s <- params) {
prepare.setObject(i + 1, s)
i += 1
}
}
}
return prepare.executeUpdate()
} catch {
case sql: SQLException => sql.printStackTrace()
} finally {
closeAll(conn, prepare, null)
}
-1
}
/**
* 关闭数据库连接
* @param conn 数据库连接
*/
def closeConn(conn: Connection): Unit = {
conn.close()
}
/**
* 关闭resultSet
* @param resultSet resultSet
*/
def closeResultSet(resultSet: ResultSet): Unit = {
resultSet.close()
}
/**
* 关闭preparedStatement
* @param preparedStatement preparedStatement
*/
def closePreparedStatement(preparedStatement: PreparedStatement): Unit = {
preparedStatement.close()
}
/**
* 关闭全部
* @param connection connection
* @param preparedStatement preparedStatement
* @param resultSet resultSet
*/
def closeAll(connection: Connection, preparedStatement: PreparedStatement, resultSet: ResultSet): Unit = {
if (connection != null) {
closeConn(connection)
}
if (preparedStatement != null) {
closePreparedStatement(preparedStatement)
}
if (resultSet != null) {
closeResultSet(resultSet)
}
}
}
package com.linewell.modeldesgin.proxy
/**
* 测试客户端
* Created by ctao on 2015/8/29.
*/
object Client extends App {
val searcher1: Searcher = ProxySearcher
println(searcher1.doSearch("ctt", "12223", "hello"))
val searcher2: Searcher = ProxySearcher
println(searcher2.doSearch("ct", "12334", "helloworld"))
print(searcher1.eq(searcher2))
}
import com.linewell.modeldesgin.dao.AccessDAO
import scala.collection.mutable.ArrayBuffer
/**
* 代理模式
* Created by ctao on 2015/8/29.
*/
/**
* 抽象主题类:查询特质
*/
trait Searcher {
def doSearch(id: String, pass: String, keyword: String): String
}
/**
* 身份验证业务单例对象
*/
object AccessValidator {
/**
* 验证方法
* @param id 查询的id
* @param pass 用户名
* @return 用户是否合法
*/
def validate(id: String, pass: String): Boolean = {
println(s"数据库验证$id 是否为合法用户")
val params = new ArrayBuffer[Any]()
params += id
val result = AccessDAO.checkUser(params)
/**
* 判断result.head获取第一个元素的name和result.head获取第一个元素的pass和传入的id和pass是否一致
* 一致返回true,否则返回false
*/
if (result.head.getOrElse("name", "null") == id && result.head.getOrElse("pass", "null").toString == pass) {
println("登录成功")
true
} else {
println("登录失败")
false
}
}
}
/**
* 日志记录类
*/
object Logger {
/**
* 记录日志
* @param id 登录id
*/
def log(id: String): Unit = {
val params = new ArrayBuffer[Any]()
params += id
val row = AccessDAO.insertLog(params)
if (row > 0) {
println(s"记录$id 到数据库")
} else {
println("出现异常")
}
}
}
/**
* 真实主题类:具体查询类
*/
object RealSearcher extends Searcher {
/**
* 复写查询方法
* @param id 用户id
* @param pass pass
* @param keyword 关键字
* @return 查询内容
*/
override def doSearch(id: String, pass: String, keyword: String): String = {
println(s"用户:$id 使用关键字$keyword 查询商务信息!")
"具体内容"
}
}
/**
* 代理主题类:代理查询类
*/
object ProxySearcher extends Searcher {
/**
* 真实查询对象
*/
private val realSearcher = RealSearcher
/**
* 身份验证对象
*/
private val accessValidator = AccessValidator
/**
* 日志对象
*/
private val logger = Logger
/**
* 复写查询
* @param id 用户id
* @param pass 密码
* @param keyword 关键字
* @return 查询结果
*/
override def doSearch(id: String, pass: String, keyword: String): String = {
/**
* 判断是否登录成功,如果登录成功则记录到数据库中,并执行真实查询类的查询方法
*/
if (validate(id, pass)) {
log(id)
realSearcher.doSearch(id, pass, keyword)
} else {
null
}
}
/**
* 日志方法,使用日志对象的日志方法
* @param id 用户id
*/
def log(id: String): Unit = logger.log(id)
/**
* 身份验证类
* @param id 用户id
* @param pass 密码
* @return 是否验证成功
*/
def validate(id: String, pass: String): Boolean = accessValidator.validate(id, pass)
}
package com.linewell.modeldesgin.dao
import com.linewell.modeldesgin.DBUtil.MySQLDBConn
import scala.collection.mutable.ArrayBuffer
/**
* 代理帐号操作数据库对象
* Created by ctao on 2015/8/29.
*/
object AccessDAO {
/**
* 查询sql
*/
private val sqlSelect = "select name,pass from user where name = ?"
/**
* 查询
* @param params 参数列表
* @return ArrayBuffer
*/
def checkUser(params: ArrayBuffer[Any]) = MySQLDBConn.Result(sqlSelect, params)
/**
* 插入日志列表sql
*/
private val sqlInsert = "insert into log(userid) values(?)"
/**
* 插入操作
* @param params 参数
* @return 受影响行数
*/
def insertLog(params: ArrayBuffer[Any]) = MySQLDBConn.updateRow(sqlInsert, params)
}
package com.linewell.modeldesgin.DBUtil
import java.sql._
import scala.collection.mutable
import scala.collection.mutable.ArrayBuffer
/**
* Mysql数据库连接
* Created by ctao on 2015/8/29.
*/
object MySQLDBConn {
try {
/**
* 加载驱动
*/
classOf[com.mysql.jdbc.Driver]
} catch {
case e: ClassNotFoundException => e.printStackTrace()
}
/**
* 获取数据库连接
* @return 数据库连接
*/
def connection(): Connection = DriverManager.getConnection(DBUtil.url, DBUtil.username, DBUtil.pass)
/**
* 返回查询的结果保存成ArrayBuffer
* @param sql 执行sql语句
* @param params 参数
* @return ArrayBuffer
*/
def Result(sql: String, params: ArrayBuffer[Any]): ArrayBuffer[mutable.HashMap[Any, Any]] = {
var arrayBuffer = new ArrayBuffer[mutable.HashMap[Any, Any]]()
var conn: Connection = null
var prepare: PreparedStatement = null
var rs: ResultSet = null
try {
conn = connection()
prepare = conn.prepareStatement(sql)
var i = 0
if (params != null) {
if (params.nonEmpty) {
for (s <- params) {
prepare.setObject(i + 1, s)
i += 1
}
}
}
rs = prepare.executeQuery()
while (rs.next()) {
val md = rs.getMetaData
val column = md.getColumnCount
var rowData = new mutable.HashMap[Any, Any]()
for (i <- 1 to column) {
rowData.put(md.getColumnName(i), rs.getObject(i))
}
arrayBuffer += rowData
}
} catch {
case sql: SQLException => sql.printStackTrace()
} finally {
closeAll(conn, prepare, rs)
}
arrayBuffer
}
/**
* 更新受影响行数
* @param sql sql语句
* @param params 参数
* @return 受影响行数
*/
def updateRow(sql: String, params: ArrayBuffer[Any]): Int = {
var conn: Connection = null
var prepare: PreparedStatement = null
try {
conn = connection()
prepare = conn.prepareStatement(sql)
var i = 0
if (params != null) {
if (params.nonEmpty) {
for (s <- params) {
prepare.setObject(i + 1, s)
i += 1
}
}
}
return prepare.executeUpdate()
} catch {
case sql: SQLException => sql.printStackTrace()
} finally {
closeAll(conn, prepare, null)
}
-1
}
/**
* 关闭数据库连接
* @param conn 数据库连接
*/
def closeConn(conn: Connection): Unit = {
conn.close()
}
/**
* 关闭resultSet
* @param resultSet resultSet
*/
def closeResultSet(resultSet: ResultSet): Unit = {
resultSet.close()
}
/**
* 关闭preparedStatement
* @param preparedStatement preparedStatement
*/
def closePreparedStatement(preparedStatement: PreparedStatement): Unit = {
preparedStatement.close()
}
/**
* 关闭全部
* @param connection connection
* @param preparedStatement preparedStatement
* @param resultSet resultSet
*/
def closeAll(connection: Connection, preparedStatement: PreparedStatement, resultSet: ResultSet): Unit = {
if (connection != null) {
closeConn(connection)
}
if (preparedStatement != null) {
closePreparedStatement(preparedStatement)
}
if (resultSet != null) {
closeResultSet(resultSet)
}
}
}
package com.linewell.modeldesgin.proxy
/**
* 测试客户端
* Created by ctao on 2015/8/29.
*/
object Client extends App {
val searcher1: Searcher = ProxySearcher
println(searcher1.doSearch("ctt", "12223", "hello"))
val searcher2: Searcher = ProxySearcher
println(searcher2.doSearch("ct", "12334", "helloworld"))
print(searcher1.eq(searcher2))
}
发表评论
-
linux mongodb3安装
2015-10-29 15:33 261http://blog.csdn.net/cjuexuan/a ... -
scala代码重构(用递归代替var和while)
2015-09-07 19:47 380原有代码,其中使用了while循环和var /** ... -
再探设计模式之观察者模式(股票通知系统)
2015-09-05 10:28 496package com.linewell.modeldesig ... -
再探设计模式之状态模式(纸牌游戏的开发)
2015-09-04 13:52 537状态模式主要用于检测和切换状态,在状态模式下状态的转化对于客户 ... -
再探设计模式之访问者模式
2015-09-03 14:44 478访问者模式的使用条件比较苛刻主要可以以用于新增访问者时只需要 ... -
scala实现访问者模式
2015-09-02 20:54 376package com.linewell.modeldesgi ... -
scala实现模版方法模式
2015-09-02 20:54 415package com.linewell.modeldesgi ... -
scala实现状态模式
2015-09-02 16:37 385package com.linewell.modeldesgi ... -
scala实现观察者模式
2015-09-02 16:35 588package com.linewell.modeldesgi ... -
scala实现迭代器模式
2015-09-01 22:56 465package com.linewell.modeldesgi ... -
scala实现备忘录模式
2015-09-01 22:54 340package com.linewell.modeldesgi ... -
scala实现中介者模式
2015-09-01 14:48 286package com.linewell.modeldesgi ... -
scala实现解释器模式
2015-08-31 20:20 316本来是看解释器模式,但感觉scala的实现的流利接口可以更优雅 ... -
scala实现命令模式
2015-08-30 21:20 269package com.linewell.modeldesgi ... -
scala实现职责链模式
2015-08-30 13:38 304package com.linewell.modeldesgi ... -
scala实现享元模式
2015-08-30 00:17 335package com.linewell.modeldesgi ... -
scala实现外观模式
2015-08-28 21:41 311package com.linewell.modeldesgi ... -
scala实现装饰者模式
2015-08-16 19:52 394package com.linewell.modeldesgi ... -
scala实现组合模式
2015-08-16 11:14 834package com.linewell.modeldesgi ... -
scala实现桥接模式
2015-08-16 11:13 311package com.linewell.modeldesgi ...
相关推荐
scala:Scala和设计模式 ...在当前软件Software设计中最流行要算GoF这本书...用方便性也很重要不妨让我们来看看Scala(种类似Ruby/Lisp的类语言它定程度上降低了模式实现繁琐)中常用 些模式 ; ; ; ; 1.Singleton(单体模式) ;
响应式架构 消息模式Actor实现与Scala.Akka应用集成 响应式架构 消息模式Actor实现与Scala.Akka应用集成
自己用scala实现的朴素贝叶斯算法。最近学习machine learning,由于之前学习了spark,于是使用scala尝试写写代码
差分进化算法的Scala实现_Scala_代码_下载
Scala设计模式,Scala高阶参考书。
消息模式Actor实现与Scala、Akka应用集成
scala 设计模式,详细讲述scala设计模式
不到一百行的代码教你在spark平台中使用scala实现kmeans算法。简单易懂,大量注释。适合初学者参考理解。本程序在intelliJ IDEA2016.1.1 中编程,运行在spark1.6.1 scala2.10.4本地模式下运行成功。 数据集:(其实...
scala for循环中的模式匹配:1)变量模式匹配2)常量模式匹配3)变量绑定模式匹配4)类型模式匹配5)构造函数模式匹配6)序列模式匹配
[Manning Publications] Play 框架开发 (Scala 实现) (英文版) [出版日期] 2013年10月11日[图书页数] 328页 [图书语言] 英语[图书格式] PDF 格式
scala语言和python一样都是交互式的语言,操作简单。这是wordcount的scala实现,简单明了,比java实现简单很多,希望对大家有所帮助
scala连接redis哨兵模式 demo 使用scala的redis库(csdn)————程序
scala正则表达式在模式匹配中的应用:提取模式的分组值,通过代码理解正则表达式与模式匹配的原理。
响应式架构++消息模式Actor实现与Scala.Akka应用集成+,沃恩·弗农+
响应式架构 消息模式Actor实现与Scala.Akka应用集成 高清扫描版
[Packt Publishing] SBT 入门教程 (Scala 实现) (英文版) [Packt Publishing] Getting Started with SBT for Scala (E-Book) ☆ 图书概要:☆ Equip yourself with a high-productivity work environment using ...
Scala语法简明教程.pdf
使用scala实现dvd系统的管理,新增dvd,删除dvd,外借,归还等模块