首页 文章 精选 留言 我的

精选列表

搜索[网站开发],共10000篇文章
优秀的个人博客,低调大师

web开发模式

Model1 显示层,控制层,数据层,统一交给jsp或者javabean处理. 处理流程 客户端发送request 到 jsp jsp 执行javabean javabean读取databases 返回 databases 返回给javabean 在返回给jsp 在response 给客户端 问题 代码杂乱即 jsp + dao 方式 model - view - controller 客户端发送request 到servlet 然后servlet 执行javabean javabean用于读取databases 控制器,获取到javabean读取的数据以后,再次返回给jsp,jso生成html文件,response 给客户端分为 显示层 控制层 模型层 EJB 属于SUN提供的分布式组件服务 分为会话bean 实体bean 消息驱动bean 实栗 一个登录程序用户提交登录信息,发送给servlet servlet数据验证失败将会返回给登录页,同时servlet将会调用数据层操作dao,dao到数据库databases进行验证,结果返回给servlet 然后返回两个结果,登录成功,登录失败. 代码如下 创建数据库 no 列名称 描述 1 userid 保存用户的登录id 2 name 用户真实姓名 3 password 用户密码 目录结构如下 ![](https://melovemingming-1253878077.cos.ap-chengdu.myqcloud.com/blog-image/2019/03/2019-03-17%2002-08-04%E5%B1%8F%E5%B9%95%E6%88%AA%E5%9B%BE.png) jdbc层 package com.ming.dbc; import java.sql.Connection; import java.sql.DriverManager; public class DatabaseConnection { private static final String DBDRIVER = "com.mysql.cj.jdbc.Driver"; private static final String DBURL = "jdbc:mysql://47.94.95.84:32786/test"; private static final String DBUSER = "test"; private static final String DBPASSWORD = "ABCcba20170607"; private Connection connection = null; // 连接数据库 public DatabaseConnection() throws Exception{ try{ Class.forName(DBDRIVER); connection = DriverManager.getConnection(DBURL, DBUSER, DBPASSWORD); }catch (Exception e){ throw e; } } // 获得数据库连接 public Connection getConnection(){ return this.connection; } // 数据库关闭 public void close() throws Exception{ if(this.connection != null){ try{ this.connection.close(); }catch (Exception e){ throw e; } } } } dao层 定义接口 package com.ming.dao; import com.ming.vo.User; public interface IUserDAO { /** * 用户登录验证 * @param user 传入VO对象 * @return 验证操作结果 * @throws Exception 抛出错误 */ public boolean findLogin(User user) throws Exception; } 实现类 package com.ming.dao; import com.ming.vo.User; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; public class UserDAOImpl implements IUserDAO { // 数据库连接对象 private Connection connection = null; // 操作对象 private PreparedStatement preparedStatement = null; // 数据库连接 public UserDAOImpl(Connection _connection){ this.connection = _connection; } /** * 用户登录验证 * * @param user 传入VO对象 * @return 验证操作结果 * @throws Exception 抛出错误 */ @Override public boolean findLogin(User user) throws Exception { boolean flag = false; try{ String sql = "SELECT name FROM user WHERE userid = ? AND password = ?"; // 获得实例化对象 this.preparedStatement = this.connection.prepareStatement(sql); // 设置id this.preparedStatement.setString(1, user.getUserid()); this.preparedStatement.setString(2, user.getPassword()); ResultSet resultset = this.preparedStatement.executeQuery(); if(resultset.next()){ user.setName(resultset.getString(1)); flag = true; } }catch (Exception e){ throw e; }finally { if(this.preparedStatement != null){ try{ this.preparedStatement.close(); }catch (Exception e){ throw e; } } } return flag; } } 代理类 package com.ming.dao; import com.ming.dbc.DatabaseConnection; import com.ming.vo.User; public class UserDAOProxy implements IUserDAO { private DatabaseConnection databaseConnection = null; private IUserDAO dao = null; public UserDAOProxy(){ try{ this.databaseConnection = new DatabaseConnection(); }catch (Exception e){ e.printStackTrace(); } this.dao = new UserDAOImpl(this.databaseConnection.getConnection()); } /** * 用户登录验证 * * @param user 传入VO对象 * @return 验证操作结果 * @throws Exception 抛出错误 */ @Override public boolean findLogin(User user) throws Exception { boolean flag = false; try{ flag = this.dao.findLogin(user); }catch (Exception e){ throw e; }finally { this.databaseConnection.close(); } return flag; } } 定义代理工厂 package com.ming.factory; import com.ming.dao.IUserDAO; import com.ming.dao.UserDAOProxy; public class DAOFactory { public static IUserDAO getIuserDAOInstance(){ return new UserDAOProxy(); } } 实体关系映射 package com.ming.vo; // 对user表进行映射 public class User { private String userid; private String name; private String password; public String getUserid() { return userid; } public String getName() { return name; } public String getPassword() { return password; } public void setUserid(String userid) { this.userid = userid; } public void setName(String name) { this.name = name; } public void setPassword(String password) { this.password = password; } } 视图层 <%@ page import="java.util.List" %> <%@ page import="java.util.Iterator" %><%-- Created by IntelliJ IDEA. User: ming Date: 19-3-16 Time: 下午11:07 To change this template use File | Settings | File Templates. --%> <%@ page contentType="text/html;charset=UTF-8" language="java" %> <html> <head> <title>Title</title> </head> <body> <h2>用户登录程序</h2> <% List<String> info = (List<String>)request.getAttribute("info"); if(info != null){ Iterator<String> iterator = info.iterator(); while(iterator.hasNext()){ %> <h4><%=iterator.next()%></h4> <% } } %> <form action="loginServlet" method="post"> 用户id <input type="text" name="userid" id="uname"/> 密码 <input type="password" name="userpass" id="password"/> <input type="submit" value="登录" id="submit"/> <input type="reset" value="重置"/> </form> <script> let submit = document.getElementById("submit"); submit.onclick = (event) => { let uname = document.getElementById("uname").value; let password = document.getElementById("password").value; if(!(/^\w{5,15}/.test(uname))){ alert("用户id为5-15位"); return false; } if(!(/^\w{5,15}/.test(password))){ alert("密码必须为5-15位"); return false; } return true; } </script> </body> </html> 配置文件 <!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" > <web-app> <display-name>Archetype Created Web Application</display-name> <servlet> <servlet-name>login</servlet-name> <servlet-class>com.ming.servlrt.LoginServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>login</servlet-name> <url-pattern>/loginServlet</url-pattern> </servlet-mapping> </web-app> mvc运行流程 表单提交到servlet,servlet调用dao进行表单验证,然后dao连接数据库进行验证,验证结果返回给业务层,即servlet,在业务层servlet中获取info等日志信息,然后服务器端跳转到运行结果页面即view层.

优秀的个人博客,低调大师

IOS开发-KVO

一、什么是kvo? key-value observing,观察者模式 观察者,观察对象属性的变化,当被观察者该属性发生变化时,观察者会接收到通知,可以在回调函数中做相应的处理 二、有什么作用? 变化处理操作可以在同一个函数中进行,先前本人都会在每次修改属性值的地方调用后续操作,比较繁琐,修改的地方也比较多,现在只要在同一个函数中操作就可以 用kvo只要做监控就行,更加方便易用,减少代码逻辑 三、使用场景: 当一个控件某个属性变化需要做别的相应操作时,比较适合用kvo,只要当该属性发生变化时,会发消息给观察者,在回调函数中做相应的操作 四、实际例子: 一)解释方法: typedef NS_OPTIONS(NSUInteger, NSKeyValueObservingOptions) { NSKeyValueObservingOptionNew = 0x01,//改变后的值 NSKeyValueObservingOptionOld = 0x02,//改变前的值 NSKeyValueObservingOptionInitial NS_ENUM_AVAILABLE(10_5, 2_0) = 0x04, //addobserving之后会马上调用observeValueForKeyPath,不会等到值改变 NSKeyValueObservingOptionPrior NS_ENUM_AVAILABLE(10_5, 2_0) = 0x08 //分2次调用。在值改变之前和值改变之后 }; NSKeyValueObservingOptionNew =0x01,//改变后的值NSKeyValueObservingOptionOld =0x02,//改变前的值这两个用到的比较多 NSObject(NSKeyValueObserving) //一旦被观察者属性发生改变,就会调用此方法后续操作在这个方法中进行 - (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context; keyPath:是被观察对象的属性,字符串表示 object:被观察对象 change:属性改变的值,字典,通过objectForKey (key为 FOUNDATION_EXPORTNSString*constNSKeyValueChangeKindKey; FOUNDATION_EXPORTNSString*constNSKeyValueChangeNewKey; FOUNDATION_EXPORTNSString*constNSKeyValueChangeOldKey; FOUNDATION_EXPORTNSString*constNSKeyValueChangeIndexesKey; FOUNDATION_EXPORTNSString*constNSKeyValueChangeNotificationIsPriorKeyNS_AVAILABLE(10_5,2_0); 对应addobserving指定的NSKeyValueObservingOptions ) context:需要传输的数据(void *:任意指针类型),一般传(__bridgevoid*)self 或者 nil,用户也能传别的 for example: - (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context { if (context == (__bridge void*)self) { if ([keyPath isEqualToString:kKeyPathForNavigationItemRightBarButtonItems]) { //取值 NSArray *rightBarButtonItems = [change objectForKey:NSKeyValueChangeNewKey]; //需要做操作 self.navigationItem.rightBarButtonItems = rightBarButtonItems; } } else { [super observeValueForKeyPath:keyPath ofObject:objectchange:changecontext:context]; } } -------------------------------------------- 二)接口方法 NSObject(NSKeyValueObserverRegistration) - (void)addObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options context:(void *)context; - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath context:(void *)context NS_AVAILABLE(10_7, 5_0); - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath; NSArray(NSKeyValueObserverRegistration) - (void)addObserver:(NSObject *)observer toObjectsAtIndexes:(NSIndexSet *)indexes forKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options context:(void *)context; - (void)removeObserver:(NSObject *)observer fromObjectsAtIndexes:(NSIndexSet *)indexes forKeyPath:(NSString *)keyPath context:(void *)contextNS_AVAILABLE(10_7,5_0); - (void)removeObserver:(NSObject *)observer fromObjectsAtIndexes:(NSIndexSet *)indexes forKeyPath:(NSString *)keyPath; - (void)addObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options context:(void *)context; - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath context:(void *)context NS_AVAILABLE(10_7, 5_0); - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath; NSOrderedSet(NSKeyValueObserverRegistration) - (void)addObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options context:(void *)context; - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath context:(void *)context NS_AVAILABLE(10_7, 5_0); - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath; NSSet(NSKeyValueObserverRegistration) - (void)addObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath options:(NSKeyValueObservingOptions)options context:(void *)context; - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath context:(void *)context NS_AVAILABLE(10_7, 5_0); - (void)removeObserver:(NSObject *)observer forKeyPath:(NSString *)keyPath; NSObject(NSKeyValueObserverNotification) //这些方法都为了手动通知用到 - (void)willChangeValueForKey:(NSString *)key; - (void)didChangeValueForKey:(NSString *)key; - (void)willChange:(NSKeyValueChange)changeKind valuesAtIndexes:(NSIndexSet *)indexes forKey:(NSString *)key; - (void)didChange:(NSKeyValueChange)changeKind valuesAtIndexes:(NSIndexSet *)indexes forKey:(NSString *)key; - (void)willChangeValueForKey:(NSString *)key withSetMutation:(NSKeyValueSetMutationKind)mutationKind usingObjects:(NSSet *)objects; - (void)didChangeValueForKey:(NSString *)key withSetMutation:(NSKeyValueSetMutationKind)mutationKind usingObjects:(NSSet *)objects; NSObject(NSKeyValueObservingCustomization) + (NSSet *)keyPathsForValuesAffectingValueForKey:(NSString *)keyNS_AVAILABLE(10_5,2_0); + (BOOL)automaticallyNotifiesObserversForKey:(NSString *)key; **addObserver和removeObserver要成对出现 ----------------------------------------------------------------------- **手动通知: 有两种通知观察者的方式,自动通知和手动通知。顾名思义,手动通知需要在值变化时调用 willChangeValueForKey:和didChangeValueForKey: 方法通知调用者。为求简便,我们一般使用自动通知。 要使用手动通知,需要在 automaticallyNotifiesObserversForKey方法中明确告诉cocoa,哪些键值要使用手动通知: forExample: [self willChangeValueForKey:@"frame"]; self.frame = CGRectMake(0,0,320,100); [self didChangeValueForKey:@"frame"]; 这时候就会调用 - (void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary *)change context:(void *)context; //重新实现NSObject类中的automaticallyNotifiesObserversForKey:方法,返回yes表示自动通知。 + (BOOL)automaticallyNotifiesObserversForKey:(NSString*)key { //当这两个值改变时,使用自动通知已注册过的观察者,观察者需要实现observeValueForKeyPath:ofObject:change:context:方法 if ([key isEqualToString:@"frame"]) { return NO; } return [super automaticallyNotifiesObserversForKey:key]; } 这时候frame就必须要手动通知 *手动通知一般不用,为了方便,都自动通知,所以这部分知道就可以了 ----------------------------------------------------------------------- 上面一些接口方法说明NSObject,NSArray,NSSet均实现了以上方法,因此我们不仅可以观察普通对象,还可以观察数组或结合类对象。 一般用的都是观察NSObject的某个属性 对NSArray进行观察是观察NSArray中每个model的属性 NSSet和NSArray差不多,只不过NSSet是无序集合 本文转自 咖啡机(K.F.J) 博客园博客,原文链接:http://www.cnblogs.com/strick/p/4036663.html ,如需转载请自行联系原作者

优秀的个人博客,低调大师

Hive UDF开发

HIVE允许用户使用UDF(user defined function)对数据进行处理。用户可以使用‘show functions’ 查看function list,可以使用'describe function function-name'查看函数说明。 [plain]view plaincopy hive>showfunctions; OK ! != ...... Timetaken:0.275seconds hive>descfunctionsubstr; OK substr(str,pos[,len])-returnsthesubstringofstrthatstartsatposandisoflengthlenorsubstr(bin,pos[,len])-returnsthesliceofbytearraythatstartsatposandisoflengthlen Timetaken:0.095seconds hive提供的build-in函数包括以下几类:1. 关系操作符:包括 = 、 <> 、 <= 、>=等2. 算数操作符:包括 + 、 - 、 *、/等3. 逻辑操作符:包括AND 、 && 、 OR 、 || 等4. 复杂类型构造函数:包括map、struct、create_union等5. 复杂类型操作符:包括A[n]、Map[key]、S.x6. 数学操作符:包括ln(double a)、sqrt(double a)等7. 集合操作符:包括size(Array<T>)、sort_array(Array<T>)等8. 类型转换函数:binary(string|binary)、cast(expr as <type>)9. 日期函数:包括from_unixtime(bigint unixtime[, string format])、unix_timestamp()等10.条件函数:包括if(boolean testCondition, T valueTrue, T valueFalseOrNull)等11. 字符串函数:包括acat(string|binary A, string|binary B...)等12. 其他:xpath、get_json_objectscii(string str)、con 编写Hive UDF有两种方式: 1. extends UDF ,重写evaluate方法 2. extends GenericUDF,重写initialize、getDisplayString、evaluate方法 编写UDF代码实例(更多例子参考https://svn.apache.org/repos/asf/hive/tags/release-0.8.1/ql/src/java/org/apache/hadoop/hive/ql/udf/):功能:大小转小写ToLowerCase.java: [plain]view plaincopy packagetest.udf; importorg.apache.hadoop.hive.ql.exec.UDF; importorg.apache.hadoop.io.Text; publicclassToLowerCaseextendsUDF{ publicTextevaluate(finalTexts){ if(s==null){returnnull;} returnnewText(s.toString().toLowerCase()); } } 功能:计算array中去重后元素个数 UDFArrayUniqElementNumber.java [java]view plaincopy packagetest.udf; importorg.apache.hadoop.hive.ql.exec.Description; importorg.apache.hadoop.hive.ql.exec.UDFArgumentException; importorg.apache.hadoop.hive.ql.exec.UDFArgumentTypeException; importorg.apache.hadoop.hive.ql.metadata.HiveException; importorg.apache.hadoop.hive.ql.udf.generic.GenericUDF; importorg.apache.hadoop.hive.serde2.objectinspector.ListObjectInspector; importorg.apache.hadoop.hive.serde2.objectinspector.ObjectInspector; importorg.apache.hadoop.hive.serde2.objectinspector.ObjectInspectorUtils; importorg.apache.hadoop.hive.serde2.objectinspector.ObjectInspector.Category; importorg.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorFactory; importorg.apache.hadoop.io.IntWritable; /** *UDF: *Getnubmerofobjectswithduplicateelementseliminated *@authorxiaomin.zhou */ @Description(name="array_uniq_element_number",value="_FUNC_(array)-Returnsnubmerofobjectswithduplicateelementseliminated.",extended="Example:\n" +">SELECT_FUNC_(array(1,2,2,3,3))FROMsrcLIMIT1;\n"+"3") publicclassUDFArrayUniqElementNumberextendsGenericUDF{ privatestaticfinalintARRAY_IDX=0; privatestaticfinalintARG_COUNT=1;//NumberofargumentstothisUDF privatestaticfinalStringFUNC_NAME="ARRAY_UNIQ_ELEMENT_NUMBER";//ExternalName privateListObjectInspectorarrayOI; privateObjectInspectorarrayElementOI; privatefinalIntWritableresult=newIntWritable(-1); publicObjectInspectorinitialize(ObjectInspector[]arguments) throwsUDFArgumentException{ //Checkiftwoargumentswerepassed if(arguments.length!=ARG_COUNT){ thrownewUDFArgumentException("Thefunction"+FUNC_NAME +"accepts"+ARG_COUNT+"arguments."); } //CheckifARRAY_IDXargumentisofcategoryLIST if(!arguments[ARRAY_IDX].getCategory().equals(Category.LIST)){ thrownewUDFArgumentTypeException(ARRAY_IDX,"\"" +org.apache.hadoop.hive.serde.Constants.LIST_TYPE_NAME +"\""+"expectedatfunctionARRAY_CONTAINS,but" +"\""+arguments[ARRAY_IDX].getTypeName()+"\"" +"isfound"); } arrayOI=(ListObjectInspector)arguments[ARRAY_IDX]; arrayElementOI=arrayOI.getListElementObjectInspector(); returnPrimitiveObjectInspectorFactory.writableIntObjectInspector; } publicIntWritableevaluate(DeferredObject[]arguments) throwsHiveException{ result.set(0); Objectarray=arguments[ARRAY_IDX].get(); intarrayLength=arrayOI.getListLength(array); if(arrayLength<=1){ result.set(arrayLength); returnresult; } //elementcompare;Algorithmcomplexity:O(N^2) intnum=1; inti,j; for(i=1;i<arrayLength;i++) { ObjectlistElement=arrayOI.getListElement(array,i); for(j=i-1;j>=0;j--) { if(listElement!=null){ Objecttmp=arrayOI.getListElement(array,j); if(ObjectInspectorUtils.compare(tmp,arrayElementOI,listElement, arrayElementOI)==0){ break; } } } if(-1==j) { num++; } } result.set(num); returnresult; } publicStringgetDisplayString(String[]children){ assert(children.length==ARG_COUNT); return"array_uniq_element_number("+children[ARRAY_IDX]+")"; } } 生成udf.jarhive有三种方法使用自定义的UDF函数 1. 临时添加UDF如下: [plain]view plaincopy hive>select*fromtest; OK Hello wORLD ZXM ljz Timetaken:13.76seconds hive>addjar/home/work/udf.jar; Added/home/work/udf.jartoclasspath Addedresource:/home/work/udf.jar hive>createtemporaryfunctionmytestas'test.udf.ToLowerCase'; OK Timetaken:0.103seconds hive>showfunctions; ...... mytest ...... hive>selectmytest(test.name)fromtest; ...... OK hello world zxm ljz Timetaken:38.218seconds 这种方式在会话结束后,函数自动销毁,因此每次打开新的会话,都需要重新add jar并且create temporary function2. 进入会话前自动创建使用hive -i参数在进入hive时自动初始化 [plain]view plaincopy $cathive_init addjar/home/work/udf.jar; createtemporaryfunctionmytestas'test.udf.ToLowerCase'; $hive-ihive_init Logginginitializedusingconfigurationinfile:/home/work/hive/hive-0.8.1/conf/hive-log4j.properties Hivehistoryfile=/tmp/work/hive_job_log_work_201209200147_1951517527.txt hive>showfunctions; ...... mytest ...... hive>selectmytest(test.name)fromtest; ...... OK hello world zxm ljz 方法2和方法1本质上是相同的,区别在于方法2在会话初始化时自动完成3. 自定义UDF注册为hive内置函数可参考:hive利器自定义UDF+重编译hive 和前两者相比,第三种方式直接将用户的自定义函数作为注册为内置函数,未来使用起来非常简单,但这种方式也非常危险,一旦出错,将是灾难性的,因此,建议如果不是特别通用,并且固化下来的函数,还是使用前两种方式比较靠谱。 本文转自 yntmdr 51CTO博客,原文链接:http://blog.51cto.com/yntmdr/1716940,如需转载请自行联系原作者

资源下载

更多资源
Mario

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长,特征是大鼻子、头戴帽子、身穿背带裤,还留着胡子。与他的双胞胎兄弟路易基一起,长年担任任天堂的招牌角色。

Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring

Spring框架(Spring Framework)是由Rod Johnson于2002年提出的开源Java企业级应用框架,旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念,提供核心容器、应用上下文、数据访问集成等模块,支持整合Hibernate、Struts等第三方框架,其适用范围不仅限于服务器端开发,绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

用户登录
用户注册