Compare commits
No commits in common. "7529cb9114315965dc83e4e2fd095bdb3ddaeced" and "94ebf0a452ac1afe4e6653dd266f755b175f58f0" have entirely different histories.
7529cb9114
...
94ebf0a452
|
|
@ -7,9 +7,10 @@ events {
|
|||
}
|
||||
|
||||
http {
|
||||
lua_package_path '$prefix/src/?/?.lua;$prefix/src/?.lua;/home/frankly/work/AuthPlatform/src/?.lua;/home/frankly/work/AuthPlatform/src/?/?.lua;;';
|
||||
lua_package_cpath '$prefix/src/share/lib/?.so;;';
|
||||
lua_package_path '$profix/src/?/?.lua;$profix/src/?.lua;;';
|
||||
lua_package_cpath '$profix/src/share/lib/?.so;;';
|
||||
|
||||
include system/user.conf
|
||||
# Path of the file with trusted CA certificates.
|
||||
#lua_ssl_trusted_certificate /etc/ssl/certs/ca-certificates.crt;
|
||||
|
||||
|
|
@ -24,7 +25,5 @@ http {
|
|||
log_not_found off;
|
||||
access_log off;
|
||||
}
|
||||
|
||||
include 'system/user.conf';
|
||||
}
|
||||
}
|
||||
|
|
@ -4,23 +4,51 @@
|
|||
--- DateTime: 2025/9/24 15:29
|
||||
---
|
||||
local radix = require("resty.radixtree")
|
||||
local userApi = require("api.system.user")
|
||||
|
||||
local function say_hello(req)
|
||||
ngx.say("Hello, World!")
|
||||
end
|
||||
|
||||
local function get_user(req)
|
||||
local user_id = req.args.id or "unknown"
|
||||
ngx.say("User ID: " .. user_id)
|
||||
end
|
||||
|
||||
local function get_id(req)
|
||||
local args = req.get_uri_args()
|
||||
-- 获取单个参数
|
||||
local id = args["id"] -- 值为 "john"
|
||||
ngx.say("User ID: " .. user_id)
|
||||
end
|
||||
|
||||
local function test(req)
|
||||
local request_method = ngx.var.request_method
|
||||
local args = nil
|
||||
ngx.say(request_method)
|
||||
|
||||
--1、获取参数的值 获取前端提交参数
|
||||
if "GET" == request_method then
|
||||
args = ngx.req.get_uri_args()
|
||||
elseif "POST" == request_method then
|
||||
ngx.req.read_body()
|
||||
args = ngx.req.get_post_args()
|
||||
end
|
||||
end
|
||||
|
||||
local routes = {
|
||||
{
|
||||
paths = { "/api/user" },
|
||||
metadata = { "metadata /user" },
|
||||
methods = { "GET", "POST" },
|
||||
handler = userApi.get_allusers,
|
||||
paths = { "/login/*action" },
|
||||
metadata = { "metadata /login/action" },
|
||||
methods = { "GET", "POST", "PUT" },
|
||||
remote_addrs = { "127.0.0.1", "192.168.0.0/16", "::1", "fe80::/32" }
|
||||
},
|
||||
{
|
||||
paths = { "/api/user/:id" },
|
||||
metadata = { "metadata /user/id" },
|
||||
methods = { "GET", "PUT", "DELETE" },
|
||||
handler = userApi.get_users,
|
||||
paths = { "/user/:name" },
|
||||
metadata = { "metadata /user/name" },
|
||||
methods = { "GET" },
|
||||
},
|
||||
{
|
||||
paths = { "/api/admin/:name", "/api/superuser/:name" },
|
||||
paths = { "/admin/:name", "/superuser/:name" },
|
||||
metadata = { "metadata /admin/name" },
|
||||
methods = { "GET", "POST", "PUT" },
|
||||
filter_fun = function(vars, opts)
|
||||
|
|
@ -29,23 +57,23 @@ local routes = {
|
|||
}
|
||||
}
|
||||
|
||||
local rx, err = radix.new(routes)
|
||||
if not rx then
|
||||
ngx.say("-----")
|
||||
local function handle_request()
|
||||
--获取接口请求的方法
|
||||
local request_method = ngx.var.request_method
|
||||
ngx.say(request_method)
|
||||
|
||||
local args = ngx.var.get_uri_args
|
||||
ngx.say(request_method)
|
||||
|
||||
local uri = ngx.var.request_uri
|
||||
ngx.say("url: " .. uri)
|
||||
local handler = routes[uri]
|
||||
if handler then
|
||||
handler(ngx.req)
|
||||
else
|
||||
ngx.status = 404
|
||||
ngx.say("Not Found")
|
||||
--ngx.exit()
|
||||
end
|
||||
end
|
||||
|
||||
local uri = ngx.var.uri
|
||||
local opts = {
|
||||
method = ngx.var.request_method,
|
||||
matched = {}
|
||||
}
|
||||
|
||||
local ok = rx:dispatch(uri, opts, opts.matched)
|
||||
if not ok then
|
||||
ngx.status = 404
|
||||
ngx.say("Not Found")
|
||||
--ngx.exit()
|
||||
end
|
||||
handle_request()
|
||||
|
|
@ -4,16 +4,17 @@
|
|||
--- DateTime: 2025/9/25 08:19
|
||||
---
|
||||
|
||||
local _M = {}
|
||||
local db_config = require('config.database')
|
||||
local pgmoon = require('share.pgmoonn')
|
||||
|
||||
--获取所有用户信息
|
||||
function _M.get_allusers()
|
||||
-- 创建一个新的连接
|
||||
local conn = pgmoon.new(db_config.postgres)
|
||||
|
||||
-- 连接到数据库
|
||||
conn:connect(function(err)
|
||||
if err then
|
||||
print("Error connecting to database: ", err)
|
||||
else
|
||||
print("Connected to the PostgreSQL server.")
|
||||
end
|
||||
|
||||
--获取所有用户信息
|
||||
function _M.get_users(req)
|
||||
|
||||
end
|
||||
|
||||
return _M
|
||||
end)
|
||||
|
|
@ -1,12 +1,10 @@
|
|||
---
|
||||
--- Generated by EmmyLua(https://github.com/EmmyLua)
|
||||
--- Created by .
|
||||
--- Created by admin.
|
||||
--- DateTime: 2025/9/25 08:19
|
||||
--- 业务逻辑
|
||||
local cjson = require('cjson')
|
||||
local pgmoon = require('pgmoon');
|
||||
|
||||
local _M = {}
|
||||
local db_config = require('config.database')
|
||||
local pgmoon = require('share.pgmoonn')
|
||||
|
||||
-- 创建一个新的连接
|
||||
local conn = pgmoon.new(db_config.postgres)
|
||||
|
|
@ -19,9 +17,3 @@ conn:connect(function(err)
|
|||
print("Connected to the PostgreSQL server.")
|
||||
end
|
||||
end)
|
||||
|
||||
function _M.getAllUser()
|
||||
|
||||
end
|
||||
|
||||
return _M
|
||||
|
|
@ -27,7 +27,7 @@ local API = require("LuaORM.API")
|
|||
|
||||
-- 2. Configure the ORM
|
||||
API.ORM:initialize({
|
||||
connection = "LuaSQL/PostgreSQL",
|
||||
connection = "LuaSQL/postgres",
|
||||
database = {
|
||||
databaseName = "postgres",
|
||||
userName = "postgres",
|
||||
|
|
@ -397,3 +397,41 @@ end
|
|||
|
||||
local timePassed = os.clock() - startTimeStamp
|
||||
print("\nExecution took " .. timePassed .. " seconds")
|
||||
|
||||
return
|
||||
|
||||
----------------------------- REQUIRE --------------------------------
|
||||
local Table = require("orm.model")
|
||||
local fields = require("orm.tools.fields")
|
||||
|
||||
----------------------------- CREATE TABLE --------------------------------
|
||||
|
||||
local User = Table({
|
||||
__tablename__ = "user",
|
||||
username = fields.CharField({max_length = 100, unique = true}),
|
||||
password = fields.CharField({max_length = 50, unique = true}),
|
||||
age = fields.IntegerField({max_length = 2, null = true}),
|
||||
job = fields.CharField({max_length = 50, null = true}),
|
||||
time_create = fields.DateTimeField({null = true})
|
||||
})
|
||||
|
||||
----------------------------- CREATE DATA --------------------------------
|
||||
local user = User({
|
||||
id = 1,
|
||||
username = "zhangsan",
|
||||
password = "123456",
|
||||
time_create = os.time()
|
||||
})
|
||||
|
||||
--user:save()
|
||||
ngx.say("User " .. user.username .. " has id " .. user.id)
|
||||
-- User Bob Smith has id 1
|
||||
|
||||
----------------------------- GET DATA --------------------------------
|
||||
local first_user = User.get:first()
|
||||
ngx.print("First user name is: " .. first_user.username)
|
||||
-- First user name is: First user
|
||||
|
||||
local users = User.get:all()
|
||||
ngx.print("We get " .. users:count() .. " users")
|
||||
-- We get 5 users
|
||||
|
|
|
|||
Loading…
Reference in New Issue
Block a user